Class Online

ZezeJava/ZezeJava/src/main/java/Zeze/Game/Online.java:85–2209

import org.jetbrains.annotations.Nullable;

public class Online extends AbstractOnline implements HotUpgrade, HotBeanFactory {
	protected static final @NotNull Logger logger = LogManager.getLogger(Online.class);
	protected static final BeanFactory beanFactory = new BeanFactory();
	protected static @Nullable Online defaultInstance; // 默认Online实例,stop后会置null

	public final @NotNull ProviderApp providerApp;
	private final AtomicLong loginTimes = new AtomicLong();
	private final @NotNull TimerRole timerRole;

	private final @NotNull EventDispatcher loginEvents;
	private final @NotNull EventDispatcher reloginEvents;
	private final @NotNull EventDispatcher logoutEvents;
	private final @NotNull EventDispatcher localRemoveEvents;
	private final @NotNull EventDispatcher linkBrokenEvents;

	// 缓存拥有Local数据的HotModule，用来优化。
	private final ConcurrentHashSet<HotModule> hotModulesHaveLocal = new ConcurrentHashSet<>();
	private boolean freshStopModuleLocal;
	private final ConcurrentHashSet<HotModule> hotModulesHaveDynamic = new ConcurrentHashSet<>();
	private boolean freshStopModuleDynamic;
	private volatile long localActiveTimeout = 600 * 1000; // 活跃时间超时。
	private volatile long localCheckPeriod = 600 * 1000; // 检查间隔
	private final AtomicInteger verifyLocalCount = new AtomicInteger();

	private final ConcurrentHashMap<String, TransmitAction> transmitActions = new ConcurrentHashMap<>();
	private @Nullable Future<?> verifyLocalTimer;

	public @NotNull ProviderApp getProviderApp() {
		return providerApp;
	}

	public void setLocalActiveTimeout(long timeout) {
		lock();
		try {
			localActiveTimeout = timeout;
		} finally {
			unlock();
		}
	}

	public void setLocalCheckPeriod(long period) {
		lock();
		try {
			if (period <= 1)
				throw new IllegalArgumentException();
			localCheckPeriod = period;
		} finally {
			unlock();
		}
	}

	private void startLocalCheck() {
		if (verifyLocalTimer != null)
			verifyLocalTimer.cancel(false);
		verifyLocalTimer = Task.scheduleUnsafe(localCheckPeriod, this::verifyLocal);
	}

	private void onHotModuleStop(HotModule hot) {