[Java] 详解Java实现批量压缩图片裁剪压缩多种尺寸缩略图一键批量上传图片

package com.demo.utils;
 
import java.io.bytearrayoutputstream;
import java.io.file;
import java.io.fileinputstream;
import java.io.filenotfoundexception;
import java.io.fileoutputstream;
import java.io.ioexception;
import java.util.arraylist;
import java.util.list;
 
import org.apache.tomcat.util.codec.binary.base64;
 
/**
 * 创建时间：2019年3月13日 下午9:02:32
 * 项目名称：shsc-batchupload-server
 * 类说明：文件流工具类
 * @author guobinhui
 * @since jdk 1.8.0_51
 */
public class fileutils {
 
  /* 
   * 读取本地物理磁盘目录里的所有文件资源到程序内存 
   */ 
  public static list<file> readfiles(string filedir) {
  file dirpath = new file(filedir);
  //用listfiles()获得子目录和文件
  file[] files = dirpath.listfiles();
  list<file> list1 = new arraylist<file>();
  for (int i = 0; i < files.length; i++) {
   file file = files[i];
   if (!file.isdirectory()) {
    list1.add(files[i]);
    }
  }
   system.out.println("目录图片数量为："+list1.size());
   return list1;
  }
  
  /* 
   * file文件流转为base64的字符串流
   * 注意：通过前端页面上传图片时，用 multipartfile文件流可以接收图片并上传,multipartfile流有很丰富的方法
   * 本案例通过后台小工具上传，需要把图片资源的文件流转为base64格式的流才可以上传
   */ 
  public static string getbase64(file file) {
  fileinputstream fis = null;
  string base64string = null;
  try {
    fis = new fileinputstream(file);
    byte[] buff = new byte[fis.available()];
    fis.read(buff);
    base64string = base64.encodebase64string(buff);
  } catch (filenotfoundexception e) {
    // todo auto-generated catch block
    e.printstacktrace();
  } catch (ioexception e) {
    // todo auto-generated catch block
    e.printstacktrace();
  }   finally{
    if(fis != null){
      try {
        fis.close();
      } catch (ioexception e) {
        // todo auto-generated catch block
        e.printstacktrace();
      }
    }
  }
  return base64string;
  }
  
  /**
  * 将file文件流转为字节数组
  * @param file
  * @return
  */
  public static byte[] getbyte(file file){
  byte[] bytes = null;
  try {
    fileinputstream fis = new fileinputstream(file);
    bytes = new byte[fis.available()];
    fis.read(bytes);
    fis.close();
  } catch (filenotfoundexception e) {
    e.printstacktrace();
  } catch (ioexception e) {
    e.printstacktrace();
  }
  return bytes;
  }
  
  /**
  * 将字节输出流写到指定文件
  * @param os
  * @param file
  */
  public static void writefile(bytearrayoutputstream os, file file){
  fileoutputstream fos = null;
  try {
    byte[] bytes = os.tobytearray();
    if (file.exists()) {
      file.delete();
    }
    fos = new fileoutputstream(file);
    fos.write(bytes);
  } catch (filenotfoundexception e) {
    e.printstacktrace();
  } catch (ioexception e) {
    e.printstacktrace();
  } finally {
    try {
      fos.close();
    } catch (ioexception e) {
      e.printstacktrace();
    }
  }
  }
}

package com.demo.mapper.entity;
 
import java.awt.image;
import java.awt.geom.affinetransform;
import java.awt.image.affinetransformop;
import java.awt.image.bufferedimage;
import java.io.bytearrayinputstream;
import java.io.bytearrayoutputstream;
import java.io.file;
import java.io.fileinputstream;
import java.io.filenotfoundexception;
import java.io.fileoutputstream;
import java.io.ioexception;
import java.io.inputstream;
import java.io.outputstream;
import javax.imageio.imageio;
 
/**
 * 创建时间：2019年3月13日 下午3:35:05
 * 项目名称：shsc-batchupload-server
 * 类说明：图片压缩处理类
 * @author guobinhui
 * @since jdk 1.8.0_51
 */
public class imgcompress {
 
  private image img; 
  private int width; 
  private int height;
  
  /** 
   * 构造函数 
   */
  public imgcompress(string filepath) throws ioexception { 
  file file = new file(filepath);// 读入文件 
  img = imageio.read(file);   // 构造image对象 
  width = img.getwidth(null);  // 得到源图宽 
  height = img.getheight(null); // 得到源图长 
  } 
  public image getimg() {
    return img;
  }
  public void setimg(image img) {
    this.img = img;
  }
  public int getwidth() {
    return width;
  }
  public void setwidth(int width) {
    this.width = width;
  }
  public int getheight() {
    return height;
  }
  public void setheight(int height) {
    this.height = height;
  }
  public void resize(int w, int h,file file,string dir) throws ioexception { 
  // scale_smooth 的缩略算法 生成缩略图片的平滑度的 优先级比速度高 生成的图片质量比较好，但是速度慢 
   bufferedimage tag = new bufferedimage(50,50,bufferedimage.type_int_rgb );
  image img = imageio.read(file);
  image image = img.getscaledinstance(w, h, image.scale_smooth);
  tag.getgraphics().drawimage(image,50, 50, null); // 绘制缩小后的图 
  
  // 将输入文件转换为字节数组
  byte[] bytes = fileutils.getbyte(file);
  // 构造输入输出字节流
  bytearrayinputstream is = new bytearrayinputstream(bytes);
  bytearrayoutputstream os = new bytearrayoutputstream();
  double rate = w/800;//缩放比率
  try {
   // 处理图片
   zoomimage(is,os,rate);
  } catch (exception e) {
   e.printstacktrace();
  }
  // 将字节输出流写入文件
  fileutils.writefile(os,new file(dir+"/"+file.getname()));
  } 
  
