Method checkKeepAlive

ZezeJava/ZezeJava/src/main/java/Zeze/Net/Service.java:877–902

()

	}

	private void checkKeepAlive() throws Exception {
		var conf = getConfig().getHandshakeOptions();
		var keepRecvTimeout = conf.getKeepRecvTimeout() > 0 ? conf.getKeepRecvTimeout() : Integer.MAX_VALUE;
		var keepSendTimeout = conf.getKeepSendTimeout() > 0 ? conf.getKeepSendTimeout() : Integer.MAX_VALUE;
		int now = (int)GlobalTimer.getCurrentSeconds();
		foreach(socket -> {
			if (socket instanceof TcpSocket) {
				int recvTime = now - socket.getActiveRecvTime();
				if (recvTime > keepRecvTimeout) {
					try {
						onKeepAliveTimeout(socket);
					} catch (Exception e) {
						logger.error("onKeepAliveTimeout exception:", e);
					}
				}
				if (socket.getType() == AsyncSocket.Type.eClient && (now - socket.getActiveSendTime() > keepSendTimeout ||
						recvTime > keepSendTimeout)) { // 上次接收时间超过SendTimeout也要发起KeepAlive,通过RPC回复更新上次接收时间
					try {
						onSendKeepAlive(socket);
					} catch (Exception e) {
						logger.error("onSendKeepAlive exception:", e);
					}
				}
			}
		});
	}

	@SuppressWarnings({"MethodMayBeStatic", "RedundantThrows"})
	protected void onKeepAliveTimeout(@NotNull AsyncSocket socket) throws Exception {