搭建一个中心化的定时服务

news2024/11/22 16:39:58

1. 背景

        在物联网络，很多设备之间都在进行交互，其中云端在远程交流中起到了很重要的作用。比如，一台设备想进行调温，但是需要知道此时房间的温度，那就需要定时去查询传感器测出来的房间温度，如果温度过高，就降低温度， 否则就升高温度。在这个过程中云端就需要对传感器的状态进行监控，其中的定时任务就起到了作用。

什么是定时任务呢？

        定时任务简答来说就是在指定时间内触发执行某个动作，比如早上设备了闹钟，提醒你起床。

2. 定时搭建的方式

2.1.1 Spring提供的注解

在SpringBoot应用中，有提供@EnableScheduling、@Scheduled来实现定时。其中：

  • @Scheduled注解是SpringBoot提供的⽤于定时任务控制的注解,主要⽤于控制任务在某个指定时间执⾏,或者每隔⼀段时间执⾏。

  • 注意需要配合@EnableScheduling使⽤，定时任务需要在配置类上添加@EnableScheduling，表示对定时任务的支持；在对应执行任务的方法上添加@Scheduled，声明需要执行定时任务的方法。

@Scheduled主要有三种配置执⾏时间的⽅式：cron、fixedRate、fixedDelay。例子分别是：

  • @Scheduled(cron = "0 0/5 * * * ?") // 每5分钟执行一次
  • @Scheduled(fixedDelay = 10000) // fixedDelay 表示固定延迟时间，上个任务完成后，延迟多长时间执行
  • @Scheduled(fixedRate = 1000 * 60) // 按照一定频率执行任务，每隔1分钟执行一次

2.1.2 具体应用

        使用@Scheduled注解的方式非常简单，首先我们创建一个类，并且加上@Component注解，确保可以被扫描。 然后我们在方法上加上这里要用到的定时任务注解@Scheduled() 其中，有个参数 cron=""，是用来写入cron表达式的。

@Component
public class CronJob{
    // 定义每隔5分钟执行一次“Hello World”打印
    `@Scheduled`(cron="0 0/5 * * * ?")
    public void printHWScheduled(){
        System.out.println("Hello World");
    }
}

具体的cron表达式练习：

具体的cron表达式练习

        除了配置@Scheduled注解，还需要在启动类上添加注解@EnableScheduling，以上两步就可以实现对方法实现定时。

@EnableScheduling
@SpringBootApplication
public class HelloWorldApplication {
    public static void main(String[] args) {
        SpringApplication.run(HelloWorldApplication.class, args);
    }

}

综上所述，使用注解的方式在SpringBoot的框架是非常方便实现定时任务的。但是也存在缺点：

  • 不支持集群： 常用于单机系统，如果部署到多台机器的话，会导致同时触发问题。
  • 常用于小型任务：对于大型任务更需要单独任务调度平台，对于频繁更新cron时， 以注解的方式就显得力不从心。

对此接下来介绍一种，轻量化分布式任务调度平台。xxl-job，地址为：

xxl-job项目地址

2.2.1 轻量化分布式任务调度平台 --xxl-job

        XXL-JOB是一个分布式任务调度平台，其核心设计目标是开发迅速、学习简单、轻量级、易扩展。该项目在github完全开源，有着丰富的文档、活跃的社区。由于其开箱即用，已经被很多互联网公司接入产品线。

相较于@Scheduled注解，xxl-job有着一下的优点：

  • 操作简单：可以使用Web页面对任务进行更新；
  • 动态：支持动态修改任务状态、启动/停止任务，并且能即时生效；
  • 调度中心HA（中心式）：调度采用中心式设计，“调度中心”自研调度组件并支持集群部署，可保证调度中心HA。

等等，还有其他的优点。

2.2.2 如何搭建调度平台

接下就演示一下，在本地如何搭建一个xxl-job服务。

  • 首先clone项目到本地

