标签：
之前在做项目的时候，刚好用到Spring-Integration的TCP/IP组件，在定义ServerSocket的过程中，有一个参数backlog比较突出，通过网上的查阅，才知道这是原生Java中ServerSocket的参数。通过查API得知，ServerSocket的构造参数：public ServerSocket(int port,int backlog)，API对于backlog的解析是这样的：requested maximum length of the queue of incoming connections；大意就是说TCP连接请求队列的最大容量。最初的理解就是如果ServerSocket由于请求太多处理不过来，后续的客户端连接就会放到阻塞队列里面，当队列满了（超过backlog定义的容量，默认为50），就会拒绝后续的连接。
1. 先上代码，再说结论：
Server端：
public class TestBackLog { public static void main(String[] args) throws IOException, InterruptedException { int backlog = 3; ServerSocket serverSocket = new ServerSocket(5000, backlog); //此处会造成客户端的连接阻塞，这时就会把request connection放到请求队列，而请求队列的容量就是backlog的值 //当程序启动，此处睡眠50秒，马上启动客户端，客户端每一秒钟起一个，起到第二个的时候，第三个就无法获得到ServerSocket //只能等待，前两个连接已获取ServerSocket连接，只有等这两个处理完了，后续第三个才会拿到连接，进行处理（可从客户端输出得出此结论） Thread.sleep(50000);//模拟服务端处理高延时任务 while (true) { Socket socket = serverSocket.accept(); InputStream is = socket.getInputStream(); OutputStream os = socket.getOutputStream(); BufferedReader br = new BufferedReader(new InputStreamReader(is)); PrintWriter out = new PrintWriter(new OutputStreamWriter(os)); int length = -1; char[] buffer = new char[200]; while (-1 != (length = br.read(buffer, 0, buffer.length))) { String string = new String(buffer, 0, length); System.out.println("TestBackLog receive String " + socket.getInetAddress() + ":" + socket.getLocalPort() + string); out.write("server welcome!"); out.flush(); socket.shutdownOutput(); } out.close(); br.close(); socket.close(); } } }
Client 端：
public class TcpClient { public static void main(String[] args) throws UnknownHostException, IOException, InterruptedException { for(int i=0; i<10; i++) { Thread.sleep(1000);//创建端口太快，降低创建速率 new Thread(new ClientThread()).start(); } } } class ClientThread implements Runnable { @Override public void run() { try { Socket client = new Socket("127.0.0.1", 5000); System.out.println("client connected server"); InputStream is = client.getInputStream(); OutputStream os = client.getOutputStream(); os.write("clinet hello world!".getBytes()); client.shutdownOutput();//这一句非常重要啊，如果没有这句，服务端的read()会一直阻塞 int length = 0; byte[] buffer = new byte[200]; while(-1 != (length = is.read(buffer, 0, buffer.length))) { System.out.println("client"); String receiveString = new String(buffer, 0, length); System.out.println("receiveString : " + receiveString); } } catch(Exception e) { e.printStackTrace(); } } }
2. 步骤：在win7 64位的机器上运行的，先启动TestBackLog，TestBackLog创建ServerSocket之后，会进入睡眠状态。马上再运行TcpClient，一旦客户端连上服务端，将会在控制台输出：client connected server
3. 观察现象并得出结论：当服务端创建服务之后，main线程会睡眠，会睡眠50秒，那如果现在运行TcpClient，将会创建10个客户端，这时将会出现什么情况？实际情况就是：在控制台只输出了三次：client connected server，那就意味着只有三个客户端连上服务端，刚好与backlog所设定的请求队列容量一致，后续的客户端再进行连接，则会抛出异常：java.net.ConnectException: Connection refused: connect（这是在windows会发生的情况，在mac上运行也是只有三次输出，但是其他的客户端没有被拒绝，而是直到连接超时）。当服务端睡眠结束，处理最初三个客户端的请求，之后再把后面的客户端请求处理完（前提是客户端的连接没有超时）。
这个实验刚好验证了请求的缓存队列，队列里的客户端已经跟服务端建立连接，等待服务端处理。但是后面未进入的队列的客户端，会进行new Socket(ip, port)，还在苦苦地跟服务端进行连接啊~
标签：
原文地址：http://www.cnblogs.com/hippo0918/p/4652173.html
