处理socket通信中的并发问题可通过多线程、线程池或nio实现；2. 多线程为每个客户端创建新线程，适合连接数少的场景；3. 线程池通过executorservice管理线程，提升资源利用率，适合中等并发；4. nio使用selector实现单线程管理多个连接，适合高并发低延迟场景；5. 常见ioexception包括connectexception（服务器未启动或端口被阻）、sockettimeoutexception（操作超时）、bindexception（端口占用）、eofexception（连接意外关闭）和broken pipe（向已关闭连接写数据）；6. 应通过try-catch捕获异常并采取对应措施，如检查网络、设置超时或更换端口；7. 实现文件传输需客户端读取文件并通过socket发送，服务器接收并写入文件；8. 使用bufferedinputstream和bufferedoutputstream可提高传输效率；9. 实际应用中应先发送文件大小以标识传输完成，确保数据完整性。
Socket在Java中就像电话插座一样，让不同的程序可以通过网络“对话”。它提供了一种低级别的、面向连接的通信方式，允许你构建各种网络应用，从简单的客户端-服务器应用到复杂的分布式系统。
解决方案
Java中使用Socket进行网络通信主要涉及两个类：
ServerSocket
（服务器端）和
Socket
（客户端）。服务器端监听特定端口，等待客户端连接；客户端则连接到服务器的IP地址和端口。
- 服务器端代码示例：
import java.net.*; import java.io.*; public class Server { public static void main(String[] args) throws IOException { ServerSocket serverSocket = new ServerSocket(12345); // 监听12345端口 System.out.println("服务器启动，等待客户端连接..."); while (true) { Socket clientSocket = serverSocket.accept(); // 阻塞，直到有客户端连接 System.out.println("客户端连接成功！"); // 创建输入输出流 PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true); BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); String inputLine; while ((inputLine = in.readLine()) != null) { System.out.println("客户端发来消息: " + inputLine); out.println("服务器已收到: " + inputLine); // 回复客户端 } // 关闭连接 clientSocket.close(); System.out.println("客户端断开连接。"); } //serverSocket.close(); // 通常不需要在这里关闭，除非你想停止服务器 } }
- 客户端代码示例：
import java.net.*; import java.io.*; public class Client { public static void main(String[] args) throws IOException { String serverAddress = "127.0.0.1"; // 服务器IP地址 int serverPort = 12345; // 服务器端口 Socket socket = new Socket(serverAddress, serverPort); System.out.println("成功连接到服务器！"); // 创建输入输出流 PrintWriter out = new PrintWriter(socket.getOutputStream(), true); BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in)); String userInput; System.out.println("请输入要发送的消息 (输入 'exit' 退出):"); while ((userInput = stdIn.readLine()) != null) { out.println(userInput); // 发送消息到服务器 System.out.println("服务器回复: " + in.readLine()); if (userInput.equals("exit")) { break; } } // 关闭连接 socket.close(); } }
如何处理Socket通信中的并发问题？
并发是Socket编程中常见的问题。如果服务器一次只能处理一个客户端连接，那么其他客户端就必须等待。解决并发问题通常有几种方法：
立即学习“Java免费学习笔记（深入）”；
-
多线程： 为每个客户端连接创建一个新的线程。这是最常用的方法，简单直接。上面服务器端的代码如果直接运行，会阻塞在
serverSocket.accept()
，直到一个客户端连接。如果要处理多个客户端，你需要把处理
clientSocket
的代码放到一个单独的线程中。
while (true) { Socket clientSocket = serverSocket.accept(); new Thread(() -> { try { // 处理客户端连接的代码（如上面的输入输出流操作） PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true); BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); // ... clientSocket.close(); } catch (IOException e) { e.printStackTrace(); } }).start(); } -
线程池： 使用线程池可以更有效地管理线程，避免创建过多的线程导致系统资源耗尽。
ExecutorService
是Java提供的线程池接口。
-
非阻塞IO（NIO）： NIO允许单个线程管理多个连接，而无需为每个连接创建一个线程。这在高并发场景下可以显著提高性能。NIO使用
Selector
来监听多个通道上的事件。
选择哪种方法取决于你的应用场景和性能需求。多线程适合连接数不多的情况，线程池适合连接数较多但并发量有限的情况，NIO适合高并发、低延迟的场景。
Socket编程中常见的IOException及其原因？
IOException
是Socket编程中最常见的异常。它表示在输入输出操作期间发生了错误。以下是一些常见的
IOException
及其原因：
-
ConnectException
：
连接被拒绝。这通常是因为服务器没有启动，或者服务器端口被防火墙阻止。检查服务器是否正在运行，以及客户端的IP地址和端口是否正确。 -
SocketTimeoutException
：
Socket操作超时。这通常是因为网络连接不稳定，或者服务器响应过慢。你可以通过Socket.setSoTimeout()
方法设置超时时间。
-
BindException
：
端口已被占用。这通常是因为有另一个程序正在使用相同的端口。你需要选择一个不同的端口，或者关闭占用端口的程序。 -
EOFException
：
连接意外关闭。这通常是因为客户端或服务器端突然断开连接。你需要检查网络连接是否正常，以及客户端和服务器端的代码是否存在错误。 -
IOException: Broken pipe
：
尝试写入已关闭的Socket。这通常发生在客户端已经关闭了连接，但服务器端仍然尝试写入数据。在写入数据之前，你应该检查Socket是否仍然连接。
处理
IOException
的关键是了解其原因，并采取相应的措施。使用
try-catch
块捕获异常，并记录错误信息，可以帮助你诊断问题。
如何使用Socket实现简单的文件传输功能？
文件传输是Socket编程的一个常见应用。基本思路是：客户端读取文件内容，通过Socket发送到服务器；服务器接收文件内容，写入到文件中。
- 客户端代码示例：
import java.net.*; import java.io.*; public class FileClient { public static void main(String[] args) throws IOException { String serverAddress = "127.0.0.1"; int serverPort = 12345; String filePath = "example.txt"; // 要发送的文件 Socket socket = new Socket(serverAddress, serverPort); System.out.println("连接到服务器..."); File file = new File(filePath); FileInputStream fis = new FileInputStream(file); BufferedInputStream bis = new BufferedInputStream(fis); OutputStream os = socket.getOutputStream(); byte[] buffer = new byte[8192]; // 8KB buffer int count; while ((count = bis.read(buffer)) > 0) { os.write(buffer, 0, count); os.flush(); // 确保数据立即发送 } os.close(); bis.close(); socket.close(); System.out.println("文件发送完毕！"); } }
- 服务器端代码示例：
import java.net.*; import java.io.*; public class FileServer { public static void main(String[] args) throws IOException { ServerSocket serverSocket = new ServerSocket(12345); System.out.println("服务器启动，等待客户端连接..."); Socket clientSocket = serverSocket.accept(); System.out.println("客户端连接成功！"); InputStream is = clientSocket.getInputStream(); FileOutputStream fos = new FileOutputStream("received.txt"); // 保存为received.txt BufferedOutputStream bos = new BufferedOutputStream(fos); byte[] buffer = new byte[8192]; int count; while ((count = is.read(buffer)) > 0) { bos.write(buffer, 0, count); bos.flush(); } bos.close(); is.close(); clientSocket.close(); serverSocket.close(); System.out.println("文件接收完毕！"); } }
这个例子使用了缓冲流来提高文件传输的效率。客户端读取文件，并通过Socket将数据发送到服务器。服务器接收数据，并将其写入到文件中。注意，这个例子没有处理文件大小和传输完成的信号，实际应用中需要添加这些功能。例如，可以先发送文件大小，然后发送文件内容，服务器根据文件大小判断是否接收完成。
