xxl-job 带参数执行和高可用部署方法

目录
  • 1. 单参数
  • 2. 多参数
  • 3. 多节点部署

xxl-job 获取参数：

String param = XxlJobHelper.getJobParam();

1. 单参数

@XxlJob("TestOneHandler")
public ReturnT<String> jobDemo(String s) throws Exception {
    String param = XxlJobHelper.getJobParam();
    System.out.println("TestOneHandler执行参数:"+param);
    return SUCCESS;
}

运行结果：

2. 多参数

自定义分割方式

@XxlJob("TestOneHandler")
public ReturnT<String> jobDemo(String s) throws Exception {
    String param = XxlJobHelper.getJobParam();
    String[] methodParams = param.split(",");
    System.out.println("TestOneHandler执行参数1:"+methodParams[0]);
    System.out.println("TestOneHandler执行参数2:"+methodParams[1]);
    return SUCCESS;
}

运行结果：

3. 多节点部署

admin服务端只部署一个节点（xxx.xx.xxx.141）
Job客户端部署两个节点（xxx.xx.xxx.141，和本地机器xxx.xx.xxx.191，两台机器在一个内网环境下）

@XxlJob("TestOneHandler")
public ReturnT<String> jobDemo(String s) throws Exception {
    String param = XxlJobHelper.getJobParam();
    System.out.println("TestOneHandler执行参数:"+param);
    RecordDTO record = new RecordDTO();
    record.setIp("");
    record.setParams(param);
    recordService.insert(record);
    return SUCCESS;
}

1、部署xxl-job-admin服务端
在xxl-job-admin项目下执行mvn clean package打包，把生成的jar包上传到141服务器上并执行启动命令java -jar xxl-job-admin-2.3.0.jar
启动后访问

2、job-client部署
在job-client项目下也执行mvn clean package把打包后的jar包上传到141上，执行java -jar job-client-1.0-SNAPSHOT.jar &启动。

3、本地节点部署

