下面是一个完整的示例，展示如何使用 Java 的 Socket 和 ServerSocket 类编写一个简单的 TCP 客户端和服务器应用程序，以及一个简单的聊天应用程序。代码包括客户端和服务器的实现，能够通过 TCP 连接进行消息交换。

1. TCP 服务器程序

首先，我们将创建一个简单的 TCP 服务器，它监听特定端口并能够接收来自客户端的消息。

Server.java

package gpt;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;public class Server {private static final int port = 12345;//设置监听端口public static void main(String[] args) {System.out.println("服务器启动，等待客户端连接...");try(ServerSocket serverSocket = new ServerSocket(port)) {while (true){Socket clientSocket = serverSocket.accept();System.out.println("客户端已连接:" + clientSocket.getInetAddress());//创建一个新的线程处理客户端请求new ClientHandler(clientSocket).start();}} catch (Exception e) {System.err.println("服务器异常: " + e.getMessage());}}}
class ClientHandler extends Thread{private Socket clientSocket;public ClientHandler(Socket clientSocket) {this.clientSocket = clientSocket;}@Overridepublic void run() {try(BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true)) {String inputlines;while((inputlines = in.readLine())!=null){System.out.println("收到消息:" + inputlines);out.println(inputlines.toUpperCase());//发送响应}} catch (Exception e) {System.out.println("客户端处理异常" + e.getMessage());}finally {try {clientSocket.close();} catch (IOException e) {System.out.println("关闭异常连接" + e.getMessage());}}}
}

2. TCP 客户端程序

然后，我们将创建一个简单的 TCP 客户端，它连接到服务器并能够发送消息。

Client.java

package gpt;import java.io.*;
import java.net.Socket;
import java.util.Scanner;public class Client {private static final String SERVER_ADDRESS = "localhost"; //服务器地址private static final int SERVER_PORT = 12345; //服务器端口public static void main(String[] args) {try (Socket socket = new Socket(SERVER_ADDRESS, SERVER_PORT);PrintWriter out = new PrintWriter(socket.getOutputStream(),true);BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));Scanner sc = new Scanner(System.in)) {System.out.println("已连接到服务器，你可以开始聊天");//新线程用于接收服务器消息new Thread(() -> {try {String severMessage;while((severMessage = in.readLine())!=null){System.out.println("服务器：" + severMessage);}} catch (Exception e) {System.out.println("接收消息时出错" + e.getMessage());}}).start();//主线程用于发送信息String userInput;while(true){userInput = sc.nextLine();if(userInput.equalsIgnoreCase("exit")){break;}out.println(userInput);//发送信息}}catch (Exception e){System.err.println("连接服务器时出现异常: " + e.getMessage());}}
}

3. 使用示例

• 1.编译代码：
  使用 javac 编译 Server.java 和 Client.java 文件。

• 2.运行服务器：首先启动服务器：java Server

• 3.你应该会看到输出“服务器启动，等待客户端连接…”。

• 4.运行客户端：java Client
  你可以输入任意消息，然后按回车键发送到服务器。服务器将以大写形式回复。

• 5.结束会话：
  在客户端输入 exit 以关闭客户端程序。