Class AsyncSocket

ZezeJava/ZezeJava/src/main/java/Zeze/Net/AsyncSocket.java:21–331

import org.jetbrains.annotations.Nullable;

public abstract class AsyncSocket implements Closeable {
	private static final @NotNull Logger logger = LogManager.getLogger(AsyncSocket.class);
	public static final @NotNull Level PROTOCOL_LOG_LEVEL = Level.toLevel(System.getProperty("protocolLog"), Level.OFF);
	public static final boolean ENABLE_PROTOCOL_LOG = PROTOCOL_LOG_LEVEL != Level.OFF && logger.isEnabled(PROTOCOL_LOG_LEVEL);
	public static final boolean ENABLE_DEBUG_LOG = logger.isDebugEnabled();
	public static final boolean ENABLE_PROTOCOL_LOG_OLD = "true".equalsIgnoreCase(System.getProperty("protocolLogOld"));
	private static final LongHashSet protocolLogExcept = new LongHashSet();

	protected Object userState;

	private static final AtomicLong sessionIdGen = new AtomicLong(1);
	private static @NotNull LongSupplier sessionIdGenFunc = sessionIdGen::getAndIncrement;

	static {
		var str = System.getProperty("protocolLogExcept");
		if (str != null) {
			//noinspection DynamicRegexReplaceableByCompiledPattern
			for (var numStr : str.split("[^\\d\\-]")) {
				if (!numStr.isBlank())
					protocolLogExcept.add(Long.parseLong(numStr));
			}
		}

		ShutdownHook.init();
	}

	private final @NotNull Service service;

	protected AsyncSocket(@NotNull Service service) {
		this.service = service;
	}

	public @NotNull Service getService() {
		return service;
	}

	public static boolean canLogProtocol(long protocolTypeId) {
		return !protocolLogExcept.contains(protocolTypeId);
	}

	public Object getUserState() {
		return userState;
	}

	public void setUserState(Object value) {
		userState = value;
	}

	public static void setSessionIdGenFunc(@Nullable LongSupplier seed) {
		sessionIdGenFunc = seed != null ? seed : sessionIdGen::getAndIncrement;
	}

	public enum Type {
		eServer,
		eClient,
		eServerSocket,
	}