如何使用Java Socket进行数据传输

在Java中，Socket编程是一种实现客户端和服务器之间通信的方式。以下是使用Java Socket进行数据传输的基本步骤：

1. 创建ServerSocket

首先，服务器端需要创建一个ServerSocket对象来监听指定的端口。

import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) {
        int port = 12345; // 监听的端口号
        try (ServerSocket serverSocket = new ServerSocket(port)) {
            System.out.println("服务器已启动，正在监听端口 " + port);

            while (true) {
                Socket clientSocket = serverSocket.accept(); // 接受客户端连接
                System.out.println("客户端已连接: " + clientSocket.getInetAddress());

                // 处理客户端请求
                handleClient(clientSocket);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private static void handleClient(Socket clientSocket) {
        try (BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
             PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true)) {

            String inputLine;
            while ((inputLine = in.readLine()) != null) {
                System.out.println("收到客户端消息: " + inputLine);
                out.println("服务器已收到: " + inputLine);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                clientSocket.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

2. 创建Socket

客户端需要创建一个Socket对象来连接服务器。

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class Client {
    public static void main(String[] args) {
        String hostname = "localhost"; // 服务器地址
        int port = 12345; // 服务器端口号

        try (Socket socket = new Socket(hostname, port)) {
            System.out.println("已连接到服务器");

            BufferedReader userInput = new BufferedReader(new InputStreamReader(System.in));
            PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            String userInputLine;
            while ((userInputLine = userInput.readLine()) != null) {
                out.println(userInputLine); // 发送消息到服务器
                String response = in.readLine(); // 接收服务器响应
                System.out.println("服务器回复: " + response);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

3. 数据传输

• 服务器端：使用Socket对象的getInputStream()方法获取输入流，读取客户端发送的数据；使用getOutputStream()方法获取输出流，向客户端发送数据。
• 客户端：使用Socket对象的getInputStream()方法获取输入流，读取服务器发送的数据；使用getOutputStream()方法获取输出流，向服务器发送数据。

4. 关闭连接

在数据传输完成后，应该关闭所有的流和Socket连接。

try {
    in.close();
    out.close();
    socket.close();
} catch (Exception e) {
    e.printStackTrace();
}

注意事项

• 确保服务器和客户端的端口号一致。
• 处理异常情况，如连接失败、读写错误等。
• 在实际应用中，可能需要使用多线程来处理多个客户端连接。

通过以上步骤，你就可以使用Java Socket进行基本的数据传输了。根据具体需求，可以进一步扩展和优化代码。