Method main

ZezeJava/ZezeJava/src/main/java/Zeze/Services/BinLogger.java:587–633

(@NotNull String @NotNull [] args)

	}

	public static void main(@NotNull String @NotNull [] args) throws Exception {
		Thread.setDefaultUncaughtExceptionHandler((t, e) -> {
			//noinspection CallToPrintStackTrace
			e.printStackTrace();
			logger.error("uncaught exception in {}:", t, e);
		});

		String host = null;
		int port = 0;
		int threadCount = 0;
		String path = "binlog";

		for (int i = 0; i < args.length; ++i) {
			switch (args[i]) {
			case "-host": // 指定监听的IP,不指定则监听所有IP,如果当前目录存在zeze.xml且定义了BinLoggerService,则默认以配置为准
				host = args[++i];
				if (host.isBlank())
					host = null;
				break;
			case "-port": // 指定监听端口号,默认DEFAULT_PORT常量,如果当前目录存在zeze.xml且定义了BinLoggerService,则默认以配置为准
				port = Integer.parseInt(args[++i]);
				break;
			case "-threads": // 网络IO线程数,默认0表示CPU核数
				threadCount = Integer.parseInt(args[++i]);
				break;
			case "-path": // 输出二进制日志的相对路径,默认"binlog"
				path = args[++i].trim();
				break;
			default:
				throw new IllegalArgumentException("unknown argument: '" + args[i] + '\'');
			}
		}

		if (threadCount < 1)
			threadCount = Runtime.getRuntime().availableProcessors();
		Task.initThreadPool(Task.newCriticalThreadPool("ZezeTaskPool"),
				Executors.newSingleThreadScheduledExecutor(
						new ThreadFactoryWithName("ZezeScheduledPool", Thread.NORM_PRIORITY + 2)));
		if (Selectors.getInstance().getCount() < threadCount)
			Selectors.getInstance().add(threadCount - Selectors.getInstance().getCount());
		ZezeCounter.tryInit();

		new BinLoggerService(path).start(host, port);
		synchronized (Thread.currentThread()) {
			Thread.currentThread().wait();
		}
	}
}