到此这篇关于xxl-job 带参数执行和高可用部署的文章就介绍到这了,更多相关xxl-job高可用部署内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • SpringBoot部署xxl-job方法详细讲解

    目录 部署xxl-job SpringBoot配置 maven 配置 application.yaml 配置 XxlJobConfig XxlJobSpringExecutor 新建执行任务 配置xxl-job-admin 执行器管理 任务管理 部署xxl-job K8S 部署 xxl-job 参考文档:https://www.jb51.net/article/252770.htm SpringBoot配置 maven 配置 pom 文件添加依赖 <!--xxl-job依赖--> <de

  • 分布式任务调度xxl-job问题解决

    分布式任务调度xxl-job问题解决

    目录 前言 xxl-job简介 功能如下 快速入门 2.1初始化“调度数据库” 2.2编译源码 2.3配置部署“调度中心” 2.4配置部署“执行器项目” 2.5开发第一个任务“HelloWorld” 前言 在单机应用时期,任务调度一般都是基于spring schedule和集成quartz来实现的,当系统发展成分布式服务,应用多实例的时候,任务就会出现多次调用的问题,很多时候我们任务并不需要跑多次.解决方案有很多,最最简单粗暴的就是可以设置应用开关.其次就是集中式话任务管理调度.当然,quart

  • docker部署xxl-job-admin出现数据库拒绝问题及解决方法

    目录 docker部署xxl-job-admin出现数据库拒绝 问题出现: 1.拉取代码: 2.docker部署mysql 3.部署代码: 4.问题出现logs(摘取部分错误): 5.问题的解决思路: 6.总结: 扩展:docker 安装 xxl-job 1.安装mysql 2.安装xxl-job-admin 3.浏览器登录 docker部署xxl-job-admin出现数据库拒绝 笔者能力有限,小白一枚,在遇到问题之后记录问题的解决方式为主要目的,欢迎各位探讨交流. 问题出现: 1.拉取代码:

  • springboot整合xxl-job实现分布式定时任务的过程

    目录 一.前言 二.xxl-job介绍 三.修改配置 1. 运行sql文件 2. 修改xxl-job-admin配置 3. 需修改xxl-job-executor-sample-springboot配置 4. 添加自己的定时任务 四.运行项目 1. 启动项目 2. 登录 3. xxl-job的好处 4. 查看执行器获取网址 5. 新增任务管理 6. 执行任务 7. 执行成功 8. 查看日志 五.总结 一.前言 定时任务有很多种,有一些大的框架也有一些简单的实现.比如常见的: JDK的Timer和

  • springboot整合xxl-job的示例代码

    springboot整合xxl-job的示例代码

    目录 关于xxl-job 调度中心 执行器 关于xxl-job 在我看来,总体可以分为三大块: 调度中心 执行器 配置定时任务 调度中心 简单来讲就是 xxl-job-admin那个模块,配置: 从doc里面取出xxl-job.sql的脚本文件,创建对应的数据库. 进行配置文件的配置,如下图 进行日志存放位置的修改 然后idea打包之后就能当作调度中心运行了 访问地址:ip:port/xxl-job-admin 默认的账号密码:admin/123456 注意:你进去后修改密码,有些浏览器就算你账

  • xxl-job 带参数执行和高可用部署方法

    目录 1. 单参数 2. 多参数 3. 多节点部署 xxl-job 获取参数: String param = XxlJobHelper.getJobParam(); 1. 单参数 @XxlJob("TestOneHandler") public ReturnT<String> jobDemo(String s) throws Exception { String param = XxlJobHelper.getJobParam(); System.out.println(&

  • 微信小程序实现带参数的分享功能(两种方法)

    微信小程序分享功能的实现方法有两种: 第一种 在page.js中实现onShareAppMessage,便可在小程序右上角选择分享该页面 onShareAppMessage: function () { return { title: '弹出分享时显示的分享标题', desc: '分享页面的内容', path: '/page/user?id=123' // 路径,传递参数到指定页面. } } 第二种 自定义按钮实现分享,在page中添加一个带有open-type='share'的button标签

  • seata docker 高可用部署的详细介绍

    版本 1.4.2 官方文档 dockerhub 启动 通过环境变量SEATA_CONFIG_NAME指定配置文件位置/root/seata-config/registry.conf docker run --name seata-server \ -p 8091:8091 \ -e SEATA_CONFIG_NAME=file:/root/seata-config/registry \ -v /User/seata/config:/root/seata-config \ seataio/seat

  • keepalived+nginx高可用实现方法示例

    1.keepalived介绍 keepalived最初是专为LVS负载均衡软件设计的,用来管理并监控LVS集群系统中各个服务节点的状态,后来又加入了实现高可用的VRRP功能.keepalived除了能够管理LVS软件外,还能支持其他服务的高可用解决方案. keepalived通过VRRP协议实现高可用功能的.VRRP(Virtual Router Redundancy Protocol)虚拟路由冗余协议.VRRP出现的目的就是为了解决静态路由单点故障问题,它能保证当个别节点宕机时,整个网络可以不

  • keepalived结合nginx实现nginx高可用的方法

    1.简介 Keepalived 是一个基于VRRP协议来实现的LVS服务高可用方案,可以利用其来避免单点故障.一个LVS服务会有2台服务器运行Keepalived,一台为主服务器(MASTER),一台为备份服务器(BACKUP),但是对外表现为一个虚拟IP,主服务器会发送特定的消息给备份服务器,当备份服务器收不到这个消息的时候,即主服务器宕机的时候, 备份服务器就会接管虚拟IP,继续提供服务,从而保证了高可用性.Keepalived是VRRP的完美实现,因此在介绍keepalived之前,先介绍

  • JS中setInterval、setTimeout不能传递带参数的函数的解决方案

    在JS中无论是setTimeout还是setInterval,在使用函数名作为调用句柄时都不能带参数,而在许多场合必须要带参数, 这就需要想方法解决. 一.采用字符串形式:--(缺陷)参数不能被周期性改变 setInterval("foo(id)",1000); 二.匿名函数包装 (推荐) 复制代码 代码如下: window.setInterval(function() { foo (id); }, 1000); 这样就可以周期性执行foo(id)这个函数,而且把变量id传递进去: 三

  • spring cloud config分布式配置中心的高可用问题

    spring cloud config分布式配置中心的高可用问题

    在前面的文章中,我们实现了配置文件统一管理的功能,但是我们可以发现,我们仅仅只用了一个server,如果当这个server挂掉的话,整个配置中心就会不可用,下面,我们就来解决配置中心的高可用问题. 下面我们通过整合Eureka来实现配置中心的高可用,因为作为架构内的配置管理,本身其实也是可以看作架构中的一个微服务,我们可以把config server也注册为服务,这样所有客户端就能以服务的方式进行访问.通过这种方法,只需要启动多个指向同一Gitlab仓库位置的config server端就能实现

  • 基于命令行执行带参数的php脚本并取得参数的方法

    本文分析了基于命令行执行带参数的php脚本并取得参数的方法.分享给大家供大家参考,具体如下: 一.为什么我们要在命令行下运行php脚本呢? 个人理解,主要有二个原因: 1. 利用crontab去跑php,可以给服务器减压,当然在这里有一个条件,就是实时性要求不高.比如:sns中的好友动态,这个实时要求不高,但是数据量比较大,这个时候定时跑的话,会给web服务器,数据库服务器分担不小的压力. 2. 就是我们要定时去完成某一事情,比如:我要删除一个月前,用户留言,这个时候,写的php脚本在cront

  • 带你了解HDFS的Namenode 高可用机制

    带你了解HDFS的Namenode 高可用机制

    目录 HDFS NameNode 高可用 Hadoop Namenode 高可用架构 Namenode 高可用的实现 隔离(Fencing) QJM共享存储 HDFS NameNode 高可用 在 Hadoop 2.0.0 之前,一个集群只有一个Namenode,这将面临单点故障问题.如果 Namenode 机器挂掉了,整个集群就用不了了.只有重启 Namenode ,才能恢复集群.另外正常计划维护集群的时候,还必须先停用整个集群,这样没办法达到 7 * 24小时可用状态.Hadoop 2.0

  • asp执行带参数的sql语句实例

    asp执行带参数的sql语句,需要向sql语句添加参数,可以有效屏蔽SQL注入,源代码如下: 复制代码 代码如下: var conn = Server.CreateObject("ADODB.Connection"); conn.ConnectionString = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" + Server.MapPath("Test.mdb"); conn.Open();

随机推荐