重庆网站建设letide,网络平面设计包括哪些,建设app下载官网,wordpress主题制作教程PowerJob介绍
PowerJob 是全新一代分布式任务调度和计算框架#xff0c;提供了可视化界面#xff0c;可通过单机、远程等形式调用任务并提供了运行监控和日志查看的功能模块#xff0c;是当前比较流行的分布式定时任务框架之一#xff1b; PowerJob 官网文档地址
环境搭建…PowerJob介绍
PowerJob 是全新一代分布式任务调度和计算框架提供了可视化界面可通过单机、远程等形式调用任务并提供了运行监控和日志查看的功能模块是当前比较流行的分布式定时任务框架之一 PowerJob 官网文档地址
环境搭建
本文介绍的是通过远程调用的形式实现定时任务的综合治理可直接通过官网提供的初始化项目直接进行搭建基础框架 git 下载命令
git clone https://github.com/PowerJob/PowerJob.git下载完成之后目录结构如下 其中我们只需要关注powerjob-worker-samples模块和powerjob-server下的powerjob-server-starter模块这两个模块主要是调度服务器和使用案例如果我们需要将起整合到项目中这两个模块是必须的其它的项目可生成JAR文件导入到项目中即可。 powerjob-server是我们的调度服务模块类似于注册中心我们需要对其进行一些简单的改善成为我们的“利刃”。 powerjob-server-starter项目下的properties文件修改application-daily.properties
oms.envDAILY
logging.configclasspath:logback-dev.xml
####### Database properties(Configure according to the the environment) #######
spring.datasource.core.driver-class-nameorg.postgresql.Driver
spring.datasource.core.jdbc-urljdbc:postgresql://pg10:5432/powerjob_mange
spring.datasource.core.usernamejob_manager
spring.datasource.core.passwordjob_manager_123
spring.datasource.core.maximum-pool-size20
spring.datasource.core.minimum-idle5
####### Resource cleaning properties #######
oms.instanceinfo.retention1
oms.container.retention.local1
oms.container.retention.remote-1
####### Cache properties #######
oms.instance.metadata.cache.size1024
####### Threshold in precise fetching server(0~100). 100 means full detection of server, in which #######
####### split-brain could be avoided while performance overhead would increase. #######
oms.accurate.select.server.percentage 50这里我们主要是更改我们的数据地址基础项目中还存在这样一段代码
####### Storage properties(Delete if not needed) #######
#oms.storage.dfs.mongodb.urimongodbsrv://zqq:No1Bug2Please3!cluster0.wie54.gcp.mongodb.net/powerjob_daily?retryWritestruewmajority
oms.storage.dfs.mysql_series.driverorg.postgresql.Driver
oms.storage.dfs.mysql_series.urljdbc:mysql://powerjob-mysql:3306/powerjob-daily?useUnicodetruecharacterEncodingUTF-8serverTimezoneAsia/Shanghai
oms.storage.dfs.mysql_series.usernameroot
oms.storage.dfs.mysql_series.passwordNo1Bug2Please3!
oms.storage.dfs.mysql_series.auto_create_tabletrue###### Email properties(Non-core configuration properties) #######
###### Delete the following code to disable the mail #######
spring.mail.hostsmtp.163.com
spring.mail.usernamezqq163.com
spring.mail.passwordGOFZPNARMVKCGONV
spring.mail.properties.mail.smtp.authtrue
spring.mail.properties.mail.smtp.starttls.enabletrue
spring.mail.properties.mail.smtp.starttls.requiredtrue###### DingTalk properties(Non-core configuration properties) #######
###### Delete the following code to disable the DingTalk #######
oms.alarm.ding.app-keydingauqwkvxxnqskknfv
oms.alarm.ding.app-secretXWrEPdAZMPgJeFtHuL0LH73LRj-74umF2_0BFcoXMfvnX0pCQvt0rpb1JOJU_HLl
oms.alarm.ding.agent-id847044348这些配置是配置一些短信通知数据存储的这边就不做多的讲解了一般没有特殊要求不需要配置这些数据的。 powerjob-worker-samples是我们的基础框架生成出来的一个实例程序经过博主的测试如果不启动修改这个项目的配置文件那么我们项目是无法正常使用的虽然可以打开UI界面但是无法进行其它操作 对powerjob-worker-samples的application.properties进行修改修改内容如下
server.port8081spring.jpa.open-in-viewfalse########### powerjob-worker 配置 ###########
# akka 工作端口可选默认 27777
powerjob.worker.akka-port27777
# 接入应用名称用于分组隔离推荐填写 本 Java 项目名称
powerjob.worker.app-namepowerjob-worker-samples
# 调度服务器地址IP:Port 或 域名多值逗号分隔
powerjob.worker.server-address127.0.0.1:7700,127.0.0.1:7701
# 持久化方式可选默认 disk
powerjob.worker.store-strategydisk
# 任务返回结果信息的最大长度超过这个长度的信息会被截断默认 8192
powerjob.worker.max-result-length4096
# 单个任务追加的工作流上下文最大长度超过这个长度的会被直接丢弃默认 8192
powerjob.worker.max-appended-wf-context-length4096其中需要注意一下name的属性值是我们等下需要进行注册的用户名需要相对于的 具体使用在官方文档中有比较详细的介绍我这边就不过多描述了。 这里要特别提醒一下项目打包的时候需要对lombok的版本进行调整 lombok.version1.18.24/lombok.version将版本调成这个版本就不会打包报错了
项目使用 这里只介绍者一种方式请求参数中的URL是需要执行定时任务的请求路径可拼接参数什么的具体因实际需求更改。
tech.powerjob.official.processors.impl.HttpProcessor这个是HTTP远程请求的固定写法不能更改的 其它的执行配置可以参考个官方文档进行使用如有不对欢迎指正。 参考文档https://www.yuque.com/powerjob/guidence/quick_start