xxl-job分布式Job实践

川长思鸟来 2023-06-20 14:56 5阅读 0赞

### 1、pom.xml ###

<dependency>
                <groupId>com.xuxueli</groupId>
                <artifactId>xxl-job-core</artifactId>
                <version>2.0.2</version>
            </dependency>

### 2、application.yml ###

spring:
      profiles:
        active: local
      application:
        name: insure-service-provider
    xxl:
      job:
        admin:
          addresses: http://192.168.30.152:5566
        executor:
          log-path: ${sys:catalina.home}/logs/job/
          log-retention-days: 30

### 3、XxlJobSpringExecutor ###

import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.cloud.commons.util.InetUtils;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    /**
     * xxl-job config
     *
     */
    @Configuration
    public class XxlJobConfig {
        private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);
    
        @Value("${xxl.job.admin.addresses}")
        private String adminAddresses;
    
        @Value("${spring.application.name}")
        private String appName;
    
        @Value("${xxl.job.executor.log-path}")
        private String logPath;
    
        @Value("${xxl.job.executor.log-retention-days}")
        private int logRetentionDays;
    
    
        @Bean(initMethod = "start", destroyMethod = "destroy")
        public XxlJobSpringExecutor xxlJobExecutor(InetUtils inetUtils ) {
            logger.info(">>>>>>>>>>> xxl-job config init.");
            XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
            xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
            xxlJobSpringExecutor.setAppName(appName);
            String ip = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress();
            xxlJobSpringExecutor.setIp(ip);
            xxlJobSpringExecutor.setPort(-1);
            xxlJobSpringExecutor.setAccessToken(null);
            xxlJobSpringExecutor.setLogPath(logPath);
            xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
            return xxlJobSpringExecutor;
        }
    }

### 4、业务job ###

import com.myfutech.insure.service.api.enums.InsureMsgTemplateEnum;
    import com.myfutech.insure.service.api.enums.InsureRenewalStatusEnum;
    import com.myfutech.insure.service.provider.model.MsgTemplate;
    import com.myfutech.insure.service.provider.model.Order;
    import com.myfutech.insure.service.provider.service.MsgTemplateService;
    import com.myfutech.insure.service.provider.service.OrderService;
    import com.myfutech.insure.service.provider.third.VxPushMsgService;
    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.apache.commons.collections4.CollectionUtils;
    import org.apache.commons.lang.time.DateUtils;
    import org.apache.commons.lang3.time.DateFormatUtils;
    import org.springframework.stereotype.Component;
    
    import javax.annotation.Resource;
    import java.util.Date;
    import java.util.List;
    
    /**
     * 保单续保消息提醒JOB
     */
    @JobHandler(value = "renewalAdviceJob")
    @Component
    public class RenewalAdviceJob extends IJobHandler {
    
        @Resource
        private OrderService orderService;
    
        @Resource
        private MsgTemplateService msgTemplateService;
    
        @Resource
        private VxPushMsgService vxPushMsgService;
    
    
        @Override
        public ReturnT<String> execute(String s) {
            XxlJobLogger.log("保单续保消息提醒JOB开始...");
    
            MsgTemplate msgTemplate = msgTemplateService.findValidByCode(InsureMsgTemplateEnum.RENEWAL.getCode());
            if (null == msgTemplate) {
                XxlJobLogger.log("续保通知异常：未找到对应消息模板！！！");
                return ReturnT.FAIL;
            }
            String oneMonthBefore = DateFormatUtils.format(DateUtils.addMonths(new Date(), -1), "MM-dd");
            String oneWeekBefore = DateFormatUtils.format(DateUtils.addDays(new Date(), -7), "MM-dd");
            String threeDaysBefore = DateFormatUtils.format(DateUtils.addDays(new Date(), -3), "MM-dd");
    
            List<Order> list = orderService.findRenewal(InsureRenewalStatusEnum.NORMAL.getCode(), oneMonthBefore);
            sendMsg(list, msgTemplate);
    
            list = orderService.findRenewal(InsureRenewalStatusEnum.TO_BE_RENEWED.getCode(), oneWeekBefore);
            sendMsg(list, msgTemplate);
    
            list = orderService.findRenewal(InsureRenewalStatusEnum.TO_BE_RENEWED.getCode(), threeDaysBefore);
            sendMsg(list, msgTemplate);
    
            XxlJobLogger.log("保单续保消息提醒JOB结束...");
    
            return ReturnT.SUCCESS;
    
        }
    
        /***
         * 遍历并推送消息
         * @param list
         * @param msgTemplate
         */
        private void sendMsg(List<Order> list, MsgTemplate msgTemplate) {
            if (CollectionUtils.isEmpty(list)) {
                return;
            }
    
            for (Order order : list) {
                String msg = msgTemplate.getContent();
                msg = msg.replace("policyName", order.getPolicyName());
                msg = msg.replace("productName", order.getProductName());
                msg = msg.replace("insureNum", order.getInsureNum());
                vxPushMsgService.push(order.getOpenId(), msgTemplate.getTemplateId());
            }
    
        }
    }

5、新增执行器

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppYWhhbzExODY_size_16_color_FFFFFF_t_70][]

6、新建任务

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppYWhhbzExODY_size_16_color_FFFFFF_t_70 1][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppYWhhbzExODY_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191210173618665.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppYWhhbzExODY=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppYWhhbzExODY_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191210173724984.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ppYWhhbzExODY=,size_16,color_FFFFFF,t_70