package common;
?
import java.awt.Image;
import java.awt.image.BufferedImage;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import javax.imageio.ImageIO;
?
public class ImageCompressionTask implements Runnable{
? ? ??
?? ?private InputStream is;
?? ?private String fileName;
?? ?private int width;
?? ?private int height;
?
?? ?/**
?? ? * 初始化參數(shù)
?? ? * @param is 圖片輸入流
?? ? * @param file ?圖片
?? ? * @param fileName ?圖片名稱(chēng)
?? ? * @param width ? 高
?? ? * @param height ?寬
?? ? */
?? ?public ImageCompressionTask(InputStream is,String fileName,int width,int height) {
?? ??? ?this.is=is;
?? ??? ?this.fileName=fileName;
?? ??? ?this.width=width;
?? ??? ?this.height=height;?? ??? ?
?? ?}
?
?? ?public void run() {
?? ??? ?// TODO Auto-generated method stub
?? ??? ?try{
?? ??? ??? ?this.compressPic();
?? ??? ?}catch(Exception e){
?? ??? ??? ?System.out.println("文件壓縮失敗"+e);
?? ??? ?}
?? ??? ?
?? ?}
?? ?
?? ?private String compressPic() throws Exception{
?? ??? ?String path = "E:\\xie\\";//新圖片存放路徑
?? ??? ?String urlPath = ?path + fileName;
?? ??? ?BufferedImage buffImage;
?? ??? ?FileOutputStream output=null;
?? ??? ?BufferedImage compressPic=null;
?? ??? ?try {
?? ??? ??? ?
?? ??? ??? ?String imagetype = "";
?? ??? ??? ?if(fileName.lastIndexOf(".") != -1){
?? ??? ??? ??? ?imagetype = fileName.substring(fileName.lastIndexOf(".") + 1).toLowerCase();
?? ??? ??? ?}
?? ??? ??? ?
?? ??? ??? ?imagetype = imagetype.toLowerCase(); //文件后綴名
?? ??? ??? ?output=new FileOutputStream(urlPath);
?? ??? ??? ?buffImage=ImageIO.read(is);
?? ??? ??? ?//圖片縮放
?? ??? ??? ?compressPic=compressPicMin(buffImage,width,height);
?? ??? ??? ?//輸出圖片
?? ??? ??? ?ImageIO.write(compressPic, imagetype, output);
?? ??? ?} finally {
?? ??? ??? ?if(output!=null){
?? ??? ??? ? ? try{
?? ??? ??? ? ? ? ?output.close();
?? ??? ??? ? ? }catch(IOException e){
?? ??? ??? ??? ? ? e.getStackTrace();
?? ??? ??? ? ? }
?? ??? ??? ?}
?? ??? ??? ?if(is!=null){
?? ??? ??? ? ? is.close();
?? ??? ??? ?}
?? ??? ?}
?? ??? ?return fileName;
?? ??? ?
?? ?}
?
? ? /**
? ? ?* 圖片等比縮放
? ? ?*@param image 圖片輸入緩存流
? ? ?*@param outputWidth 圖片壓縮到的寬
? ? ?*@param outputHeight 圖片壓縮到的高
? ? ?*@return BufferedImage
? ? ?* */
?? ?private BufferedImage compressPicMin(BufferedImage image,
?? ?int outputWidth, int outputHeight) {
?? ??? ?// TODO Auto-generated method stub
?? ??? ?if(image==null){
?? ??? ??? ?return null;
?? ??? ?}
?? ??? ?
?? ??? ?//如果圖片本身的寬和高均小于要壓縮到的寬和高，則不壓縮直接返回
?? ??? ?if(outputWidth>image.getWidth(null)&&outputHeight>image.getHeight(null)){
?? ??? ??? ?return image;
?? ??? ?}
?? ??? ?
?? ??? ?int newWidth;
?? ??? ?int newHeight;
?? ? ? ?//寬和高等比縮放的率
?? ??? ?double rate1=(double)image.getWidth(null)/(double)outputWidth;
?? ??? ?double rate2=(double)image.getHeight(null)/(double)outputHeight;
?? ??? ?//控制縮放大小
?? ??? ?double rate=rate1<rate2 ? rate1:rate2;
?? ??? ?newWidth=(int) (image.getWidth(null)/rate);
?? ??? ?newHeight=(int) (image.getHeight(null)/rate);
?? ??? ?
?? ??? ?BufferedImage newImage=new BufferedImage(newWidth, newHeight,BufferedImage.TYPE_INT_RGB);
?? ??? ?newImage.createGraphics().drawImage(image.getScaledInstance(newWidth, outputHeight, Image.SCALE_SMOOTH), 0, 0, null);
?
?? ??? ?return newImage;
?? ?}
?? ?
?? ?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;
?? ?}
?
?
}

