attachmentsimple上传图片同时生成缩略图并存到服务器！

ufo1982ufo

由于在微信里遇到了乱码之类的且压缩文件失效（见这个帖子http://bbs.wex5.com/forum.php?mod=viewthread&tid=120874&extra=），于是重新用java做了一个jar专门对上传的图片文件进行压缩。缩略图没有做了，有需要做的适当修改一下文件，同时输出一个小的图片，在前端里保存时就可以用增加的缩略图保存在mysql数据库应该就可以实现了。

大概意思就是：监控图片文件夹，有新增的就进行压缩后替换（需要缩略图的就多增加一句代码定义好宽高），用studio输出jar文件，用bat文件启动该jar并输出日志（正确和出错日志分开），最后用gpedit.msc添加开机脚本（bat文件）。


1、新建项目，包，类3个java文件：




2、ImgResize.java文件如下：

1. package 包名;
   
2. 
   
3. import java.io.*;
   
4. //import java.util.Date;
   
5. import java.awt.*;
   
6. import java.awt.image.*;
   
7. import javax.imageio.ImageIO;
   
8. import com.sun.image.codec.jpeg.*;
   
9. 
   
10. 
    
11. /**
    
12. * 图片压缩处理
    
13. */
    
14. public class ImgResize {
    
15.     private Image img;
    
16.     private int width;
    
17.     private int height;  
    
18.     private String pathtoresize;  
    
19.    
    
20.     /**
    
21.      * 构造函数
    
22.      */
    
23. //    public ImgResize() throws IOException {
    
24.     public ImgResize(String fileName) throws IOException {
    
25.         File file = new File(fileName);// 读入文件
    
26.         pathtoresize = fileName;
    
27.         img = ImageIO.read(file);      // 构造Image对象
    
28.         width = img.getWidth(null);    // 得到源图宽
    
29.         height = img.getHeight(null);  // 得到源图长
    
30.     }
    
31.     /**
    
32.      * 按照宽度还是高度进行压缩
    
33.      * @param w int 最大宽度
    
34.      * @param h int 最大高度
    
35.      */
    
36.     public void resizeFix(int w, int h) throws IOException {
    
37.         if (width / height > w / h) {
    
38.             resizeByWidth(w);
    
39.         } else {
    
40.             resizeByHeight(h);
    
41.         }
    
42.     }
    
43.     /**
    
44.      * 以宽度为基准，等比例放缩图片
    
45.      * @param w int 新宽度
    
46.      */
    
47.     public void resizeByWidth(int w) throws IOException {
    
48.         int h = (int) (height * w / width);
    
49.         resize(w, h);
    
50.     }
    
51.     /**
    
52.      * 以高度为基准，等比例缩放图片
    
53.      * @param h int 新高度
    
54.      */
    
55.     public void resizeByHeight(int h) throws IOException {
    
56.         int w = (int) (width * h / height);
    
57.         resize(w, h);
    
58.     }
    
59.     /**
    
60.      * 强制压缩/放大图片到固定的大小
    
61.      * @param w int 新宽度
    
62.      * @param h int 新高度
    
63.      */
    
64.     public void resize(int w, int h) throws IOException {
    
65.         // SCALE_SMOOTH 的缩略算法 生成缩略图片的平滑度的 优先级比速度高 生成的图片质量比较好 但速度慢
    
66.         BufferedImage image = new BufferedImage(w, h,BufferedImage.TYPE_INT_RGB );  
    
67.         image.getGraphics().drawImage(img, 0, 0, w, h, null); // 绘制缩小后的图
    
68.         File destFile = new File(pathtoresize);
    
69.         FileOutputStream out = new FileOutputStream(destFile); // 输出到文件流
    
70.         // 可以正常实现bmp、png、gif转jpg
    
71.         JPEGImageEncoder encoder = JPEGCodec.createJPEGEncoder(out);
    
72.         encoder.encode(image); // JPEG编码
    
73.         out.close();
    
74.     }
    
75. 
    
76. 
    
77. }

