java中使用socket实现网络通信需先建立客户端与服务端的连接，随后通过输入输出流交换数据。1. 服务端创建serversocket监听端口，调用accept()等待连接，获取socket后处理数据收发并关闭资源；2. 客户端创建socket连接服务端，同样通过输入输出流通信；3. 多线程并发处理可通过线程池或每个连接分配一个线程实现；4. 粘包拆包问题可采用固定长度、消息头含长度信息或特殊分隔符解决；5. 异常处理包括捕获异常、记录日志、重试机制、优雅关闭连接及心跳检测保持连接有效性。
使用Socket在Java中实现网络通信，本质上是在客户端和服务端之间建立一个虚拟的“管道”，数据可以通过这个管道双向流动。客户端发起连接请求，服务端监听并接受连接，之后双方就可以通过输入输出流进行数据交换了。
解决方案
-
服务端实现：
- 创建ServerSocket，监听指定端口。
- 使用accept()方法阻塞等待客户端连接。
- 获取Socket对象，用于与客户端通信。
- 通过Socket的getInputStream()和getOutputStream()获取输入输出流。
- 使用输入输出流进行数据读写。
- 关闭Socket和ServerSocket。
import java.io.*; import java.net.*; public class Server { public static void main(String[] args) { try (ServerSocket serverSocket = new ServerSocket(6666)) { // 监听6666端口 System.out.println("Server is listening on port " + 6666); Socket socket = serverSocket.accept(); // 阻塞等待客户端连接 System.out.println("Client connected: " + socket.getInetAddress()); try (InputStream input = socket.getInputStream(); OutputStream output = socket.getOutputStream()) { BufferedReader reader = new BufferedReader(new InputStreamReader(input)); PrintWriter writer = new PrintWriter(output, true); String line; while ((line = reader.readLine()) != null) { System.out.println("Received from client: " + line); writer.println("Server received: " + line); // Echo back to client } } catch (IOException ex) { System.out.println("Server exception: " + ex.getMessage()); ex.printStackTrace(); } } catch (IOException ex) { System.out.println("Server exception: " + ex.getMessage()); ex.printStackTrace(); } } } -
客户端实现：
- 创建Socket对象，指定服务端IP地址和端口号。
- 通过Socket的getInputStream()和getOutputStream()获取输入输出流。
- 使用输入输出流进行数据读写。
- 关闭Socket。
import java.io.*; import java.net.*; public class Client { public static void main(String[] args) { String hostname = "localhost"; // 服务端IP地址 int port = 6666; // 服务端端口号 try (Socket socket = new Socket(hostname, port)) { System.out.println("Connected to server"); try (InputStream input = socket.getInputStream(); OutputStream output = socket.getOutputStream()) { BufferedReader reader = new BufferedReader(new InputStreamReader(input)); PrintWriter writer = new PrintWriter(output, true); // Send data to the server writer.println("Hello from client!"); // Receive data from the server String line = reader.readLine(); System.out.println("Received from server: " + line); } catch (IOException ex) { System.out.println("Client exception: " + ex.getMessage()); ex.printStackTrace(); } } catch (UnknownHostException ex) { System.out.println("Server not found: " + ex.getMessage()); } catch (IOException ex) { System.out.println("I/O error: " + ex.getMessage()); } } }
副标题1：如何处理Socket通信中的多线程并发？
Socket通信经常需要处理多个客户端的并发连接。一个简单的单线程服务器只能处理一个客户端的请求，处理完才能处理下一个。这显然不适用于高并发的场景。解决办法是使用多线程。
-
线程池： 使用ExecutorService创建线程池，将每个客户端的连接请求分配给一个线程处理。这样可以避免频繁创建和销毁线程的开销。
import java.io.*; import java.net.*; import java.util.concurrent.*; public class MultiThreadedServer { private static final int PORT = 6666; private static final int THREAD_POOL_SIZE = 10; public static void main(String[] args) throws IOException { ExecutorService executor = Executors.newFixedThreadPool(THREAD_POOL_SIZE); try (ServerSocket serverSocket = new ServerSocket(PORT)) { System.out.println("Multi-threaded Server is listening on port " + PORT); while (true) { Socket socket = serverSocket.accept(); System.out.println("Client connected: " + socket.getInetAddress()); executor.submit(new ClientHandler(socket)); // 提交给线程池处理 } } } private static class ClientHandler implements Runnable { private final Socket socket; public ClientHandler(Socket socket) { this.socket = socket; } @Override public void run() { try (InputStream input = socket.getInputStream(); OutputStream output = socket.getOutputStream()) { BufferedReader reader = new BufferedReader(new InputStreamReader(input)); PrintWriter writer = new PrintWriter(output, true); String line; while ((line = reader.readLine()) != null) { System.out.println("Received from client: " + line); writer.println("Server received: " + line); // Echo back to client } } catch (IOException ex) { System.out.println("Server exception: " + ex.getMessage()); ex.printStackTrace(); } finally { try { socket.close(); System.out.println("Client disconnected: " + socket.getInetAddress()); } catch (IOException e) { e.printStackTrace(); } } } } } 每个连接一个线程： 为每个客户端连接创建一个新的线程。这种方式简单直接，但当客户端数量非常大时，会消耗大量的系统资源。
副标题2：如何处理Socket通信中的粘包和拆包问题？
TCP是面向流的协议，数据在传输过程中可能会被拆分或合并，导致接收端接收到的数据不完整或包含多个消息，这就是粘包和拆包问题。
Java开发手册规约集合，基于阿里巴巴Java开发手册（嵩山版）。 涵盖7大维度：编程规约、异常日志、单元测试、安全规约、MySQL数据库、工程结构、设计规约。 当用户需要：(1) 编写或审查Java代码 (2) 检查命名/代码规范 (3) 处理异常和日志 (4) 编写单元测试 (5) 安全编码 (6) 数据库设...
固定长度： 发送端每次发送固定长度的数据，接收端也按照固定长度接收。如果实际数据长度小于固定长度，则填充一些特殊字符。这种方法简单，但不够灵活。
-
消息头包含长度信息： 在每个消息的开头添加一个消息头，包含消息的长度信息。接收端先读取消息头，获取消息长度，然后按照长度读取消息内容。
// 示例：发送端 public static void sendData(OutputStream output, String message) throws IOException { byte[] data = message.getBytes("UTF-8"); int length = data.length; // 将长度信息写入消息头 (4字节) byte[] header = ByteBuffer.allocate(4).putInt(length).array(); output.write(header); // 写入消息内容 output.write(data); output.flush(); } // 示例：接收端 public static String receiveData(InputStream input) throws IOException { // 读取消息头 (4字节) byte[] header = new byte[4]; input.read(header); int length = ByteBuffer.wrap(header).getInt(); // 读取消息内容 byte[] data = new byte[length]; input.read(data); return new String(data, "UTF-8"); } 使用特殊分隔符： 在每个消息的末尾添加一个特殊的分隔符，接收端通过分隔符来区分不同的消息。这种方法简单易用，但需要选择一个不会出现在消息内容中的分隔符。
副标题3：如何进行Socket通信的异常处理和错误恢复？
Socket通信过程中可能会出现各种异常，例如连接中断、网络超时等。良好的异常处理和错误恢复机制可以提高程序的健壮性。
使用try-catch块捕获异常： 在Socket通信的关键代码块中使用try-catch块捕获IOException等异常，并进行相应的处理。
记录日志： 将异常信息记录到日志文件中，方便排查问题。
重试机制： 对于一些可以恢复的错误，例如连接超时，可以尝试重新连接。但需要设置重试次数和间隔，避免无限重试。
优雅关闭连接： 在不再需要连接时，应该优雅地关闭Socket，释放资源。先关闭输出流，再关闭输入流，最后关闭Socket。
心跳检测： 客户端和服务端可以定期发送心跳包，检测连接是否仍然有效。如果一段时间内没有收到心跳包，则认为连接已断开，需要重新连接。心跳包的实现，可以简单地发送一个预定义的字符串。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
