SpringCloud项目搭建(六) —elastic-job的使用，以及consul的配置使用（衔接上篇）

所需材料

compile "com.dangdang:elastic-job-lite-core:2.1.5"
compile "com.dangdang:elastic-job-lite-spring:2.1.5"
compile 'org.springframework.cloud:spring-cloud-starter-consul-discovery
compile 'org.springframework.cloud:spring-cloud-starter-consul-config:2.1.1.RELEASE'
compile 'org.springframework.cloud:spring-cloud-starter-consul-discovery:2.1.1.RELEASE'

启用sirius-quartz项目，总体结构如下

配置文件信息

application.yml:

server:port: 8011
spring:profiles:active: devapplication:name: quartz-serversecurity:user:name: adminpassword: 12345datasource:driver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql://10.0.21.66:3306/sirius?useUnicode=true&characterEncoding=UTF-8username: 9now_devpassword: 9now.321mail:host: ${mail.config.host}port: ${mail.config.port}username: ${mail.config.username}password: ${mail.config.password}properties:mail.smtp.auth: truemybatis:type-aliases-package:com.cloud.sirius.demo.service.entitymapper-locations:classpath:mybatis/*.xmlmapper:mappers:tk.mybatis.mapper.common.MappernotEmpty:true

bootstrap.yml:

spring:cloud:consul:discovery:hostname: localhostport: 8500tags: version=1.0,author=hmdbbinstance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}enabled: trueservice-name: ${spring.application.name}config:# 快速失败fail-fast: true#启用enabled: true#consul上面文件的格式  YAML FILES PROPERTIES KEY-VALUEformat: YAML# 基本文件夹prefix: config# 所有应用程序默认文件夹名defaultContext: application#设置分隔符的值，用于使用配置文件在属性源中分隔配置文件名称profileSeparator: ','data-key: datawatch:#调用的频率 1000 毫秒delay: 1000
logging:config:classpath:logback-test.xml

logback-test.xml

<configuration><!-- %m输出的信息,%p日志级别,%t线程名,%d日期,%c类的全名,%i索引【从数字0开始递增】,,, --><!-- appender是configuration的子节点，是负责写日志的组件。 --><!-- ConsoleAppender：把日志输出到控制台 --><appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"><encoder><pattern>%d %p [%t] (%c:%line\): %m%n</pattern><!-- 控制台也要使用UTF-8，不要使用GBK，否则会中文乱码 --><charset>UTF-8</charset></encoder></appender><!-- RollingFileAppender：滚动记录文件，先将日志记录到指定文件，当符合某个条件时，将日志记录到其他文件 --><!-- 以下的大概意思是：1.先按日期存日志，日期变了，将前一天的日志文件名重命名为XXX%日期%索引，新的日志仍然是sys.log --><!--             2.如果日期没有发生变化，但是当前日志的文件大小超过1KB时，对当前日志进行分割 重命名--><appender name="SERVICE_LOG_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"><File>log/sys.log</File><!-- rollingPolicy:当发生滚动时，决定 RollingFileAppender 的行为，涉及文件移动和重命名。 --><!-- TimeBasedRollingPolicy： 最常用的滚动策略，它根据时间来制定滚动策略，既负责滚动也负责出发滚动 --><rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"><!-- 活动文件的名字会根据fileNamePattern的值，每隔一段时间改变一次 --><!-- 文件名：log/sys.2017-12-05.0.log --><fileNamePattern>log/sys.%d.%i.log</fileNamePattern><!-- 每产生一个日志文件，该日志文件的保存期限为30天 --><maxHistory>30</maxHistory><timeBasedFileNamingAndTriggeringPolicy  class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"><!-- maxFileSize:这是活动文件的大小，默认值是10MB,本篇设置为1KB，只是为了演示 --><maxFileSize>100MB</maxFileSize></timeBasedFileNamingAndTriggeringPolicy></rollingPolicy><encoder><!-- pattern节点，用来设置日志的输入格式 --><pattern>%d %p [%t] (%c:%line\): %m%n</pattern><!-- 记录日志的编码 --><charset>UTF-8</charset> <!-- 此处设置字符集 --></encoder></appender><!-- 控制台输出日志级别 --><root level="info"><appender-ref ref="STDOUT" /><appender-ref ref="SERVICE_LOG_FILE" /></root><!-- 指定项目中某个包，当有日志操作行为时的日志记录级别 --><!-- com.cloud.sirius为根包，也就是只要是发生在这个根包下面的所有日志操作行为的权限都是DEBUG --><!-- 级别依次为【从高到低】：FATAL > ERROR > WARN > INFO > DEBUG > TRACE  --><logger name="com.cloud.sirius" level="DEBUG" additivity="false"><appender-ref ref="STDOUT" /></logger>
</configuration>

