任務注冊中心(registry)

registry是任務注冊中心，在整個生態圈內擔任著各個組件注冊節點的任務，任務注冊中心實現方式是多樣化的，目前包含：memory、zookeeper、redis、consul等。

通過idea、eclipse工具創建SpringBoot項目并添加如下依賴到pom.xml文件內。

com.github.hengboyspring-boot-starter-registry-memory{lastVersion}

在resources資源目錄下添加application.yml配置文件，配置內容如下所示：

server: port: 9000hengboy: job: registry: # 任務注冊中心節點注冊方式 away: memory

任務調度器(schedule)

schedule是任務調度器，每一個任務的創建都是通過調度器進行分配執行，分配過程中根據消費節點的負載均衡策略配置進行不同消費者節點任務消費。

在生產任務時，也會根據調度器的負載均衡策略來進行篩選執行任務調度的調度器節點。

通過idea、eclipse工具創建SpringBoot項目并添加如下依賴到pom.xml文件內。

com.github.hengboy spring-boot-starter-schedule {lastVersion}

在resources資源目錄下添加application.yml配置文件，配置內容如下所示：

server: port: 8081hengboy: job: registry: # 保持與任務注冊中心節點注冊方式一致即可 away: memory schedule: # 內存方式調度器處理任務隊列以及任務日志的存儲 job-store-type: memory

任務消費節點(consumer)

consumer是任務消費者執行節點，任務由consumer進行定義以及上報，當schedule調用消費者執行任務請求時，會自動根據jobKey來執行對應的任務邏輯方法。

通過idea、eclipse工具創建SpringBoot項目并添加如下依賴到pom.xml文件內。

com.github.hengboyspring-boot-starter-consumer{lastVersion}

在resources資源目錄下添加application.yml配置文件，配置內容如下所示：

server: port: 8082hengboy: job: registry: # 保持與任務注冊中心節點注冊方式一致即可 away: memory

任務定義示例

我們來定義一個簡單的Job，示例如下所示：

@Job(jobExecuteAway = JobExecuteAwayEnum.ONCE)public class TestJob implements MicroJob { /** * logger instance */ static Logger logger = LoggerFactory.getLogger(TestJob.class); @Override public JobExecuteResult execute(JobExecuteParam jobExecuteParam) throws JobException { logger.info("執行Key：{}，執行參數：{}

總結

以上是生活随笔為你收集整理的plsql job执行多个存储过程_spring-boot-micro-job一款分布式任务调度执行框架的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。