spring boot 使用redis消息队列发送短息_springboot redis批量发送短信池

介绍：该功能用在处理登录、注册、支付的时候发送短信或者邮件通知的时候，将信息先放进redis list ，然后再已先进先出的方式取出，处理数据。

流程图：

第一步：redis工具类

public class RedisTools {

    public static void lPush(StringRedisTemplate stringRedisTemplate,String key,String value){
        stringRedisTemplate.opsForList().leftPush(key,value);
    }

    public static String rpop(StringRedisTemplate stringRedisTemplate,String key){
        return stringRedisTemplate.opsForList().rightPop(key);
    }
}
1
2
3
4
5
6
7
8
9
10

第二步：模拟访问放入数据到redis

@RequestMapping("reg")
public void reg(){
   RedisTools.lPush(stringRedisTemplate,"reg", UUID.randomUUID().toString().replaceAll("-",""));
}
1
2
3
4

第三步：另一台服务器循环读取处理数据

//可以加上其他的中间键，不同的数据往不同的地方推送
while (true){
   List<String> list = new ArrayList<>();
   for (int i = 0; i < 100; i++) {
      String s = RedisTools.rpop(stringRedisTemplate,"reg");
      if(s==null){
         break;
      }
      list.add(s);
   }
   //发送短信
   //修改短信发送状态成功或失败
   System.out.println(list);
   System.out.println("一分钟读取一次:"+ LocalDateTime.now());
   Thread.sleep(60000);
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16