Method App

ZezeJava/ZezeJavaTest/src/Infinite/App.java:20–54

(int serverId)

	final CoverHistory coverHistory;

	public App(int serverId) {
		config = Config.load("zeze.xml");
		config.setServerId(serverId);
		config.setFastRedoWhenConflict(false);
		config.setCheckpointPeriod(1000);
		config.getServiceConfMap().remove("Zeze.Onz.Server");
		config.setHistory("ZezeTest");

		var tdef = config.getDefaultTableConf();
		// 提高并发
		tdef.setCacheCleanPeriod(1000);
		// 超出容量时，快速尝试。
		tdef.setCacheCleanPeriodWhenExceedCapacity(100);
		// 减少容量，实际使用记录数要超过一些。让TableCache.Cleanup能并发起来。
		tdef.setCacheCapacity(Simulate.CacheCapacity);
		tdef.setCacheFactor(1.0f);

		var tflush = config.getTableConfMap().get("demo_Module1_tflush");
		// 提高并发
		tflush.setCacheCleanPeriod(1000);
		// 超出容量时，快速尝试。
		tflush.setCacheCleanPeriodWhenExceedCapacity(100);
		// 减少容量，实际使用记录数要超过一些。让TableCache.Cleanup能并发起来。
		tflush.setCacheCapacity(Tasks.tflushInt1Trade.CacheCapacity);
		tflush.setCacheFactor(1.0f);

		config.getServiceConfMap().remove("TestServer");
		coverHistory = new CoverHistory(this.app);

		for (var dbCfg : config.getDatabaseConfMap().values()) {
			var dc = dbCfg.getDruidConf();
			if (dc != null && (dc.maxActive == null || dc.maxActive > 10))
				dc.maxActive = 10;
		}
	}

	public int getServerId() {
		return config.getServerId();