ToB企服应用市场:ToB评测及商务社交产业平台

标题: 若依-单呆板多服务器定时使命重复实行问题解决-分布式锁 [打印本页]
作者: 乌市泽哥    时间: 2024-9-18 16:10
标题: 若依-单呆板多服务器定时使命重复实行问题解决-分布式锁
1.定位定时使命所走方法


   任意找一个定时使命的方法类,打断点检察实行过程
  


   点击立刻实行,实行该方法
  


   点击步过,寻找符合的代码位置增长分布式锁
  

   最终看到方法在此处进行返回,我们可以再此处进行加锁操作
  

2.添加分布式锁


   在ruoyi-common pom引入redisson依赖
  1. <!--Redisson redis若依已经引入-->
  2. <dependency>
  3.     <groupId>org.redisson</groupId>
  4.     <artifactId>redisson</artifactId>
  5.     <version>3.17.4</version>
  6. </dependency>
复制代码
  添加配置类
  1. package com.ruoyi.common.core.redis;
  3. import org.redisson.Redisson;
  4. import org.redisson.api.RedissonClient;
  5. import org.redisson.config.Config;
  6. import org.springframework.beans.factory.annotation.Value;
  7. import org.springframework.context.annotation.Bean;
  8. import org.springframework.context.annotation.Configuration;
  10. /**
  11. * @Author Cxt
  12. * @Description redisson配置
  13. * @Date 2023/6/29 15:47
  14. * @Version 1.0
  15. */
  16. @Configuration
  17. public class RedissonConfig {
  18.     @Value("${spring.redis.host}")
  19.     private String host;
  21.     @Value("${spring.redis.port}")
  22.     private String port;
  24.     @Value("${spring.redis.password}")
  25.     private String password;
  27.     @Bean
  28.     public RedissonClient redissonClient() {
  29.         Config config = new Config();
  30.         // 配置Redisson连接信息
  31.         config.useSingleServer().setAddress("redis://" + host + ":" + port).setPassword(null);
  32.         return Redisson.create(config);
  33.     }
  34. }
复制代码


   如果开启了ScheduleConfig类 注入方式请改为如下图所示注入
  


在处理好sysJob对象后 根据使命名称来创建锁对象
  1. @Override
  2. public void execute(JobExecutionContext context) throws JobExecutionException
  3. {
  4.     SysJob sysJob = new SysJob();
  5.     BeanUtils.copyBeanProp(sysJob, context.getMergedJobDataMap().get(ScheduleConstants.TASK_PROPERTIES));
  6.     try
  7.     {
  8.         before(context, sysJob);
  9.         if (sysJob != null)
  10.         {
  11.             //创建锁对象
  12.             RLock lock = redissonClient.getLock(ScheduleConstants.TASK_PROPERTIES);
  13.             //尝试获取锁
  14.             boolean isLock = lock.tryLock();
  15.             if (!isLock){
  16.                 throw new ServiceException("该任务正在执行中!");
  17.             }
  18.             try{
  19.                 //真正执行的方法
  20.                 doExecute(context, sysJob);
  21.             }finally {
  22.                 //释放锁
  23.                 lock.unlock();
  24.             }
  25.         }
  26.         after(context, sysJob, null);
  27.     }
  28.     catch (Exception e)
  29.     {
  30.         log.error("任务执行异常  - ：", e);
  31.         after(context, sysJob, e);
  32.     }
  33. }
复制代码
3.测试

同一时间如果拿不到锁将会直接失败,成功达到效果

特别注意

   在拿到锁之后,由于走的是本地缓存,为了克制重复实行,请将使命策略改为放弃实行
   

官方方法

   取消注释类ScheduleConfig即可(注意检察相关表是否存在)
  


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4