复制代码

3、FileListenerChange.java文件内容：

1. package 包名;
   
2. 
   
3. import java.io.File;
   
4. 
   
5. import org.apache.commons.io.monitor.FileAlterationMonitor;
   
6. import org.apache.commons.io.monitor.FileAlterationObserver;
   
7. 
   
8. public class FileListenerChange {
   
9. 
   
10.     public static void main(String[] args) {
    
11.     try {
    
12.         // 构造观察类主要提供要观察的文件或目录，当然还有详细信息的filter
    
13.         FileAlterationObserver observer = new FileAlterationObserver(
    
14.                 new File("你的图片文件夹路径"), null);
    
15.         // 构造收听类
    
16.         FileListenerAdaptor listener = new FileListenerAdaptor();
    
17.         // 为观察对象添加收听对象
    
18.         observer.addListener(listener);
    
19.         // 配置Monitor，第一个参数单位是毫秒，是监听的间隔；第二个参数就是绑定我们之前的观察对象。
    
20.         FileAlterationMonitor fileMonitor = new FileAlterationMonitor(
    
21.             5000, new FileAlterationObserver[] { observer });
    
22.         // 启动开始监听
    
23.         fileMonitor.start();
    
24.     } catch (Exception e) {
    
25.         System.out.println("监听启动失败!");
    
26.         e.printStackTrace();
    
27.     }
    
28.     }
    
29. }

复制代码

4、监听文件变化，在新建文件时（onFileCreate）写代码，FileListenerAdaptor.java：

1. package 包名;
   
2. 
   
3. import java.io.File;
   
4. import java.io.IOException;
   
5. import java.util.Date;
   
6. 
   
7. import org.apache.commons.io.monitor.FileAlterationListenerAdaptor;
   
8. import org.apache.commons.io.monitor.FileAlterationObserver;
   
9. 
   
10. public class FileListenerAdaptor extends FileAlterationListenerAdaptor {
    
11. 
    
12.     @Override
    
13.     public void onStart(FileAlterationObserver arg0) {
    
14.     System.out.println(new Date()+",begin listening!");
    
15.     super.onStart(arg0);
    
16.     }
    
17. 
    
18.     @Override
    
19.     public void onStop(FileAlterationObserver arg0) {
    
20.     System.out.println(new Date()+",end listening!");
    
21.     super.onStop(arg0);
    
22.     }
    
23. 
    
24.     @Override
    
25.     public void onDirectoryCreate(File fold) {
    
26.     System.out.println(new Date()+",fold: " + fold.getAbsolutePath() + " is created.");
    
27.     super.onDirectoryCreate(fold);
    
28.     }
    
29. 
    
30.     @Override
    
31.     public void onDirectoryChange(File fold) {
    
32.     System.out.println(new Date()+",fold: " + fold.getAbsolutePath() + " is changed.");
    
33.     super.onDirectoryChange(fold);
    
34.     }
    
35. 
    
36.     @Override
    
37.     public void onDirectoryDelete(File fold) {
    
38.     System.out.println(new Date()+",fold: " + fold.getAbsolutePath() + " is deleted.");
    
39.     super.onDirectoryDelete(fold);
    
40.     }
    
41. 
    
42.     @Override
    
43.     public void onFileCreate(File file) {
    
44.     System.out.println(new Date()+",file: " + file.getAbsolutePath() + " is created.");
    
45.     String pathtoresize = file.getAbsolutePath();
    
46.     long size = file.length();
    
47. //    System.out.println("新创建文件大小: " + size);
    
48.     if(size >  262144){
    
49.         System.out.println("新创建文件大小: " + size + "，大于256Kb的图片将被压缩....");
    
50.                 try {
    
51.                         ImgResize imgCom = new ImgResize(pathtoresize);
    
52.                     imgCom.resizeFix(800, 800); //图片的最大尺寸
    
53.                 } catch (IOException e) {
    
54.                         // TODO 自动生成的 catch 块
    
55.                         e.printStackTrace();
    
56.                 }
    
57.     } else{
    
58.         System.out.println("新创建文件大小: " + size + "，小于256Kb，取消压缩....");
    
59.     }
    
60.     super.onFileCreate(file);
    
61.     }
    
62. 
    
63.         @Override
    
64.     public void onFileChange(File file) {
    
65.     System.out.println(new Date()+",file: " + file.getAbsolutePath() + " is changed.");
    
66.     super.onFileChange(file);
    
67.     }
    
68. 
    
69.     @Override
    
70.     public void onFileDelete(File file) {
    
71.     System.out.println(new Date()+",file: " + file.getAbsolutePath() + " is deleted");
    
72.     super.onFileDelete(file);
    
73.     }
    
74. 
    
75. 
    
76. }

