package tech.powerjob.samples;
|
|
import org.springframework.context.annotation.Configuration;
|
|
/**
|
* powerjob-worker 配置
|
* 代码配置示例，SpringBoot 项目支持使用 starter，只需要在 application.properties 中完成配置即可
|
*
|
* @author tjq
|
* @since 2020/4/17
|
*/
|
@Configuration
|
public class PowerJobWorkerInitializer {
|
|
/*
|
手动配置版代码
|
常规 SpringBoot 用户直接使用 starter 配置即可，具体配置见 application.properties
|
|
@Bean
|
public PowerJobSpringWorker initPowerJobSpringWorkerByCode() {
|
|
// 初始化 PowerJob 配置文件
|
PowerJobWorkerConfig config = new PowerJobWorkerConfig();
|
// 传输协议，新用户建议直接上 HTTP
|
config.setProtocol(Protocol.HTTP);
|
// 传输层端口号
|
config.setPort(28888);
|
// worker 的归组，建议使用项目名称
|
config.setAppName("powerjob-multi-worker-2");
|
// server 的服务发现地址，支持多IP 或 HTTP 域名
|
config.setServerAddress(Lists.newArrayList("127.0.0.1:7700", "127.0.0.1:7701"));
|
// 如果没有大型 Map/MapReduce 的需求，建议使用内存来加速计算
|
config.setStoreStrategy(StoreStrategy.DISK);
|
// 执行器的自定义标签，可用于指定部分执行器运行。举例：多单元机房将 TAG 设置为单元名称，即可在控制台指定单元运行
|
config.setTag("CENTER");
|
|
// 以上为核心配置，其他配置可直接参考注释 or 官方文档
|
|
// 注意 Spring 用户请使用 PowerJobSpringWorker 而不是 PowerJobWorker，后者无法使用 Spring 管理的 Bean 作为执行器
|
return new PowerJobSpringWorker(config);
|
}
|
|
*/
|
}
|