在这里插入图片描述

  • 运行sql，建立数据库，建立必要的表
    在这里插入图片描述

在这里插入图片描述

  • 修改xxl-job-admin中的数据库路径

在这里插入图片描述

  • 使用maven对项目进行打包，在终端使用命令：mvn install。如下图所示，生成了一个war包

在这里插入图片描述

  • 这一步需要准备好tomcat服务，将war包放到webapps目录下，然后再bin目录下，点击startup.bat启动tomcat
    在这里插入图片描述

在这里插入图片描述

  • 输入服务的地址：http://localhost:8080/xxl-job-admin-1.9.2/， 账号：admin 12345
    在这里插入图片描述

如果出现了以上的界面，就说明任务调度中心Web界面就搭建完成。

2.2.3 如何使用xxl-job实现定时

接下来讲解下在SpringBoot中如何使用xxl-job。

  • 首先在pom.xml中导入依赖
<dependency>
    <groupId>com.xuxueli</groupId>
    <artifactId>xxl-job-core</artifactId>
    <version>2.3.1</version>
</dependency>
  • 新增配置类
package com.xxl.job.executor.core.config;

import com.xxl.job.core.executor.XxlJobExecutor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;

/**
 * xxl-job config
 *
 * @author xuxueli 2017-04-28
 */
@Configuration
@ComponentScan(basePackages = "com.xxl.job.executor.service.jobhandler")
public class XxlJobConfig {
    private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);

    @Value("${xxl.job.admin.addresses}")
    private String adminAddresses;

    @Value("${xxl.job.executor.appname}")
    private String appName;

    @Value("${xxl.job.executor.ip}")
    private String ip;

    @Value("${xxl.job.executor.port}")
    private int port;

    @Value("${xxl.job.accessToken}")
    private String accessToken;

    @Value("${xxl.job.executor.logpath}")
    private String logPath;

    @Value("${xxl.job.executor.logretentiondays}")
    private int logRetentionDays;


    @Bean(initMethod = "start", destroyMethod = "destroy")
    public XxlJobExecutor xxlJobExecutor() {
        logger.info(">>>>>>>>>>> xxl-job config init.");
        XxlJobExecutor xxlJobExecutor = new XxlJobExecutor();
        xxlJobExecutor.setAdminAddresses(adminAddresses);
        xxlJobExecutor.setAppName(appName);
        xxlJobExecutor.setIp(ip);
        xxlJobExecutor.setPort(port);
        xxlJobExecutor.setAccessToken(accessToken);
        xxlJobExecutor.setLogPath(logPath);
        xxlJobExecutor.setLogRetentionDays(logRetentionDays);

        return xxlJobExecutor;
    }

}

每个配置的含义如下：

/**
	 ### 调度中心部署根地址 [选填]：如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调"；为空则关闭自动注册；
	 xxl.job.admin.addresses=http://localhost:8080/xxl-job-admin
	 ### 执行器通讯TOKEN [选填]：非空时启用；
	 xxl.job.accessToken=
	 ### 执行器AppName [选填]：执行器心跳注册分组依据；为空则关闭自动注册
	 xxl.job.executor.appname=xxl-job-executor-sample
	 ### 执行器注册 [选填]：优先使用该配置作为注册地址，为空时使用内嵌服务 ”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=/data/applogs/xxl-job/jobhandler
	 ### 执行器日志文件保存天数 [选填] ： 过期日志自动清理, 限制值大于等于3时生效; 否则, 如-1, 关闭自动清理功能；
	 xxl.job.executor.logretentiondays=30
	 * @return
	 */
  • 实现IJobHandler接口，实现execute方法，业务实现就在这里实现。
package com.xxl.job.executor.service.jobhandler;

import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.IJobHandler;
import com.xxl.job.core.handler.annotation.JobHandler;
import com.xxl.job.core.log.XxlJobLogger;
import org.springframework.stereotype.Component;

