Java 實現螢幕廣播與鼠標同步控制的雙通道 Socket 方案

架構設計

採用雙 Socket 通道分離關注點：

• 通道 1 (Port 8002)：服務端推送螢幕截圖（JPG + ZIP 壓縮）
• 通道 2 (Port 8001)：服務端推送鼠標座標（文本協議 Movemouse,x,y）

客戶端並行接收兩個通道數據，分別在 Swing 界面顯示圖片、用 Robot.mouseMove 同步鼠標。

服務端核心代碼

主啟動類

public class BroadCastServer {
    public static void main(String[] args) {
        ExecutorService pool = Executors.newFixedThreadPool(2);
        pool.execute(new SendScreenImg());   // 截圖發送線程
        pool.execute(new SendMouseMessage()); // 鼠標發送線程
        System.out.println("廣播服務已啟動");
    }
}

截圖發送線程 (SendScreenImg)

public class SendScreenImg extends Thread {
    private final int PORT = 8002;
    private final ServerSocket server;
    private final Robot robot;
    private final Rectangle screenRect;

    public SendScreenImg() throws AWTException, IOException {
        server = new ServerSocket(PORT);
        robot = new Robot();
        Dimension size = Toolkit.getDefaultToolkit().getScreenSize();
        screenRect = new Rectangle(size);
    }

    @Override
    public void run() {
        while (true) {
            try (Socket client = server.accept();
                 ZipOutputStream zos = new ZipOutputStream(new DataOutputStream(client.getOutputStream()))) {
                zos.setLevel(9);
                BufferedImage img = robot.createScreenCapture(screenRect);
                zos.putNextEntry(new ZipEntry("screen.jpg"));
                ImageIO.write(img, "jpg", zos);
                zos.closeEntry();
            } catch (IOException e) {
                System.err.println("截圖通道異常: " + e.getMessage());
            }
        }
    }
}

鼠標發送線程 (SendMouseMessage)

public class SendMouseMessage extends Thread {
    private final int PORT = 8001;
    private final ServerSocket server;

    public SendMouseMessage() throws IOException {
        server = new ServerSocket(PORT);
    }

    @Override
    public void run() {
        while (true) {
            try (Socket client = server.accept();
                 DataOutputStream out = new DataOutputStream(client.getOutputStream())) {
                Point pt = MouseInfo.getPointerInfo().getLocation();
                String msg = "Movemouse," + pt.x + "," + pt.y;
                out.write(msg.getBytes());
                out.flush();
            } catch (IOException e) {
                System.err.println("鼠標通道斷開: " + e.getMessage());
            }
        }
    }
}

客戶端核心代碼

主啟動類

public class BroadcastClient {
    private static final String SERVER_IP = "192.168.1.100"; // 替換為服務端 IP

    public static void main(String[] args) {
        ExecutorService pool = Executors.newFixedThreadPool(2);
        pool.execute(new ReceiveImages(SERVER_IP));
        pool.execute(new OperateMouse(SERVER_IP));
    }
}

接收圖片線程 (ReceiveImages)

public class ReceiveImages extends Thread {
    private final String ip;
    private final JFrame frame = new JFrame("遠程桌面");
    private final JLabel imgLabel = new JLabel();

    public ReceiveImages(String ip) {
        this.ip = ip;
        frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        frame.add(imgLabel);
        frame.setSize(800, 600);
        frame.setVisible(true);
    }

    @Override
    public void run() {
        while (frame.isDisplayable()) {
            try (Socket socket = new Socket(ip, 8002);
                 ZipInputStream zis = new ZipInputStream(socket.getInputStream())) {
                zis.getNextEntry();
                Image img = ImageIO.read(zis);
                if (img != null) {
                    SwingUtilities.invokeLater(() -> {
                        imgLabel.setIcon(new ImageIcon(img));
                        frame.pack();
                    });
                }
                Thread.sleep(50); // 幀率控制 ~20fps
            } catch (Exception e) {
                System.err.println("圖片接收異常: " + e.getMessage());
                try { Thread.sleep(1000); } catch (InterruptedException ignored) {}
            }
        }
    }
}

鼠標同步線程 (OperateMouse)

public class OperateMouse extends Thread {
    private final String ip;
    private final Robot robot;

    public OperateMouse(String ip) throws AWTException {
        this.ip = ip;
        this.robot = new Robot();
    }

    @Override
    public void run() {
        while (true) {
            try (Socket socket = new Socket(ip, 8001);
                 DataInputStream in = new DataInputStream(socket.getInputStream())) {
                StringBuilder sb = new StringBuilder();
                int b;
                while ((b = in.read()) != -1) sb.append((char) b);
                String msg = sb.toString().trim();
                if (msg.startsWith("Movemouse")) {
                    String[] parts = msg.split(",");
                    if (parts.length == 3) {
                        int x = Integer.parseInt(parts[1]);
                        int y = Integer.parseInt(parts[2]);
                        robot.mouseMove(x, y);
                    }
                }
            } catch (IOException e) {
                System.err.println("鼠標同步斷開: " + e.getMessage());
                try { Thread.sleep(1000); } catch (InterruptedException ignored) {}
            }
        }
    }
}

關鍵技術點總結

局限與改進方向

• 鼠標座標與螢幕分辨率綁定，多顯示器/縮放環境需座標轉換。
• 未實現鼠標點擊、鍵盤事件傳輸，協議可擴展為 Click,x,y,button、Key,code,pressed。
• 生產環境建議加入 TLS 加密、身份驗證、幀差異編碼（如 H.264/VP8）以提升性能與安全性。

1. 上一篇文章： Jar 打包命令完整參數詳解與實戰用法
2. 下一篇文章： PowerShell 進階別名技巧：使用函數封裝參數實現預設值

Java 相關知識

Spring Framework 與 IBM Data Studio pureQuery 整合實戰指南

前言 IBM Data Studio 中內建的 pureQu

結合 XForms 與 Ruby on Rails 開發小型門診管理系統（第 3 部分）：護士與醫生表單實作

本篇實作護士用的病患編輯與審核表單，包含 Kiosk 編輯視

Spring學習筆記（四）：實例剖析Spring IoC解耦全過程

前文已講解IoC與AOP兩大核心，本文通過「添加用戶」案例，

X3D 實戰基礎講座（六）：視點導航與觀察控制

X3D 通過 Viewpoint 定義預設觀察位置/角度，N