Java 写一个分享屏幕和设备音频的软件包含服务端和客户端

以下是一个简单的Java示例，展示了如何编写一个基本的屏幕分享和设备音频共享的软件，包括服务端和客户端。

服务端代码：

import java.awt.*;
import java.awt.image.BufferedImage;
import java.io.*;
import javax.imageio.ImageIO;
import javax.sound.sampled.*;

public class ScreenSharingServer {
    private Robot robot;
    private Rectangle screenRect;
    private boolean isRunning;

    public ScreenSharingServer() {
        try {
            robot = new Robot();
            screenRect = new Rectangle(Toolkit.getDefaultToolkit().getScreenSize());
        } catch (AWTException e) {
            e.printStackTrace();
        }
    }

    public void startSharing() {
        isRunning = true;
        try {
            ServerSocket serverSocket = new ServerSocket(9999);
            System.out.println("Server started, waiting for clients...");

            while (isRunning) {
                Socket socket = serverSocket.accept();
                System.out.println("Client connected: " + socket.getInetAddress().getHostAddress());

                Thread screenThread = new Thread(() -> {
                    try {
                        OutputStream outputStream = socket.getOutputStream();
                        ObjectOutputStream objectOutputStream = new ObjectOutputStream(outputStream);

                        while (isRunning) {
                            BufferedImage screenshot = robot.createScreenCapture(screenRect);
                            ByteArrayOutputStream baos = new ByteArrayOutputStream();
                            ImageIO.write(screenshot, "jpg", baos);
                            baos.flush();

                            byte[] imageData = baos.toByteArray();
                            objectOutputStream.writeObject(imageData);
                            objectOutputStream.flush();
                        }

                        objectOutputStream.close();
                        outputStream.close();
                        socket.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                });

                Thread audioThread = new Thread(() -> {
                    try {
                        AudioFormat format = new AudioFormat(44100, 16, 1, true, true);
                        DataLine.Info info = new DataLine.Info(TargetDataLine.class, format);
                        TargetDataLine microphone = (TargetDataLine) AudioSystem.getLine(info);
                        microphone.open(format);
                        microphone.start();

                        OutputStream outputStream = socket.getOutputStream();
                        byte[] buffer = new byte[4096];

                        while (isRunning) {
                            int count = microphone.read(buffer, 0, buffer.length);
                            outputStream.write(buffer, 0, count);
                            outputStream.flush();
                        }

                        microphone.close();
                        outputStream.close();
                        socket.close();
                    } catch (LineUnavailableException | IOException e) {
                        e.printStackTrace();
                    }
                });

                screenThread.start();
                audioThread.start();
            }

            serverSocket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public void stopSharing() {
        isRunning = false;
    }

    public static void main(String[] args) {
        ScreenSharingServer server = new ScreenSharingServer();
        server.startSharing();
    }
}

客户端代码：

import java.awt.*;
import java.awt.image.BufferedImage;
import java.io.*;
import javax.imageio.ImageIO;
import javax.sound.sampled.*;

public class ScreenSharingClient {
    private boolean isRunning;

    public void startReceiving(String serverAddress) {
        isRunning = true;

        try {
            Socket socket = new Socket(serverAddress, 9999);
            System.out.println("Connected to server: " + socket.getInetAddress().getHostAddress());

            Thread screenThread = new Thread(() -> {
                try {
                    InputStream inputStream = socket.getInputStream();
                    ObjectInputStream objectInputStream = new ObjectInputStream(inputStream);

                    while (isRunning) {
                        byte[] imageData = (byte[]) objectInputStream.readObject();
                        ByteArrayInputStream bais = new ByteArrayInputStream(imageData);
                        BufferedImage screenshot = ImageIO.read(bais);

                        // 显示截图
                        // ...

                        bais.close();
                    }

                    objectInputStream.close();
                    inputStream.close();
                    socket.close();
                } catch (IOException | ClassNotFoundException e) {
                    e.printStackTrace();
                }
            });

            Thread audioThread = new Thread(() -> {
                try {
                    AudioFormat format = new AudioFormat(44100, 16, 1, true, true);
                    DataLine.Info info = new DataLine.Info(SourceDataLine.class, format);
                    SourceDataLine speakers = (SourceDataLine) AudioSystem.getLine(info);
                    speakers.open(format);
                    speakers.start();

                    InputStream inputStream = socket.getInputStream();
                    byte[] buffer = new byte[4096];

                    while (isRunning) {
                        int count = inputStream.read(buffer, 0, buffer.length);
                        speakers.write(buffer, 0, count);
                        speakers.flush();
                    }

                    speakers.close();
                    inputStream.close();
                    socket.close();
                } catch (LineUnavailableException | IOException e) {
                    e.printStackTrace();
                }
            });

            screenThread.start();
            audioThread.start();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public void stopReceiving() {
        isRunning = false;
    }

    public static void main(String[] args) {
        ScreenSharingClient client = new ScreenSharingClient();
        client.startReceiving("127.0.0.1"); // 替换为服务端的IP地址
    }
}

请注意，以上代码只是一个基本的示例，仅用于演示如何进行屏幕分享和设备音频共享。在实际应用中，可能需要更多的错误处理、用户界面以及其他功能