复制代码

5、输出为jar文件：



6、创建bat文件，我的bat和jar在一个文件夹下面，日志路径大家自定吧，正确日志每次启动一个文件，错误日志就进行追加，我的为：c:\resize_log，内容如下：

1. @echo off  
   
2. if not defined s set s= && start /min "" %0& exit
   
3. set today=%date:~0,4%-%date:~5,2%-%date:~8,2%
   
4. java -jar xxxxxxxx.jar  >c:\resize_log\log%today%_%time:~0,2%%time:~3,2%%time:~6,2%.txt 2>>c:\resize_log\errolog%today%.txt
   
5. pause

复制代码

7、添加启动脚本：



8、像这个样子：



备注：
由于我本身也是菜鸟，大家也可以晚上查查。这个jar生成后进行监听处理新加入的图片文件，即使attachmentsimple上传的不带扩展名的都可以。
我大概看了一个，不停的张贴图片文件，每次100个，共10次，内存从16.7M一直到500M，之后回落至100M左右，cpu（4核）会有1秒左右到100%，基本都是在30%附件。我还在一台768的虚拟机里测试，内存在15M至60M之间直到处理完照片（200张左右，没有用1000张测试）。

一个重要的问题：在本地测试没有问题，在虚拟机里测试页没有问题，到了服务器会报错：

1. Exception in thread "Thread-0" java.lang.NullPointerException
   
2.         at mfxxl.ImgResize.<init>(ImgResize.java:29)
   
3.         at mfxxl.FileListenerAdaptor.onFileCreate(FileListenerAdaptor.java:51)
   
4.         at org.apache.commons.io.monitor.FileAlterationObserver.doCreate(FileAlterationObserver.java:379)
   
5.         at org.apache.commons.io.monitor.FileAlterationObserver.checkAndNotify(FileAlterationObserver.java:345)
   
6.         at org.apache.commons.io.monitor.FileAlterationObserver.checkAndNotify(FileAlterationObserver.java:335)
   
7.         at org.apache.commons.io.monitor.FileAlterationObserver.checkAndNotify(FileAlterationObserver.java:335)
   
8.         at org.apache.commons.io.monitor.FileAlterationObserver.checkAndNotify(FileAlterationObserver.java:335)
   
9.         at org.apache.commons.io.monitor.FileAlterationObserver.checkAndNotify(FileAlterationObserver.java:335)
   
10.         at org.apache.commons.io.monitor.FileAlterationObserver.checkAndNotify(FileAlterationObserver.java:304)
    
11.         at org.apache.commons.io.monitor.FileAlterationMonitor.run(FileAlterationMonitor.java:182)
    
12.         at java.lang.Thread.run(Unknown Source)
    

复制代码

估计会不会是使用NFS系统引起的不知道，其余的系统都是正常运行，即使低内存也没有出错的情况！
如果后端java基础好还是直接写为好，毕竟自己不行就做了这么一个。结贴！