Add translations for PowerJobAutoConfiguration.

This commit is contained in:
jiangjining 2021-01-07 09:36:55 +08:00
parent 1384e1a886
commit d69171afa5

View File

@ -16,7 +16,7 @@ import java.util.Arrays;
import java.util.List;
/**
* PowerJob 自动装配
* Auto configuration class for PowerJob-worker.
*
* @author songyinyin
* @since 2020/7/26 16:37
@ -32,30 +32,46 @@ public class PowerJobAutoConfiguration {
PowerJobProperties.Worker worker = properties.getWorker();
// 服务器HTTP地址端口号为 server.port而不是 ActorSystem port请勿添加任何前缀http://
/*
* Address(es) of PowerJob-server node(s). Do not mistake for ActorSystem port. Do not add
* any prefix, i.e. http://.
*/
CommonUtils.requireNonNull(worker.getServerAddress(), "serverAddress can't be empty!");
List<String> serverAddress = Arrays.asList(worker.getServerAddress().split(","));
// 1. 创建配置文件
/*
* Create OhMyConfig object for setting properties.
*/
OhMyConfig config = new OhMyConfig();
// 端口配置支持随机端口
/*
* Configuration of worker port. Random port is enabled when port is set with non-positive number.
*/
int port = worker.getAkkaPort();
if (port <= 0) {
port = NetUtils.getRandomPort();
}
config.setPort(port);
// appName需要提前在控制台注册否则启动报错
/*
* appName, name of the application. Applications should be registered in advance to prevent
* reporting error. This property should be the same with what you entered for appName when
* getting registered.
*/
config.setAppName(worker.getAppName());
config.setServerAddress(serverAddress);
// 如果没有大型 Map/MapReduce 的需求建议使用内存来加速计算
// 有大型 Map/MapReduce 需求可能产生大量子任务Task的场景请使用 DISK否则妥妥的 OutOfMemory
/*
* For non-Map/MapReduce tasks, {@code memory} is recommended for speeding up calculation.
* Map/MapReduce tasks may produce batches of subtasks, which could lead to OutOfMemory
* exception or error, {@code disk} should be applied.
*/
config.setStoreStrategy(worker.getStoreStrategy());
// 启动测试模式true情况下不再尝试连接 server 并验证appName
/*
* When enabledTestMode is set as true, PowerJob-worker no longer connects to PowerJob-server
* or validate appName.
*/
config.setEnableTestMode(worker.isEnableTestMode());
// 2. 创建 Worker 对象设置配置文件
/*
* Create OhMyWorker object and set properties.
*/
OhMyWorker ohMyWorker = new OhMyWorker();
ohMyWorker.setConfig(config);
return ohMyWorker;