您现在的位置：程式碼之家 >> 編程語言 > >> Java 程式設計 >> Java 相關知識

Java 圖片上傳完整代碼實現與 Socket 通訊詳解

編輯：Java 相關知識

Java 圖片上傳完整代碼實現

本文提供一個基於 Java Socket 通訊的圖片上傳完整代碼範例，包含客戶端發送端與伺服器端接收端的完整實現，適合初學者參考學習網路程式設計與檔案傳輸機制。

核心功能特點

支援 JPG 格式圖片上傳
檔案大小限制 10MB 以內
採用 TCP Socket 可靠傳輸協議
包含上傳狀態回饋機制
多執行緒處理並發連線

客戶端發送端實現 (picsend 類)

import java.io.*;
import java.net.*;

class picsend {
    public static void main(String[] args) throws Exception {
        // 參數檢查
        if(args.length != 1) {
            System.out.println("請選擇一張 .jpg 圖片");
            return;
        }
        
        File file = new File(args[0]);
        // 檔案存在性與格式驗證
        if(!(file.exists() && file.isFile())) {
            System.out.println("圖片有問題(不是檔案或不存在)");
            return;
        }
        if(!file.getName().endsWith(".jpg")) {
            System.out.println("圖片格式錯誤，請重新選擇圖片");
            return;
        }
        if(file.length() > 1024 * 1024 * 10) {
            System.out.println("圖片過大，無法上傳");
            return;
        }
        
        // 建立 Socket 連線
        Socket s = new Socket("192.168.33.1", 10006);
        FileInputStream fis = new FileInputStream(file);
        OutputStream out = s.getOutputStream();
        
        // 分塊讀取並傳輸
        byte[] buffer = new byte[1024];
        int len;
        while((len = fis.read(buffer)) != -1) {
            out.write(buffer, 0, len);
        }
        
        // 關閉輸出流，標記傳輸結束
        s.shutdownOutput();
        
        // 接收伺服器回應
        InputStream in = s.getInputStream();
        byte[] response = new byte[1024];
        int num = in.read(response);
        System.out.println(new String(response, 0, num));
        
        fis.close();
        s.close();
    }
}

伺服器端接收端實現 (picThread 與 picrece 類)


// 處理執行緒類
class picThread implements Runnable {
    private Socket socket;
    
    picThread(Socket socket) {
        this.socket = socket;
    }
    
    public void run() {
        int count = 1;
        String clientIP = socket.getInetAddress().getHostAddress();
        System.out.println(clientIP + ".............connect");
        
        try {
            InputStream in = socket.getInputStream();
            // 避免檔名衝突
            File file = new File(clientIP + "(" + count + ")" + ".jpg");
            while(file.exists()) {
                file = new File(clientIP + "(" + (count++) + ")" + ".jpg");
            }
            
            FileOutputStream fos = new FileOutputStream(file);
            byte[] buffer = new byte[1024];
            int len;
            while((len = in.read(buffer)) != -1) {
                fos.write(buffer, 0, len);
            }
            
            // 發送成功回應
            OutputStream out = socket.getOutputStream();
            out.write("上傳成功！".getBytes());
            
            fos.close();
            socket.close();
        } catch (Exception e) {
            throw new RuntimeException("上傳失敗");
        }
    }
}

// 伺服器主類
class picrece {
    public static void main(String[] args) throws Exception {
        ServerSocket serverSocket = new ServerSocket(10006);
        while(true) {
            Socket socket = serverSocket.accept();
            new Thread(new picThread(socket)).start();
        }
    }
}