自定义抽象类AbstractJob，实现SimpleJob，方便抽象出公共的工具类，以及方便后续aop的使用

package com.cloud.sirius.demo.quartz.job;import com.cloud.sirius.demo.utils.log.SiriusLogger;
import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.simple.SimpleJob;
import org.slf4j.Logger;
import org.springframework.web.context.support.SpringBeanAutowiringSupport;public abstract class AbstractJob implements SimpleJob {protected Logger logger = new SiriusLogger(this.getClass());//    protected void clear() {
//        DbContextHolder.clearDbType();
//        TraceUtil.INSTANCE.clear();
//    }/*** 执行定时任务*/public abstract void run(ShardingContext context);@Overridepublic void execute(ShardingContext context) {run(context);}protected void springBeanAutowiringSupport() {SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this);}
}

DemoJob

package com.cloud.sirius.demo.quartz.job;import com.dangdang.ddframe.job.api.ShardingContext;
import org.springframework.stereotype.Component;/*** @author xu.guanguo* @time 2019/6/28* @description*/
@Component("bieYangRemindJob")
public class BieYangRemindJob extends AbstractJob{@Overridepublic void run(ShardingContext shardingContext) {System.out.println(String.format("------Thread ID: %s, 任务总片数: %s, " +"当前分片项: %s.当前参数: %s,"+"当前任务名称: %s.当前任务参数: %s" ,Thread.currentThread().getId(),shardingContext.getShardingTotalCount(),shardingContext.getShardingItem(),shardingContext.getShardingParameter(),shardingContext.getJobName(),shardingContext.getJobParameter()));}
}

zk的配置

package com.cloud.sirius.demo.quartz.config;import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperConfiguration;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Data
@Configuration
public class ElasticJobConfig {@Value("${quartz.app.zkAddress}")private String zkNodes;@Value("${quartz.app.namespace}")private String namespace;@Beanpublic ZookeeperConfiguration zkConfig() {return new ZookeeperConfiguration(zkNodes, namespace);}@Bean(initMethod = "init")public ZookeeperRegistryCenter regCenter(ZookeeperConfiguration config) {return new ZookeeperRegistryCenter(config);}
}

job总管理类

package com.cloud.sirius.demo.quartz.config;import com.dangdang.ddframe.job.api.simple.SimpleJob;
import com.dangdang.ddframe.job.config.JobCoreConfiguration;
import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
import com.dangdang.ddframe.job.lite.api.JobScheduler;
import com.dangdang.ddframe.job.lite.config.LiteJobConfiguration;
import com.dangdang.ddframe.job.lite.spring.api.SpringJobScheduler;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** @author xu.guanguo* @time 2019/6/28* @description*/
@Configuration
public class SiriusJobs {@Autowiredprivate ZookeeperRegistryCenter regCenter;@Bean(initMethod = "init")public JobScheduler bieYangRemindJobScheduler(@Autowired @Qualifier("bieYangRemindJob") SimpleJob simpleJob,@Value("${quartz.app.billCronExpress}") final String cron,@Value("${quartz.app.shardingCount}") int shardingCount,@Value("${quartz.app.shardingItemParameters}") String shardingItemParameters) {return new SpringJobScheduler(simpleJob, regCenter, getLiteJobConfiguration(simpleJob.getClass(), cron, shardingCount, shardingItemParameters));}/*** @Description 任务配置类*/private LiteJobConfiguration getLiteJobConfiguration(final Class<? extends SimpleJob> jobClass, final String cron, final int shardingTotalCount, final String shardingItemParameters) {return LiteJobConfiguration.newBuilder(new SimpleJobConfiguration(JobCoreConfiguration.newBuilder(jobClass.getName(), cron, shardingTotalCount).shardingItemParameters(shardingItemParameters).build(), jobClass.getCanonicalName())).overwrite(true).build();}
}

