1.多線程上傳圖片的客戶端

package controller.UploadImage;

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class TcpSendImage {
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("127.0.0.1", 8080);
        OutputStream out = socket.getOutputStream();
        //創(chuàng)建字節(jié)的輸入流微渠，讀取本機(jī)的圖片
        FileInputStream fis = new FileInputStream("/Users/shangri-la/Pictures/timg.jpg");
        // 開始讀寫字節(jié)數(shù)組
        byte[] bytes = new byte[1024];
        int len = 0;
        while ((len = fis.read(bytes)) != -1) {
            out.write(bytes, 0, len);
        }
        // 給服務(wù)器終止方法
        socket.shutdownOutput();
        // 獲取字節(jié)的輸入流
        InputStream in = socket.getInputStream();
        System.out.println((new String(bytes, 0, in.read(bytes))));
        fis.close();
        socket.close();

    }
}

2.多線程上傳圖片的服務(wù)器TcpImageRunable接口

package controller.UploadImage;

import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Random;

public class TcpImageRunable implements Runnable {

    private Socket socket;

    public TcpImageRunable(Socket socket) {
        this.socket = socket;
    }

    public void run() {
        try {
            InputStream in = socket.getInputStream();
            // 將目的文件夾封裝到File對象
            File upload = new File("/Users/shangri-la/upload");
            if (!upload.exists()) {
                upload.mkdirs();
            }

            // 文件名規(guī)則：域名+時間戳+6位的隨機(jī)數(shù)
            String fullName = upload + "/itcost" + System.currentTimeMillis() + new Random().nextInt(6) + ".jpg";

            //創(chuàng)建字節(jié)的輸出流刘离，將圖片寫到目的文件夾中
            FileOutputStream fos = new FileOutputStream(fullName);
            byte[] data = new byte[1024];
            int len = 0;
            while ((len = in.read(data)) != -1) {
                fos.write(data, 0, len);
            }
            OutputStream out = socket.getOutputStream();
            out.write("上傳成功".getBytes());

            fos.close();
            socket.close();
        } catch (Exception ex) {
            System.out.println(ex);
        }
    }
}

3.多線程上傳圖片的服務(wù)器TCPThreadServer調(diào)用Thread類的start（）方法

package controller.UploadImage;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class TCPThreadServer {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(8080);
        while (true) {
            Socket socket = serverSocket.accept();
            new Thread(new TcpImageRunable(socket)).start();
        }
    }
}