Class Online

ZezeJava/ZezeJava/src/main/java/Zeze/Arch/Online.java:70–1861

import org.jetbrains.annotations.Nullable;

public class Online extends AbstractOnline implements HotUpgrade {
	protected static final @NotNull Logger logger = LogManager.getLogger(Online.class);

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

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

	// 缓存拥有Local数据的HotModule，用来优化。
	private final ConcurrentHashSet<HotModule> hotModulesHaveLocal = new ConcurrentHashSet<>();
	private boolean freshStopModule = false;

	private void onHotModuleStop(@NotNull HotModule hot) {
		freshStopModule |= hotModulesHaveLocal.remove(hot) != null;
	}

	@Override
	public boolean hasFreshStopModuleLocalOnce() {
		var tmp = freshStopModule;
		freshStopModule = false;
		return tmp;
	}

	static class Retreat {
		final @NotNull String account;
		final @NotNull String clientId;
		final @NotNull String key;
		final @NotNull Bean bean;

		Retreat(@NotNull String account, @NotNull String clientId, @NotNull String key, @NotNull Bean bean) {
			this.account = account;
			this.clientId = clientId;
			this.key = key;
			this.bean = bean;
		}
	}

	@Override
	public void upgrade(@NotNull Function<Bean, Bean> retreatFunc) throws Exception {
		// 如果需要，重建_tlocal内存表的用户设置的bean。
		var retreats = new ArrayList<Retreat>();
		_tlocal.walkMemory((account, locals) -> {
			for (var login : locals.getLogins()) {
				var clientId = login.getKey();
				for (var e : login.getValue().getDatas()) {
					var retreatBean = retreatFunc.apply(e.getValue().getAny().getBean());
					if (retreatBean != null) {
						beanFactory.register(retreatBean); // 覆盖beanFactory.
						retreats.add(new Retreat(account, clientId, e.getKey(), retreatBean));
						if (retreats.size() > 50) {
							saveRetreats(retreats);
							retreats.clear();
						}
					}
				}