项目的总初始化类BeanInjector

package com.cloud.sirius.demo.quartz.config;import com.cloud.sirius.demo.base.AbstractInjector;
import com.cloud.sirius.demo.utils.mail.MailConfig;
import com.cloud.sirius.demo.utils.mail.MailUtil;
import org.I0Itec.zkclient.ZkClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Bean;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.stereotype.Component;@Component
@RefreshScope
public class BeanInjector extends AbstractInjector {@Autowiredprivate JavaMailSender javaMailSender;@Autowiredprivate MailConfig mailConfig;@Autowiredprivate QuartzAppConfig appConfig;@Bean@RefreshScopepublic MailUtil mailUtil() {MailUtil mailUtil = new MailUtil(javaMailSender, mailConfig);return mailUtil;}private ZkClient zkClient = null;@Bean(name = "zkClient")public ZkClient zkClient() {if (zkClient != null) {return zkClient;}zkClient = new ZkClient(appConfig.getZkAddress());return zkClient;}}

启动跑一跑?

没啥问题收工✋

SpringCloud项目搭建(六) —elastic-job的使用，以及consul的配置使用（衔接上篇）相关推荐

SpringCloud项目搭建步骤
SpringCloud项目搭建步骤 springCloud五大核心组件五大核心组件如下: 服务发现--Netflix Eureka客户端负载均衡--Netflix Ribbon 断路器--Netf ...
IDEA项目搭建六——使用Eureka和Ribbon进行项目服务化
一.Eureka的作用这里先简单说明使用eureka进行业务层隔离,实现项目服务化也可以理解为微服务,我一直崇尚先实现代码再学习理论,先简单上手进行操作,eureka使用分为三块,1是服务注册中心, ...
SpringCloud 项目搭建
1. 技术选型 springcloud管理的微服务架构众多,为了不用在项目后期解决环境冲突问题,请严格按照官网给出的 boot 与cloud 对应关系进行选型. SpringCloud官网地址版本对 ...
手把手教你搭建SpringCloud项目（十六）集成Stream消息驱动
Spring Cloud全集文章目录: 零.什么是微服务?一看就会系列! 一.手把手教你搭建SpringCloud项目(一)图文详解,傻瓜式操作二.手把手教你搭建SpringCloud项目(二)生产 ...
手把手教你搭建SpringCloud项目（十）集成Hystrix之服务降级
Spring Cloud全集文章目录: 零.什么是微服务?一看就会系列! 一.手把手教你搭建SpringCloud项目(一)图文详解,傻瓜式操作二.手把手教你搭建SpringCloud项目(二)生产 ...
手把手教你搭建SpringCloud项目（九）集成OpenFeign服务接口调用
Spring Cloud全集文章目录: 零.什么是微服务?一看就会系列! 一.手把手教你搭建SpringCloud项目(一)图文详解,傻瓜式操作二.手把手教你搭建SpringCloud项目(二)生产 ...
后台管理系统项目搭建
项目搭建规范一. 代码规范 1.1. 集成editorconfig配置 EditorConfig 有助于为不同 IDE 编辑器上处理同一项目的多个开发人员维护一致的编码风格. # http://ed ...
Spring MVC + Mybatis项目搭建
1.参考<Java Spring MVC项目搭建(一)--Spring MVC框架集成>配置spring mvc需要的jar包及eclipse配置(主要是针对servlet-api.jar ...
《SpringCloud超级入门》Spring Boot项目搭建步骤（超详细）《六》
目录编写第一个 REST 接口读取配置文件 profiles 多环境配置热部署 actuator 监控自定义 actuator 端点统一异常处理异步执行随机端口编译打包在 Sprin ...

SpringCloud项目搭建(六) —elastic-job的使用，以及consul的配置使用（衔接上篇）

SpringCloud项目搭建(六) —elastic-job的使用，以及consul的配置使用（衔接上篇）相关推荐

最新文章

热门文章