package testBlockSocket;import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketTimeoutException;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;//通过加入线程的概念，让 Socket Server 能够在应用层面
//通过非阻塞的方式同时处理多个 Socket 套接字
public class SocketServer4AllTimeoutAndMultiThread {private final static Logger LOGGER = LoggerFactory.getLogger(SocketServer4AllTimeoutAndMultiThread.class);private static Object xWait = new Object();public static void main(String[] args) throws Exception {ServerSocket serverSocket = new ServerSocket(8888);serverSocket.setSoTimeout(100);try {while (true) {Socket socket = null;try {socket = serverSocket.accept();} catch (SocketTimeoutException el) {// ===================// 执行到这里，说明本次 accept()方法没有接收到任何 TCP 连接主线程在这里就可以做一些事情，记为 x// ＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝synchronized (SocketServer4AllTimeoutAndMultiThread.xWait) {LOGGER.info("这次没有接收到 TCP 连接，等待10 毫秒，模拟事件x 的处理时间 ");SocketServer4AllTimeoutAndMultiThread.xWait.wait(10);}continue;}// 业务处理过程可以交给一个线程（这里可以使用线程池）// 注意 ， 线程的创建过程是很耗资源和时间的// 最终改变不了 accept （ ）方法只能一个一个地接收 Socket 连接的情况SocketServerThreadWithTimeOut socketServerThread = new SocketServerThreadWithTimeOut(socket);new Thread(socketServerThread).start();}} catch (Exception e) {LOGGER.error(e.getMessage(), e);} finally {if (serverSocket != null) {serverSocket.close();}}}
}// 当然，接收到客户端的 Socket 后，业务的处理过程可以交给一个线程来做
class SocketServerThreadWithTimeOut implements Runnable {private final static Logger LOGGER = LoggerFactory.getLogger(SocketServerThreadWithTimeOut.class);private Socket socket;public SocketServerThreadWithTimeOut(Socket socket) {this.socket = socket;}@Overridepublic void run() {InputStream inputStream = null;OutputStream outputStream = null;try {inputStream = socket.getInputStream();outputStream = socket.getOutputStream();Integer sourcePort = socket.getPort();int maxLen = 2048;byte[] contextBytes = new byte[maxLen];int realLen;StringBuffer message = new StringBuffer();// 下面我们收取信息this.socket.setSoTimeout(10);BIORead: while (true) {try {while ((realLen = inputStream.read(contextBytes, 0, maxLen)) != -1) {message.append(new String(contextBytes, 0, realLen));// 我们同样假设读取到"over"关键字，表示业务内容传输完成if (message.indexOf("over") != -1) {break BIORead;}}} catch (SocketTimeoutException e2) {// =================// 执行到这里，说明本次 read （）方法没有接收到任何数据流主线程在这里又可以做一些事情，记为 Y// =================LOGGER.info("这次没有接收到任务数据报文，等待 10 ~盖秒 ，模拟事件 Y 的处理时间 ");continue;}}// 下面打印信息Long threadId = Thread.currentThread().getId();SocketServerThreadWithTimeOut.LOGGER.info("服务器（线程 ：" + threadId + ")收到来自于端口 ：" + sourcePort + "的信息： " + message);// 下面开始发送信息outputStream.write("回发响应信息：".getBytes());// 关闭 in 和 out 对象
            inputStream.close();outputStream.close();} catch (Exception e) {LOGGER.error(e.getMessage(), e);}}
}