更新时间:2020-12-29 18:28
在开始使用任务调度产品之前,对于不同的工程类型,您必须做以下准备:
<dependency>
<groupId>com.alipay.sofa</groupId>
<artifactId>tracer-enterprise-sofa-boot-starter</artifactId>
</dependency>
pom.xml
文件中引入任务调度产品的依赖:
<dependency>
<groupId>com.alipay.sofa</groupId>
<artifactId>scheduler-enterprise-sofa-boot-starter</artifactId>
</dependency>
settings.xml
文件:settings.xml
文件中,配置 mvn.cloud.alipay.com
仓库的地址及用户名密码。配置后工程即可通过 Maven 获取该仓库中任务调度的 JAR 依赖包,不配置则无法获取到 JAR 包。说明:
mvn.cloud.alipay.com
仓库的地址及用户名密码请 提交工单 获取。
在工程的主 pom.xml
文件中引入 antschedulerclient
的依赖。以 1.0.7 版本为例:
<dependency>
<groupId>com.alipay.antschedulerclient</groupId>
<artifactId>antschedulerclient-core</artifactId>
<version>1.0.7</version>
</dependency>
<dependency>
<groupId>com.alipay.antschedulerclient</groupId>
<artifactId>antschedulerclient-antvip</artifactId>
<version>1.0.7</version>
</dependency>
<!-- 间接依赖 -->
<dependency>
<groupId>com.antcloud.antvip</groupId>
<artifactId>antcloud-antvip-client</artifactId>
<version>1.0.4</version>
</dependency>
<dependency>
<groupId>com.antcloud.antvip</groupId>
<artifactId>antcloud-antvip-common</artifactId>
<version>1.0.4</version>
</dependency>
<!-- antvip-common的依赖 -->
<dependency>
<groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId>
<version>1.4</version>
</dependency>
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
<version>2.2</version>
</dependency>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
<version>2.4</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.50</version>
</dependency>
<dependency>
<groupId>com.alipay.sofa.cloud</groupId>
<artifactId>sdk-core</artifactId>
<version>0.1</version>
</dependency>
<dependency>
<groupId>com.alipay.sofa.common</groupId>
<artifactId>sofa-common-tools</artifactId>
<version>1.0.12</version>
</dependency>
<dependency>
<groupId>com.alipay.sofa</groupId>
<artifactId>bolt</artifactId>
<version>1.4.1</version>
</dependency>
<dependency>
<groupId>com.alibaba.toolkit.common</groupId>
<artifactId>toolkit-common-lang</artifactId>
<version>1.1.1</version>
</dependency>
<dependency>
<groupId>com.alipay.sofa</groupId>
<artifactId>hessian</artifactId>
<version>3.3.0</version>
</dependency>
<dependency>
<groupId>com.alipay.sofa.lookout</groupId>
<artifactId>lookout-api</artifactId>
<version>1.4.3</version>
</dependency>
<dependency>
<groupId>com.alipay.sofa</groupId>
<artifactId>tracer-core</artifactId>
<version>2.1.1</version>
</dependency>
<dependency>
<groupId>com.alipay.sofa</groupId>
<artifactId>tracer-extensions</artifactId>
<version>2.1.1</version>
</dependency>
<dependency>
<groupId>com.alipay.common</groupId>
<artifactId>tracer</artifactId>
<version>2.1.1</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>20.0</version>
</dependency>
初始化客户端 Client。示例如下:
@Override
public void onApplicationEvent(ContextRefreshedEvent event) {
try {
ApplicationContext applicationContext = event.getApplicationContext();
Map<String, IJobHandler> handlerBeans = applicationContext
.getBeansOfType(IJobHandler.class);
for (IJobHandler handler : handlerBeans.values()) {
handlerList.add(handler);
}
// zone(cell),如果为空则认为不分zone(cell)
zone = System.getProperty("com.alipay.ldc.zone");
Config config = new Config(app, zone, instanceId, accessKey, securityKey);
AntVipRouterConfig routerConfig = new AntVipRouterConfig();
routerConfig.setEndPoint(antvipEndpoint);
AntVipRouter router = new AntVipRouter(routerConfig);
antSchedulerClient = new AntSchedulerClient(config, router, handlerList);
antSchedulerClient.init();
} catch (Throwable t) {
LOGGER.error("init antschedulerclient error", t);
throw new RuntimeException(t);
}
}
在文档使用中是否遇到以下问题
更多建议
匿名提交