在Java中,使用Socket进行通信主要涉及到两个类:java.net.Socket
(用于客户端)和java.net.ServerSocket
(用于服务器端)。下面是一个简单的示例,展示了如何使用这两个类实现基本的TCP通信。
1. 服务器端
import java.io.*;
import java.net.*;
public class Server {
public static void main(String[] args) throws IOException {
// 创建一个ServerSocket对象,监听指定端口
ServerSocket serverSocket = new ServerSocket(8888);
System.out.println("Server is listening on port 8888...");
// 接受来自客户端的连接
Socket socket = serverSocket.accept();
System.out.println("Client connected.");
// 获取输入输出流
InputStream inputStream = socket.getInputStream();
OutputStream outputStream = socket.getOutputStream();
// 读取客户端发送的数据
BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
String message = reader.readLine();
System.out.println("Received from client: " + message);
// 向客户端发送数据
PrintWriter writer = new PrintWriter(outputStream, true);
writer.println("Hello from server!");
// 关闭资源
reader.close();
writer.close();
socket.close();
serverSocket.close();
}
}
2. 客户端
import java.io.*;
import java.net.*;
public class Client {
public static void main(String[] args) throws IOException {
// 创建一个Socket对象,连接到服务器的IP地址和端口
Socket socket = new Socket("localhost", 8888);
System.out.println("Connected to server.");
// 获取输入输出流
InputStream inputStream = socket.getInputStream();
OutputStream outputStream = socket.getOutputStream();
// 向服务器发送数据
PrintWriter writer = new PrintWriter(outputStream, true);
writer.println("Hello from client!");
// 读取服务器发送的数据
BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
String message = reader.readLine();
System.out.println("Received from server: " + message);
// 关闭资源
reader.close();
writer.close();
socket.close();
}
}
在这个示例中,服务器监听8888端口,并在接受到客户端连接后,通过输入输出流与客户端进行通信。客户端连接到服务器的IP地址和端口,然后通过输入输出流与服务器进行通信。
注意:在实际应用中,你可能需要处理更多的异常情况,例如连接超时、网络中断等。此外,为了提高程序的健壮性,你还可以考虑使用多线程来处理多个客户端的连接。