SpringBoot集成系列
文章目录。
- 1.建立调度中心xxll-job-admin。
- 1、下载项目。
- 2、调整项目参数。
- 3、SQL执行初始化数据库。
- 4、启动项目。
- 5、访问。
- 二、集成步骤。
- 1、添加xxl-job依赖性。
- 2、添加xxl-job依赖性。
- 3、配置执行器。
- 4、创建执行器。
- 5、开发任务。
- 1)方法1:BEAN模式(方法形式)
- 2)方法2:GLUE模式(Java)。
- 6、测试。
- 三、总结。
1.建立调度中心xxll-job-admin。
1、下载项目。
https://gitee.com/xuxueli0323///xxl-job。
2、调整项目参数。
端口号冲突修改端口号,不同的数据库密码,更改您的密码。
3、SQL执行初始化数据库。
4、启动项目。
将项目打包成jar包和#xff0c;使用java -jar命令启动。
5、访问。
访问。http://localhost:8087/xxl-job-admin。
,输入用户名:admin,密码:123456,这是默认初始化的用户名和密码,登录成功。
二、集成步骤。
1、添加xxl-job依赖性。
引入对pom的依赖.xml。
<!。--。Xxl。-。Job。--。><dependency。><groupId。>com。.。xuxueli。</。groupId。><artifactId。>xxl。-。job。-。core。</。artifactId。><version。>2.3。.0。</。version。></。dependency。>
2、添加xxl-job依赖性。
application.properties添加xxl-job配置。
### 根地址部署在调度中心。 [。选填。]。:如果调度中心集群部署有多个地址,则用逗号分隔。该地址将用于执行器。"执行器心跳注册"和。"回调任务结果";自动注册;xxl。.。job。.。admin。.。addresses。=http。:。/。/。127.0。.0。.1。:。8087。/。xxl。-。job。-。admin### 执行器通信。TOKEN。[。选填。]。:非空时启用;xxl。.。job。.。accessToken。=default_token### 执行器。AppName。[。选填。]。:执行器心跳注册分组依据;自动注册xxl为空关闭。.。job。.。executor。.。appname。=xxl。-。job。-。executor。-。forlan### 注册执行器。 [。选填。]。:优先使用该配置作为注册地址,在空闲时间使用内嵌服务 ”。IP。:。PORT。“ 注册地址。从而更灵活地支持容器类型执行器的动态。IP。动态映射端口问题。xxl。.。job。.。executor。.。address。=### 执行器。IP。[。选填。]。:默认为空意味着自动获取。IP。,手动设置多网卡指定。IP。,该。IP。不会绑定。Host。仅作为通信实用;地址信息用于。 "执行器注册"和。 "调度中心要求并触发任务";xxl。.。job。.。executor。.。ip。=### 执行器端口号。 [。选填。]。:小于等于。0自动获取;默认端口为。9999。,单机部署多个执行器时注意配置不同的执行器端口;xxl。.。job。.。executor。.。port。=9999。### 磁盘路径存储在执行器操作日志文件中。 [。选填。]。:该路径需要阅读和写作权限;默认路径;xxl。.。job。.。executor。.。logpath。=D。:。/。data。/。applogs。/。xxl。-。job。/。jobhandler### 保存执行器日志文件的天数。 [。选填。]。: 自动清理过期日志。,限制值大于或等于。3。时生效。;否则。,如。-。1。,关闭自动清洁功能;xxl。.。job。.。executor。.。logretentiondays。=30。
3、执行器的配置。
xxl-job执行器的初始化和配置#xff0c;将其集成到Spring 在Boot应用中。
@Configuration。public。class。XxlJobConfig。{ 。// 任务执行逻辑。System。.。out。.。println。(。"MyXxlJobHandler is running.")。;XxlJobHelper。.。log。(。"MyXxlJobHandler is running.")。;}。}。
选择任务管理菜单新任务保存填写信息即可。
填写说明书:
- 执行器:选择我们以前创建的。
- 报警邮件:如果需要报警,,可配邮箱任务失败时会触发。
- Jobhandler填写我们代码注释中的myXxlJobhandler。
- 路由策略:在部署执行器集群时,提供丰富的路由策略,包括:第一,最后一,轮询,随机,一致性HASH、最不常用,最近最久没用,故障转移,忙碌转移等,根据情况选择自己。
- 阻塞处理策略:太密集的执行器来不及处理时的调度处理策略,该策略包括:单机串行(默认)、丢弃后续调度,覆盖之前的调度;
2)方法2:GLUE模式(Java)。
直接在调度中心,新的调度任务,选择运行模式 "GLUE模式(Java)”。
选择指定任务点击任务右侧“GLUE按钮,Web将前往GLUE任务 IDE界面。
编写我们的代码,保存即可。
6、测试。
选择执行一次你可以看到成功的执行。
查看日志我们可以看到我们的执行情况。
三、总结。
xxl-job包括两个主要部分:调度中心和执行器,调度中心负责管理调度信息c;根据调度配置发出调度请求,执行器负责接收调度请求,执行Jobhandler中相应的业务逻辑。通过这种方式,“调度”和“任务”两部分可以相互解耦,提高系统的整体稳定性和扩展性。
一般原理如下:
- 任务注册:通过xxl注册任务-job-在admin管理平台上配置任务信息c;包括任务名称、执行器地址、任务参数等。
- 任务调度:xxl-job-Admin管理平台将根据任务配置信息,将任务调度信息写入数据库。调度中心定期扫描数据库,根据任务的调度策略和触发器条件,任务调度应选择合适的执行器节点。
- 任务执行:执行器节点定期向调度中心发送心跳请求c;获取待执行的任务。根据任务的调度策略,调度中心,将任务分配给执行器节点。执行器节点收到任务后,根据任务类型和参数执行任务。
- 任务监控:xxl-job提供任务监控功能,您可以查看任务的执行情况、日志和统计信息。执行节点将向调度中心报告任务的执行情况和日志信息c;调度中心在数据库中存储这些信息,用户查看。
通过上述功能xxl-job实现了分布式任务的调度和执行,提供可靠高效的任务调度解决方案。
本文地址:http://cdn.baiduyun.im/video/www.bfzx365.com/news/show.php/video/688b56598746.html
版权声明
本文仅代表作者观点,不代表本站立场。
本文系作者授权发表,未经许可,不得转载。