Redis与RabbitMQ共同使用多线程（多消耗者）处理处罚消息

弁言

并发引起的服务器瓦解黑白经常见的征象，为相识决这一标题，现在盛行使用缓存数据库与消息队列搭配使用。在近来的项目中也是使用到这一本事，本篇文章通过一个案例为各人展示该套方案怎样使用。
案例形貌与流程

本案例是一个经典的并发下单的案例。在Redis中存在一条key为Apple，Value为10000的数据，为防止超卖标题的发生使用Redisson分布式锁克制超卖（在Redis办理超卖Demo这篇文章中已经讲过），在一个线程拿到锁而且符合下单条件则直接返回下单乐成同时发送消息，使用AMQP监听队列消息，通过线程池创建多个线程作为消耗者举行底层DB的更新。
   

  情况预备

创建模块名为Redis

   

  yml设置文件的编写

1. server:
2.   port: 9000
3. spring:
4.   application:
5.     name: redis
6.   datasource:
7.     driver-class-name: com.mysql.jdbc.Driver
8.     url: jdbc:mysql://localhost:3306/user?useSSL=false
9.     username: root
10.     password: 123456
12.   redis:
13.     host: 192.168.136.130
14.     port: 6379
15.     password: 123456
16.     lettuce:
17.       pool:
18.         max-active: 10
19.         max-idle: 10
20.         min-idle: 1
21.         time-between-eviction-runs: 10s
23.   rabbitmq:
24.     host: 192.168.136.130  #MQ地址
25.     port: 5672        #端口
26.     virtual-host: /   #虚拟主机
27.     username: demo   #用户密码
28.     password: 123321
29.     connection-timeout: 1s
30.     template:
31.       retry:  #重试机制
32.         enabled: true
33.         initial-interval: 1000ms
34.         multiplier: 1
35.         max-attempts: 3
36.     publisher-confirm-type: correlated
37.     publisher-returns: true

复制代码

Controller Test类的编写

  设置路径为  /testAddsetxAddFinally

2. @RestController
3. @RequestMapping("/")
4. public class Test {
5.     @Autowired
6.     private RedisTemplate redisTemplate;
7.     @Autowired
8.     private RabbitTemplate rabbitTemplate;
11.     /*使用setnx锁，同时给锁释放过期时间，自动释放锁
12.     * */
14.     @RequestMapping("testAddsetxAddFinally")
15.     String cherkAndReduceStockAddSetnxAddFinally()
16.     {
18.         Boolean lock = redisTemplate.opsForValue().setIfAbsent("lock-stock", "0000",2, TimeUnit.SECONDS);
19.         //获取锁失败，停止50ms，递归调用
20.         if (!lock){
21.             try {
22.                 Thread.sleep(3000);
23.                 this.cherkAndReduceStockAdd

复制代码