package test1;?
?
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
?
import common.ImageCompressionTask;
?
?
public class ImageTest {
?
?? ?public static void main(String[] args){
?? ??? ?String imgName = System.currentTimeMillis() + "_" + ((int) (Math.random() * 900) + 100) + "." + "jpg";
?? ??? ?File f=new File("E:\\xie\\xxx.jpg");
?? ??? ?try {
?? ??? ??? ?InputStream input = new FileInputStream(f);
?? ??? ??? ?ImageCompressionTask r=new ImageCompressionTask(input, imgName, 520, 320);
?? ??? ??? ?/*
?? ??? ??? ? * 方法一：
?? ??? ??? ? *?
?? ??? ??? ? Thread thread1 = new Thread(r);
?? ??? ??? ? thread1.start(); // 啟動(dòng)線(xiàn)程
?? ??? ??? ?*/
?? ??? ??? ?
?? ??? ??? ?/*
?? ??? ??? ? * 方法二：使用ThreadPoolExecutor創(chuàng)建線(xiàn)程池，并不提倡我們直接使用ThreadPoolExecutor
?? ??? ??? ? *?
?? ??? ??? ? */
?? ??? ??? ?/* ThreadPoolExecutor executor = new ThreadPoolExecutor(
?? ??? ??? ? ? ? ? ? ? ?5, ?//核心池的大小（即線(xiàn)程池中的線(xiàn)程數(shù)目大于這個(gè)參數(shù)時(shí)，提交的任務(wù)會(huì)被放進(jìn)任務(wù)緩存隊(duì)列）
?? ??? ??? ? ? ? ? ? ? ?10, //線(xiàn)程池最大能容忍的線(xiàn)程數(shù)
?? ??? ??? ? ? ? ? ? ? ?200, //線(xiàn)程存活時(shí)間 ??
?? ??? ??? ? ? ? ? ? ? ?TimeUnit.MILLISECONDS, //參數(shù)keepAliveTime的時(shí)間單位
?? ??? ??? ? ? ? ? ? ? ?new ArrayBlockingQueue<Runnable>(5) //任務(wù)緩存隊(duì)列，用來(lái)存放等待執(zhí)行的任務(wù)
?? ??? ??? ? );
?? ??? ??? ?executor.execute(r);*/
?? ??? ??? ?/*
?? ??? ??? ? * 方法三：并不提倡我們直接使用ThreadPoolExecutor，而是使用Executors類(lèi)中提供的幾個(gè)靜態(tài)方法來(lái)創(chuàng)建線(xiàn)程池
?? ??? ??? ? * ?以下是三個(gè)靜態(tài)方法
?? ??? ??? ? * ?Executors.newCachedThreadPool(); ? ? ? ?//創(chuàng)建一個(gè)緩沖池，緩沖池容量大小為Integer.MAX_VALUE
? ? ? ? ? ? ? ? ? ? ? ? ?* ?Executors.newSingleThreadExecutor(); ? //創(chuàng)建容量為1的緩沖池
? ? ? ? ? ? ? ? ? ? ? ? ?* ?Executors.newFixedThreadPool(int); ? ?//創(chuàng)建固定容量大小的緩沖池
?? ??? ??? ? */
?? ??? ??? ? newCachedThreadPool().execute(r);
?? ??? ??? ? //newSingleThreadExecutor().execute(r);
?? ??? ??? ? //newFixedThreadPool(10).execute(r);
?? ??? ??? ?System.out.println("圖片上傳成功");
?? ??? ?} catch (Exception e) {
?? ??? ??? ?// TODO Auto-generated catch block
?? ??? ??? ?e.printStackTrace();
?? ??? ?}
?? ?}
?? ?
?? ?/*靜態(tài)方法的具體實(shí)現(xiàn)
?? ? * Executors.newCachedThreadPool()
?? ? * 創(chuàng)建一個(gè)緩沖池，緩沖池容量大小為Integer.MAX_VALUE
?? ? */
?? ?public static ExecutorService newCachedThreadPool() {
?? ? ? ?return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
?? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?60L, TimeUnit.SECONDS,
?? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?new SynchronousQueue<Runnable>());
?? ?}
?? ?
?? ?/*靜態(tài)方法的具體實(shí)現(xiàn)
?? ? * Executors.newSingleThreadExecutor()?
?? ? * 創(chuàng)建容量為1的緩沖池
?? ? */
?? ?public static ExecutorService newSingleThreadExecutor() {
?? ? ? ?return ?new ThreadPoolExecutor(1, 1,
?? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?0L, TimeUnit.MILLISECONDS,
?? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?new LinkedBlockingQueue<Runnable>());
?? ?}
?? ?
?? ?/*靜態(tài)方法的具體實(shí)現(xiàn)
?? ? * Executors.newFixedThreadPool(int)?
?? ? * 創(chuàng)建固定容量大小的緩沖池
?? ? */
?? ?public static ExecutorService newFixedThreadPool(int nThreads) {
?? ? ? ?return new ThreadPoolExecutor(nThreads, nThreads,
?? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?0L, TimeUnit.MILLISECONDS,
?? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?new LinkedBlockingQueue<Runnable>());
?? ?}
}