使用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数据传输功能。在实际应用中,你可能需要处理更多的细节,例如异常处理、多线程通信、数据编码和解码等。此外,为了确保代码的健壮性,你可能还需要添加适当的日志记录和错误处理机制。