使用Java Socket进行数据传输主要包括两个步骤:创建Socket对象和进行数据读写。以下是一个简单的示例,演示了如何使用Java Socket在客户端和服务器之间发送和接收字符串数据。
服务器端代码:
import java.io.*;
import java.net.*;
public class Server {
public static void main(String[] args) throws IOException {
// 创建一个Socket对象,监听指定端口
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();
BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
String message = reader.readLine();
System.out.println("Received message: " + message);
// 向客户端发送响应
OutputStream outputStream = socket.getOutputStream();
PrintWriter writer = new PrintWriter(outputStream, true);
writer.println("Hello from server!");
// 关闭资源
reader.close();
writer.close();
socket.close();
serverSocket.close();
}
}
客户端代码:
import java.io.*;
import java.net.*;
public class Client {
public static void main(String[] args) throws IOException {
// 创建一个Socket对象,连接到指定服务器和端口
Socket socket = new Socket("localhost", 8888);
System.out.println("Connected to server.");
// 向服务器发送数据
OutputStream outputStream = socket.getOutputStream();
PrintWriter writer = new PrintWriter(outputStream, true);
writer.println("Hello from client!");
// 获取服务器发送的数据
InputStream inputStream = socket.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
String message = reader.readLine();
System.out.println("Received message: " + message);
// 关闭资源
reader.close();
writer.close();
socket.close();
}
}
在这个示例中,服务器监听端口8888,并在接收到客户端连接后,读取客户端发送的数据并打印出来。然后,服务器向客户端发送一条响应消息。客户端连接到服务器后,发送一条消息给服务器,并打印出从服务器接收到的响应消息。
请注意,这个示例仅用于演示基本的Socket数据传输功能。在实际应用中,你可能需要处理更多的细节,例如异常处理、多线程通信、数据编码和解码等。此外,为了确保代码的健壮性,你可能还需要添加适当的日志记录和错误处理机制。