Method TcpSocket

ZezeJava/ZezeJava/src/main/java/Zeze/Net/TcpSocket.java:143–182

for server socket

(@NotNull Service service, @Nullable InetSocketAddress localEP, @Nullable Acceptor acceptor)

	 * for server socket
	 */
	public TcpSocket(@NotNull Service service, @Nullable InetSocketAddress localEP, @Nullable Acceptor acceptor) {
		super(service);

		this.acceptorOrConnector = acceptor;
		this.type = Type.eServerSocket;
		service.tryStartKeepAliveCheckTimer();

		ServerSocketChannel ssc = null;
		try {
			ssc = ServerSocketChannel.open();
			ssc.configureBlocking(false);
			ServerSocket ss = ssc.socket();
			ss.setReuseAddress(true);
			// xxx 只能设置到 ServerSocket 中，以后 Accept 的连接通过继承机制得到这个配置。
			Integer recvBufSize = service.getSocketOptions().getReceiveBuffer();
			if (recvBufSize != null)
				ss.setReceiveBufferSize(recvBufSize);
			ss.bind(localEP, service.getSocketOptions().getBacklog());
			service.onServerSocketBind(ss);
			logger.info("Listen: [{}] {} for {}:{}", getSessionId(), localEP, service.getClass().getName(), service.getName());

			timeThrottle = null;
			selector = service.getSelectors().choice();
			operates = null;
			inputBuffer = null;
			outputBuffer = null;
			selectionKey = selector.register(ssc, 0, this); // 先获取key,因为有小概率出现事件处理比赋值更先执行
			addInterestOps(SelectionKey.OP_ACCEPT);
			selector.wakeup();
		} catch (IOException e) {
			if (ssc != null) {
				try {
					ssc.close();
				} catch (Exception ex) {
					logger.error("ServerSocketChannel.close exception:", ex);
				}
			}
			throw new IllegalStateException("bind " + localEP, e);
		}
	}

	@Override
	public void doHandle(@NotNull SelectionKey key) throws Exception {