  public void zoomimage(inputstream is, outputstream os,double rate) throws exception { 
   bufferedimage bufimg = imageio.read(is);
   affinetransformop ato = new affinetransformop(affinetransform.getscaleinstance(rate,rate), null);
   bufferedimage bufferedimage = ato.filter(bufimg, null);
   imageio.write(bufferedimage, "jpg", os);
 }
}

package com.demo.controller;
 
import java.awt.color;
import java.awt.graphics;
import java.awt.image;
import java.awt.image.bufferedimage;
import java.io.bytearrayinputstream;
import java.io.bytearrayoutputstream;
import java.io.file;
import java.io.fileinputstream;
import java.io.filenotfoundexception;
import java.io.ioexception;
import java.util.arraylist;
import java.util.iterator;
import java.util.list;
 
import javax.imageio.imageio;
 
import org.apache.tomcat.util.codec.binary.base64;
import org.springframework.beans.beanutils;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.web.bind.annotation.requestmapping;
import org.springframework.web.bind.annotation.responsebody;
import org.springframework.web.bind.annotation.restcontroller;
import com.demo.mapper.entity.attachmentmodel;
import com.demo.mapper.entity.imgcompress;
import com.demo.mapper.entity.productpic;
import com.demo.service.ifileservice;
import com.demo.utils.fileutils;
import com.shsc.framework.common.resultinfo;
 
/**
 * 创建时间：2019年3月8日 下午3:03:56
 * 项目名称：shsc-batchupload-server
 * 类说明：图片批量压缩上传
 * @author guobinhui
 * @since jdk 1.8.0_51
 */
@restcontroller
@requestmapping(value="/file")
public class filecontroller {
 
 
@autowired
private ifileservice fileserviceimpl;
 
 
@requestmapping("/test")
@responsebody
public string test() {
 //原始图片目录
 string originalfiledir = "d:/pics/pic1";
 list <file> originalfilelist = readfiles(originalfiledir);
 iterator<file> it = originalfilelist.iterator();
 //压缩后的缩略图目录
 string thumbnaildir = "d:/uploadbasedir/productpic/20190313/thumbnail";
 long startwrite = system.currenttimemillis();
 while(it.hasnext()){
  file file = (file)it.next();
  try {
   imgcompress img = new imgcompress(file.getpath());
   img.resize(50, 50, file, thumbnaildir);
  } catch (ioexception e) {
   // todo auto-generated catch block
   e.printstacktrace();
   return "上传失败!";
  }   
  }
 long endwrite = system.currenttimemillis();
 system.out.println("批量上传文件共计耗时：" +(endwrite-startwrite)/1000+"秒" );  
return "<h1 style='color:red;'>批量上传文件成功,非常棒,压缩上传文件总数量为："+num+",共计耗时"+(endwrite-startwrite)/1000+"秒</h1>";
 } 
}