import java.util.concurrent.TimeUnit;


/**
 * 任务Handler示例（Bean模式）
 *
 * 开发步骤：
 * 1、继承"IJobHandler"：“com.xxl.job.core.handler.IJobHandler”；
 * 2、注册到Spring容器：添加“@Component”注解，被Spring容器扫描为Bean实例；
 * 3、注册到执行器工厂：添加“@JobHandler(value="自定义jobhandler名称")”注解，注解value值对应的是调度中心新建任务的JobHandler属性的值。
 * 4、执行日志：需要通过 "XxlJobLogger.log" 打印执行日志；
 *
 * @author xuxueli 2015-12-19 19:43:36
 */
@JobHandler(value="demoJobHandler")
@Component
public class DemoJobHandler extends IJobHandler {

	@Override
	public ReturnT<String> execute(String param) throws Exception {
		XxlJobLogger.log("XXL-JOB, Hello World.");

		for (int i = 0; i < 5; i++) {
			XxlJobLogger.log("beat at:" + i);
			TimeUnit.SECONDS.sleep(2);
		}
		return SUCCESS;
	}

}
  • 启动SpringBoot项目，配置

在这里插入图片描述

日志执行：如下显示demoJobHandler已经注册成功，并且执行成功了两次

17:41:34.934 logback [Thread-7] INFO  c.x.j.c.t.ExecutorRegistryThread - >>>>>>>>>>> xxl-job registry success, registryParam:RegistryParam{registGroup='EXECUTOR', registryKey='xxl-job-ex
ecutor-sample', registryValue='10.14.161.30:9999'}, registryResult:ReturnT [code=200, msg=null, content=null]
17:42:04.952 logback [Thread-7] INFO  c.x.j.c.t.ExecutorRegistryThread - >>>>>>>>>>> xxl-job registry success, registryParam:RegistryParam{registGroup='EXECUTOR', registryKey='xxl-job-ex
ecutor-sample', registryValue='10.14.161.30:9999'}, registryResult:ReturnT [code=200, msg=null, content=null]

3. 结语

        综上所述，一共讨论了两种定时的实现方式，所有的操作都是基于SpringBoot框架实现的；每种方式都要自己的优势所在，可以根据自己业务的难易进行选择；以上的步骤亲测可以实现，欢迎留言讨论。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/404177.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

【C++学习】【STL】list容器

【C++学习】【STL】list容器

list 容器&#xff0c;又称双向链表容器&#xff0c;即该容器的底层是以双向链表的形式实现的。这意味着&#xff0c;list 容器中的元素可以分散存储在内存空间里&#xff0c;而不是必须存储在一整块连续的内存空间中。可以看到&#xff0c;list 容器中各个元素的前后顺序是靠指…
阅读更多...
【NodeJs】使用ffmpeg将视频webm转换为mp4

【NodeJs】使用ffmpeg将视频webm转换为mp4

使用Chrome浏览器录制视频文件是webm格式&#xff0c;但是很多媒体播放器是不支持的&#xff0c;不利于分享&#xff0c;需要转换为mp4格式才行&#xff0c;接下来给大家讲 ffmpeg ffmpeg是什么呢&#xff0c; 一个免费开源的视频转换工具&#xff0c;一款音视频编解码工具&…
阅读更多...
日志与可视化方案：从ELK到EFK，再到ClickHouse

日志与可视化方案：从ELK到EFK，再到ClickHouse

EFK方案 从ELK谈起 ELK是三个开源软件的缩写&#xff0c;分别表示&#xff1a;Elasticsearch&#xff0c;Logstash&#xff0c;Kibana。新增了一个FlieBeat&#xff0c;它是一个轻量级的日志收集处理工具&#xff0c;FlieBeat占用资源少&#xff0c;适用于在各个服务器上搜集…
阅读更多...
JS语法（扫盲）

JS语法（扫盲）

文章目录一、初识JavaScript二、第一个JS程序JS代码的引入JS程序的输出三、语法变量使用动态类型内置类型运算符强类型语言&弱类型语言条件语句循环语句数组创建数组获取数组元素新增数组元素删除数组元素函数语法格式形参实参个数的问题匿名函数&函数表达式作用域作用…
阅读更多...
PHP 的运行方式有哪些？

PHP 的运行方式有哪些？

PHP本质上的运行方式可以分为两种&#xff1a; 基于命令行的基于PHP-FPM的 但实际上&#xff0c;PHP能做的事很多&#xff0c;很多场景下&#xff0c;不同的运行方式能让开发更方便&#xff0c;减轻各种工作。 测试开发 PHP内置了一个HTTP 的server。这意味着&#xff0c;很…
阅读更多...
stm32外设-GPIO

stm32外设-GPIO

0. 写在最前 本栏目笔记都是基于stm32F10x 1. GPIO基本介绍 GPIO—general purpose intput output 是通用输入输出端口的简称&#xff0c;简单来说就是软件可控制的引脚&#xff0c; STM32芯片的GPIO引脚与外部设备连接起来&#xff0c;从而实现与外部通讯、控制以及数据采集的…
阅读更多...
java Date 和 Calendar类 万字详解（通俗易懂）

java Date 和 Calendar类 万字详解（通俗易懂）

Date类介绍及使用关于SimpleDateFormat类Calendar类介绍及使用LocalDateTime类介绍及使用关于DateTimeFormatter类一、前言本节内容是我们《API-常用类》专题的第五小节了。本节内容主要讲Date 类 和 Calendar 类&#xff0c;内容包括但不限于Date类简介&#xff0c;Date类使用…
阅读更多...
【微信小程序】-- 自定义组件 - 数据监听器 （三十四）

【微信小程序】-- 自定义组件 - 数据监听器 （三十四）

&#x1f48c; 所属专栏&#xff1a;【微信小程序开发教程】 &#x1f600; 作  者&#xff1a;我是夜阑的狗&#x1f436; &#x1f680; 个人简介&#xff1a;一个正在努力学技术的CV工程师&#xff0c;专注基础和实战分享 &#xff0c;欢迎咨询&#xff01; &…
阅读更多...
传奇开服流程—传奇单机架设教程

传奇开服流程—传奇单机架设教程

现在传奇私服还是那么的火爆&#xff0c;上次有报道发布站一年盈利几个亿&#xff0c;还是有很大的机会&#xff0c;很多玩家因为GM开服关服给折腾&#xff0c;刚充的钱服务器就关了&#xff0c;很是恼火&#xff0c;于是都想自己整个服开开&#xff0c;但又不知道从何下手&…
阅读更多...
三菱FX5U之数据处理类指令的使用

三菱FX5U之数据处理类指令的使用

本课程使用三菱PLC works3编程软件进行教学&#xff0c;并使用works3的仿真功能进行PLC仿真&#xff0c;学习的时候不需要有实物PLC。 补充说明&#xff1a;三菱 FX 5U系列PLC使用的是GX works3编程软件&#xff0c;FX 3U、Q系列PLC使用的是GX works3编程软件。 第一章 八个案…
阅读更多...
YUV实践记录

YUV实践记录

文章目录YUV基础介绍&#xff1a;不同采样YUV格式的区别为什么要使用YUV格式呢&#xff1f;YUV的存储方式Android中的YUV_420_888附录&#xff1a;YUV基础介绍&#xff1a; YUV在做手机图像或者视频处理的时候会经常用到的一个格式&#xff0c;用此文来记录YUV相关介绍&#xf…
阅读更多...
hibernate学习（五）

hibernate学习（五）

hibernate学习&#xff08;五&#xff09; hibernate的一对多关联映射&#xff1a; 一、数据库表与表之间关系 一对多建表原则&#xff1a; 多对多的建表原则&#xff1a; 一对一建表原则&#xff1a; &#xff08;1&#xff09;唯一外键对应&#xff1a; &#xff08;…
阅读更多...
时间复杂度和空间复杂度的计算

时间复杂度和空间复杂度的计算

目录 算法的复杂度 时间复杂的的概念 时间复杂度计算方法 大O的渐进表示法 空间复杂的概念 空间复杂的的计算方法 时间和空间复杂度的应用 消失的数字 轮转数组 算法的复杂度 算法在编写成可执行程序后&#xff0c;运行时需要耗费时间资源和空间&#xff08;内存&…
阅读更多...
modbus转profinet网关连接5台台达ME300变频器案例

modbus转profinet网关连接5台台达ME300变频器案例

通过兴达易控Modbus转Profinet&#xff08;XD-MDPN100&#xff09;网关改善网络场景&#xff0c;变频器有掉线或数据丢失报警&#xff0c;影响系统的正常运行&#xff0c;将5台 ME300变频器modbus转Profinet到1200PLC&#xff0c;通过网关还可以实现Profinet转modbus RTU协议转…
阅读更多...
LabVIEW中以编程方式获取VI克隆名称

LabVIEW中以编程方式获取VI克隆名称

LabVIEW中以编程方式获取VI克隆名称演示如何以编程方式获取VI的名称或克隆名称。如果VI作为顶级VI运行&#xff0c;则将显示VI的名称。如果VI在主VI中用作子VI&#xff0c;它将返回克隆的名称。在项目开发过程中&#xff0c;有时需要获取VI的名称。在此示例中&#xff0c;实现了…
阅读更多...
【数论】试除法判断质数，分解质因数，筛质数

【数论】试除法判断质数，分解质因数，筛质数

Halo&#xff0c;这里是Ppeua。平时主要更新C语言&#xff0c;C&#xff0c;数据结构算法......感兴趣就关注我吧&#xff01;你定不会失望。 &#x1f308;个人主页&#xff1a;主页链接 &#x1f308;算法专栏&#xff1a;专栏链接 现已更新完KMP算法、排序模板&#xff0c;之…
阅读更多...
代码管理--svnadmin工具介绍

代码管理--svnadmin工具介绍

1、简介 SVNAdmin2 是一款通过图形界面管理服务端SVN的web程序。正常情况下配置SVN仓库的人员权限需要登录到服务器手动修改 authz 和 passwd 两个文件&#xff0c;当仓库结构和人员权限上了规模后&#xff0c;手动管理就变的非常容易出错&#xff0c;本系统能够识别人员和权限…
阅读更多...
【AWS入门】IAM基本应用-2023/3/4

【AWS入门】IAM基本应用-2023/3/4

目录IAM概述根用户和IAM用户参考IAM概述 IAM(Identity Access Management&#xff09;是身份和访问管理服务&#xff0c;要访问AWS服务和资源&#xff0c;就要使用IAM进行身份验证和授权。当我们通过控制台&#xff0c;CLI&#xff0c;或API访问AWS服务时&#xff0c;都需要通…
阅读更多...
p5.js map映射

p5.js map映射

theme: smartblue 本文正在参加「金石计划」 本文简介 带尬猴&#xff0c;我嗨德育处主任 p5.js 为开发者提供了很多有用的方法&#xff0c;这些方法实现起来可能不难&#xff0c;但却非常实用&#xff0c;能大大减少我们的开发时间。 本文将通过举例说明的方式来讲解 映射 map…
阅读更多...
《计算机网络》期末复习笔记

《计算机网络》期末复习笔记

文章目录一、一些英文名词的标签&#xff08;方便记忆&#xff09;二、OSI七层协议三、综合题3.0 知识点储备3.1 在Internet 网中&#xff0c;某计算机的IP 地址是11001010.01100000.00101100.01011000 &#xff0c;请回答下列问题3.2 假定发送方要发送的数据为10000101。采用C…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023