Java网络编程：客户端与服务器交互示例

原创古城微笑少年丶 2024-10-16 11:33 87阅读 0赞

在Java中，实现客户端与服务器交互的基本步骤如下，我们将使用Socket和ServerSocket进行通信：

1. 创建Server端：
   - 引入`java.net.ServerSocket`和`java.io.PrintStream`。
   - 定义一个方法处理连接请求（通常是一个循环）。

```java
import java.net.ServerSocket;
import java.io.PrintStream;

public class Server {
    private static final int PORT = 1234; // 你可以根据需求修改端口

public static void main(String[] args) throws Exception {
        ServerSocket serverSocket = new ServerSocket(PORT);

PrintStream out = new PrintStream(System.out);
        
        while (true) {
            Socket clientSocket = serverSocket.accept();
            BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())));

String inputLine;
            String response;

System.out.println("Server: Waiting for input...");

while ((inputLine = in.readLine()) != null) {
                response = processInput(inputLine); // 这里假设有一个处理输入的函数

if (response != null) {
                    out.println("Server: " + response);
                } else {
                    out.println("Server: Invalid input, please try again.");
                }
            }

clientSocket.close();
        }
    }

// 假设有一个处理输入的函数
    private static String processInput(String inputLine) {
        // 这里可以实现你的逻辑，比如检查是否合法、执行业务等
        return "Processed: " + inputLine; // 示例返回值
    }
}
```

2. 创建Client端：
   - 引入`java.net.Socket`和创建连接的代码。

```java
import java.net.Socket;

public class Client {
    private static final String SERVER_HOST = "localhost"; // 服务器主机名
    private static final int SERVER_PORT = 1234; // 服务器端口

public static void main(String[] args) throws Exception {
        Socket socket = new Socket(SERVER_HOST, SERVER_PORT));

BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()))));
        PrintStream out = new PrintStream(socket.getOutputStream()));

System.out.println("Client: Waiting for input...");

String userInput;
        while ((userInput = readFromUser()) != null) {
            out.println("Client: " + userInput);
            response = socket.ReceiveObject(in.readLine())); // 这里假设接收服务器的响应

if (response != null && !response.isEmpty()) {
                System.out.println("Server: " + response));
            } else {
                System.out.println("Error: No response received from server.");
            }
        }

socket.close();
    }

private static String readFromUser() throws Exception {
        Scanner scanner = new Scanner(System.in);
        System.out.print("Client: Enter your input: ");
        return scanner.nextLine();
    }
}
```

3. 运行客户端和服务器，通过输入命令进行交互。

注意：以上代码是一个基本的客户端与服务器交互示例，实际使用中可能需要根据具体需求进行修改。