@requestmapping("/upload")
@responsebody
public string upload(){
  //win环境原始文件目录
  string originalfiledir = "d:/pics/pic1";
  system.out.println("读磁盘文件开始");
  long startread = system.currenttimemillis();
  list <file> originalfilelist = readfiles(originalfiledir);
  long endread = system.currenttimemillis();
  system.out.println("读磁盘文件结束");
  system.out.println("读取磁盘文件共计耗时：" +(endread-startread)+"毫秒" );   
  
  iterator<file> it = originalfilelist.iterator();
  system.out.println("压缩拷贝文件开始");
  long startwrite = system.currenttimemillis();
//  integer size = 500;//每500个图片批量插入一次
//  integer i = 0;
  string productnumber = null;
  
  string thumbnaildir = "d:/uploadbasedir/productpic/20190313/thumbnail";
  string base64 = null;
  string new50picname = "";
  string new100picname = "";
  string new200picname = "";
  string new400picname = "";
  list <productpic> piclist = new arraylist<productpic>();
  int pictype;
  list <integer> sizelist = new arraylist<integer>();
  sizelist.add(0,50);
  sizelist.add(1,100);
  sizelist.add(2,200);
  sizelist.add(3,400);
  
 while(it.hasnext()){
  file file = (file)it.next();
  system.out.println("原始文件路径为："+file.getpath());
  string originalfilename= file.getname();
  string prefixname = originalfilename.substring(0,originalfilename.lastindexof("."));
  string ext = originalfilename.substring(originalfilename.lastindexof("."));
  
  byte[] buff = fileutils.getbyte(file);
  bytearrayinputstream is = new bytearrayinputstream(buff);
  bytearrayoutputstream os = null;
  bufferedimage bi = null;
  base64 = getbase64(file);
  resultinfo<?> r = fileserviceimpl.uploadbase64(base64,originalfilename);
  attachmentmodel att = (attachmentmodel)r.getdata();
  if(originalfilename.indexof('-') == -1) {
   pictype = 1;
   productnumber = prefixname;
  }else {
   pictype = 2;
   productnumber = originalfilename.substring(0,originalfilename.lastindexof("-"));
  }
  if(r.issuccess()) {
   productpic pic = new productpic();
   beanutils.copyproperties(att, pic);
   pic.getpicname();
   pic.setproductid(productnumber);
   pic.setpictype(pictype);
   piclist.add(pic);
  }
  if(originalfilename.indexof('-') == -1) {//不带'-'的是商品主图
   productnumber = prefixname;
   new50picname = productnumber+'-'+ "50×50"+ext;
   new100picname = productnumber+'-'+ "100×100"+ext;
   new200picname = productnumber+'-'+ "200×200"+ext;
   new400picname = productnumber+'-'+ "400×400"+ext;
  }else {
   productnumber = originalfilename.substring(0,originalfilename.lastindexof("-"));
   new50picname = originalfilename.substring(0,originalfilename.lastindexof("."))+'-'+ "50×50"+ext;
   new100picname = originalfilename.substring(0,originalfilename.lastindexof("."))+'-'+ "100×100"+ext;
   new200picname = originalfilename.substring(0,originalfilename.lastindexof("."))+'-'+ "200×200"+ext;
   new400picname = originalfilename.substring(0,originalfilename.lastindexof("."))+'-'+ "400×400"+ext;
  }
  
  try {
   file f = null;
   bi = imageio.read(is);
   for (int i = 0; i < sizelist.size(); i++) {
    os = new bytearrayoutputstream();
    image image = bi.getscaledinstance(sizelist.get(i),sizelist.get(i), image.scale_smooth);
    bufferedimage tag = new bufferedimage(sizelist.get(i),sizelist.get(i),bufferedimage.type_int_rgb);
    graphics g = tag.getgraphics();
    g.setcolor(color.red);
    g.drawimage(image, 0, 0, null); //绘制处理后的图
    g.dispose();
    imageio.write(tag, "jpg", os);
    if(sizelist.get(i) == 50) {
     fileutils.writefile(os,new file(thumbnaildir+"/"+new50picname));
     f = new file(thumbnaildir+"/"+new50picname);
    }else if(sizelist.get(i) == 100) {
     fileutils.writefile(os,new file(thumbnaildir+"/"+new100picname));
     f = new file(thumbnaildir+"/"+new100picname);
    }else if(sizelist.get(i) == 200) {
     fileutils.writefile(os,new file(thumbnaildir+"/"+new200picname));
     f = new file(thumbnaildir+"/"+new200picname);
    }else if(sizelist.get(i) == 400) {
     fileutils.writefile(os,new file(thumbnaildir+"/"+new400picname));
     f = new file(thumbnaildir+"/"+new400picname);
    }
    base64 = getbase64(f);
    resultinfo<?> rr = fileserviceimpl.uploadbase64(base64,f.getname());
    if(rr.issuccess()) {
      attachmentmodel atta = (attachmentmodel)rr.getdata();
      if(atta.getpicname().indexof('-') == -1) {//不带'-'的是商品主图
        pictype = 1;
      }else if(atta.getpicname().indexof("-1.") != -1
          || atta.getpicname().indexof("-2.") != -1
          || atta.getpicname().indexof("-3.") != -1
          || atta.getpicname().indexof("-4.") != -1) {
        pictype = 2;
      }else if((atta.getpicname().indexof("-1-") == -1
          ||atta.getpicname().indexof("-2-") == -1
          ||atta.getpicname().indexof("-3-") == -1
          ||atta.getpicname().indexof("-4-") == -1)
          && atta.getpicname().indexof("-") != -1) {
        pictype = 3;
      }else {
        pictype = 4;
      }
      productpic pic = new productpic();
      beanutils.copyproperties(atta, pic);
      pic.getpicname();
      pic.setproductid(productnumber);
      pic.setpictype(pictype);
      piclist.add(pic);
    }
  } 
  } catch (exception e1) {
    // todo auto-generated catch block
    e1.printstacktrace();
  }
}
int num = fileserviceimpl.insertpics(piclist);
if(num > 0) {
  long endwrite = system.currenttimemillis();
  system.out.println("批量上传文件共计耗时：" +(endwrite-startwrite)/1000+"秒" ); 
  return "<h1 style='color:red;'>批量上传文件成功,非常棒,压缩上传文件总数量为："+num+",共计耗时"+(endwrite-startwrite)/1000+"秒</h1>";
}
return "批量上传文件失败！";
}