ServerSocket的一个简单例子，学习backlog参数的设置，即可以接受客户端的数量

69 阅读 0 评论 46 点赞

我是靠谱客的博主迷人高山，最近开发中收集的这篇文章主要介绍ServerSocket的一个简单例子，学习backlog参数的设置，即可以接受客户端的数量，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

1：Client类

import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {
	
	public static void main(String args[]) throws UnknownHostException, IOException, InterruptedException {
		final int length = 100;
		String host = "localhost";
		int port = 8000;
		
		Socket[] sockets = new Socket[length];
		for(int i = 0; i < length; i++) {
			sockets[i] = new Socket(host, port);
			System.out.println("the " + (i+1) + "connection is successful");
		}
		
		Thread.sleep(3000);
		for(int i = 0; i < length; i++) {
			sockets[i].close();
		}
	}
}

2：Server类

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;


public class Server {
	
	private int port = 8000;
	private int server_num = 3;
	private static ServerSocket serverSocket;
	
	public Server() throws IOException {
		serverSocket = new ServerSocket(port, server_num);
		System.out.println("The server is starting");
		
	}
	public void service() {
		while(true) {
			Socket socket = null;
			try {
				socket = serverSocket.accept();
				System.out.println("new connection is completed " + socket.getInetAddress() + ":" + socket.getPort());
			} catch(IOException e) {
				e.printStackTrace();
			} finally {
				if(socket != null) {
					try {
						socket.close();
					} catch (IOException e) {
						e.printStackTrace();
					}
				}
			}
		}
	}
	
	public static void main(String args[]) throws IOException, InterruptedException {
		Server server = new Server();
		Thread.sleep(60000*10);
		server.service();
	}
}

3：程序结果

当Thread.sleep(60000*10)被注释时，Client端的效果为

Server端的效果为：

当server.service();被注释时，client端的效果为：

4：结果解析

*当server.service()方法被注释后，使得服务器与8000端口绑定后，永远不会执行serverSocket.accept()方法，这意味着队列中的连接请求永远不会被取出。

*当Thread.sleep(60000*10)被注释后，使得服务器与8000端口绑定后，就会在一个while循环中不断执行serverSocket.accept()方法，该方法从队列中取出连接请求，使得队列能够及时的腾出空间，以容纳新的连接请求。

5：补充小程序

import java.io.IOException;
import java.net.ServerSocket;

public class testServerSocket {

	public static void main(String[] args) {
		
		ServerSocket serverSocket = null;
		
		for(int i = 0; i < 65535; i++) {
			try {
				serverSocket = new ServerSocket(i);
				serverSocket.close();
			} catch (IOException e) {
				e.printStackTrace();
				System.out.println("端口" + i + "已经被其他服务器进程占用");
			}
		}
	}
}

该程序循环判断1到65535的端口有没有被占用，当被占用时会打印输出被占用的端口号

ServerSocket的几个方法

*isClosed()：判断serverSocket是否已经被关闭，只有执行了ServerSocket的close方法，isClosed()方法才返回true，否则，即使ServerSocket还没有和特定的端口绑定，isClosed方法也会返回false

*isBound（）：判断ServerSocket方法是否已经与一个端口绑定，只要ServerSocket已经和一个端口绑定，即使它已经被关闭，isBound（）也会返回true

*如果需要判断一个ServerSocket已经与特定端口绑定，并且还没有被关闭，则可以采用下列方式：

boolean isOpen = serverSocket.isBound() && !serverSocket.isClosed()