From 555a20bc7ff5933bde37f9b0660e9c610e85a514 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9C=B1=E5=85=AB?= Date: Sat, 1 Aug 2020 21:45:45 +0800 Subject: [PATCH] [dev] samples change to use powerjob-spring-boot-starter & change pom version to 3.2.2 --- pom.xml | 2 +- powerjob-client/pom.xml | 4 ++-- powerjob-common/pom.xml | 2 +- powerjob-server/pom.xml | 4 ++-- powerjob-worker-agent/pom.xml | 4 ++-- powerjob-worker-samples/pom.xml | 8 ++++---- .../powerjob/samples/OhMySchedulerConfig.java | 19 +++++++------------ .../src/main/resources/application.properties | 10 +++++++++- powerjob-worker-spring-boot-starter/pom.xml | 4 ++-- powerjob-worker/pom.xml | 4 ++-- 10 files changed, 32 insertions(+), 29 deletions(-) diff --git a/pom.xml b/pom.xml index ae73497b..2a3fc49d 100644 --- a/pom.xml +++ b/pom.xml @@ -9,7 +9,7 @@ 2.0.0 pom powerjob - https://github.com/KFCFans/PowerJob + http://www.powerjob.tech Distributed scheduling and execution framework diff --git a/powerjob-client/pom.xml b/powerjob-client/pom.xml index 83485c94..d464c9d4 100644 --- a/powerjob-client/pom.xml +++ b/powerjob-client/pom.xml @@ -10,11 +10,11 @@ 4.0.0 powerjob-client - 3.2.1 + 3.2.2 jar - 3.2.1 + 3.2.2 5.6.1 diff --git a/powerjob-common/pom.xml b/powerjob-common/pom.xml index f0aadcfb..9aa123c9 100644 --- a/powerjob-common/pom.xml +++ b/powerjob-common/pom.xml @@ -10,7 +10,7 @@ 4.0.0 powerjob-common - 3.2.1 + 3.2.2 jar diff --git a/powerjob-server/pom.xml b/powerjob-server/pom.xml index 0675761e..835d725b 100644 --- a/powerjob-server/pom.xml +++ b/powerjob-server/pom.xml @@ -10,13 +10,13 @@ 4.0.0 powerjob-server - 3.2.1 + 3.2.2 jar 2.9.2 2.2.6.RELEASE - 3.2.1 + 3.2.2 8.0.19 19.7.0.0 diff --git a/powerjob-worker-agent/pom.xml b/powerjob-worker-agent/pom.xml index b6a16adb..42d7ef9f 100644 --- a/powerjob-worker-agent/pom.xml +++ b/powerjob-worker-agent/pom.xml @@ -10,12 +10,12 @@ 4.0.0 powerjob-worker-agent - 3.2.1 + 3.2.2 jar - 3.2.1 + 3.2.2 1.2.3 4.3.2 diff --git a/powerjob-worker-samples/pom.xml b/powerjob-worker-samples/pom.xml index 071be86e..3b0f37e2 100644 --- a/powerjob-worker-samples/pom.xml +++ b/powerjob-worker-samples/pom.xml @@ -10,11 +10,11 @@ 4.0.0 powerjob-worker-samples - 3.2.1 + 3.2.2 2.2.6.RELEASE - 3.2.1 + 3.2.2 1.2.68 @@ -43,8 +43,8 @@ com.github.kfcfans - powerjob-worker - ${powerjob.worker.version} + powerjob-worker-spring-boot-starter + ${powerjob.worker.starter.version} diff --git a/powerjob-worker-samples/src/main/java/com/github/kfcfans/powerjob/samples/OhMySchedulerConfig.java b/powerjob-worker-samples/src/main/java/com/github/kfcfans/powerjob/samples/OhMySchedulerConfig.java index b4316a36..74b9defc 100644 --- a/powerjob-worker-samples/src/main/java/com/github/kfcfans/powerjob/samples/OhMySchedulerConfig.java +++ b/powerjob-worker-samples/src/main/java/com/github/kfcfans/powerjob/samples/OhMySchedulerConfig.java @@ -1,17 +1,10 @@ package com.github.kfcfans.powerjob.samples; -import com.github.kfcfans.powerjob.worker.OhMyWorker; -import com.github.kfcfans.powerjob.worker.common.OhMyConfig; -import com.github.kfcfans.powerjob.worker.common.constants.StoreStrategy; -import com.google.common.collect.Lists; -import org.springframework.beans.factory.annotation.Value; -import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; -import java.util.List; - /** - * OMS-Worker 配置 + * powerjob-worker 配置 + * 代码配置示例,SpringBoot 项目支持使用 starter,只需要在 application.properties 中完成配置即可 * * @author tjq * @since 2020/4/17 @@ -19,8 +12,7 @@ import java.util.List; @Configuration public class OhMySchedulerConfig { - @Value("${powerjob.akka.port}") - private int port; + /* @Bean public OhMyWorker initOMS() throws Exception { @@ -30,7 +22,7 @@ public class OhMySchedulerConfig { // 1. 创建配置文件 OhMyConfig config = new OhMyConfig(); - config.setPort(port); + config.setPort(27777); config.setAppName("powerjob-agent-test"); config.setServerAddress(serverAddress); // 如果没有大型 Map/MapReduce 的需求,建议使用内存来加速计算 @@ -40,5 +32,8 @@ public class OhMySchedulerConfig { OhMyWorker ohMyWorker = new OhMyWorker(); ohMyWorker.setConfig(config); return ohMyWorker; + } + + */ } diff --git a/powerjob-worker-samples/src/main/resources/application.properties b/powerjob-worker-samples/src/main/resources/application.properties index 7d804f17..ef35ebd2 100644 --- a/powerjob-worker-samples/src/main/resources/application.properties +++ b/powerjob-worker-samples/src/main/resources/application.properties @@ -2,4 +2,12 @@ server.port=8081 spring.jpa.open-in-view=false -powerjob.akka.port=27777 \ No newline at end of file +########### powerjob-worker 配置 ########### +# akka 工作端口,可选,默认 27777 +powerjob.akka-port=27777 +# 接入应用名称,用于分组隔离,推荐填写 本 Java 项目名称 +powerjob.app-name=powerjob-agent-test +# 调度服务器地址,IP:Port 或 域名,多值逗号分隔 +powerjob.server-address=127.0.0.1:7700,127.0.0.1:7701 +# 持久化方式,可选,默认 disk +powerjob.store-strategy=disk \ No newline at end of file diff --git a/powerjob-worker-spring-boot-starter/pom.xml b/powerjob-worker-spring-boot-starter/pom.xml index 73c237bf..d778229d 100644 --- a/powerjob-worker-spring-boot-starter/pom.xml +++ b/powerjob-worker-spring-boot-starter/pom.xml @@ -10,11 +10,11 @@ 4.0.0 powerjob-worker-spring-boot-starter - 3.2.1 + 3.2.2 jar - 3.2.1 + 3.2.2 2.2.6.RELEASE diff --git a/powerjob-worker/pom.xml b/powerjob-worker/pom.xml index 7fb3fd36..9aee1ae2 100644 --- a/powerjob-worker/pom.xml +++ b/powerjob-worker/pom.xml @@ -10,12 +10,12 @@ 4.0.0 powerjob-worker - 3.2.1 + 3.2.2 jar 5.2.4.RELEASE - 3.2.1 + 3.2.2 1.4.200 3.4.2 5.6.1