SpringBoot集成系列

2025-06-24 12:52:56 141

文章目录。

  • 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
版权声明

本文仅代表作者观点,不代表本站立场。
本文系作者授权发表,未经许可,不得转载。

热门标签

全站热门

Sancc C34uPro:240Hz电竞屏幕,WQHD分辨率,21:视角宽,视觉盛宴1999元

小米Xiaomi 15 限时购买4279元5G手机

Sqop将hive处理的数据导出到MySQL

【Hadoop】HA高可用搭建保姆级教程(大二学长的万字笔记)

不按套路出牌的“理科男”,靠好奇心成为“华文推理之光”!

毒毒V3极速版无线鼠标手价287.23!

Realme GT6 5g手机到手价1834元!

R、python读取空间转录组的8种方式

友情链接