Springboot中使用RabbitMQ

╰半夏微凉° 2024-03-22 18:17 37阅读 0赞

## 1、比较常见的MQ实现： ##

*  ActiveMQ
 *  RabbitMQ
 *  RocketMQ
 *  Kafka  
    几种常见MQ的对比：

<table> 
 <thead> 
  <tr> 
   <th>项目</th> 
   <th>RabbitMQ</th> 
   <th>ActiveMQ</th> 
   <th>RocketMQ</th> 
   <th>Kafka</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>公司/社区</td> 
   <td>Rabbit</td> 
   <td>Apache</td> 
   <td>阿里</td> 
   <td>Apache</td> 
  </tr> 
  <tr> 
   <td>开发语言</td> 
   <td>Erlang</td> 
   <td>Java</td> 
   <td>Java</td> 
   <td>Scala&amp;Java</td> 
  </tr> 
  <tr> 
   <td>协议支持</td> 
   <td>AMQP，XMPP，SMTP，STOMP</td> 
   <td>OpenWire,STOMP，REST,XMPP,AMQP</td> 
   <td>自定义协议</td> 
   <td>自定义协议</td> 
  </tr> 
  <tr> 
   <td>可用性</td> 
   <td>高</td> 
   <td>一般</td> 
   <td>高</td> 
   <td>高</td> 
  </tr> 
  <tr> 
   <td>单机吞吐量</td> 
   <td>一般</td> 
   <td>差</td> 
   <td>高</td> 
   <td>非常高</td> 
  </tr> 
  <tr> 
   <td>消息延迟</td> 
   <td>微秒级</td> 
   <td>毫秒级</td> 
   <td>毫秒级</td> 
   <td>毫秒以内</td> 
  </tr> 
  <tr> 
   <td>消息可靠性</td> 
   <td>高</td> 
   <td>一般</td> 
   <td>高</td> 
   <td>一般</td> 
  </tr> 
 </tbody> 
</table>

追求可用性：Kafka、 RocketMQ 、RabbitMQ

追求可靠性：RabbitMQ、RocketMQ

追求吞吐能力：RocketMQ、Kafka

追求消息低延迟：RabbitMQ、Kafka

## 2、RabbitMQ 下载、安装 ##

[RabbitMQ 下载、安装][RabbitMQ]

## 3、RabbitMq在springboot中使用 ##

在pom中加入依赖

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-amqp</artifactId>
            </dependency>

在application.yml配置mq的参数

spring:
      rabbitmq:
        #设置RabbitMQ的IP地址
        host: 192.168.1.186
        #设置rabbitmq服务器用户名
        username: root
        #设置rabbitmq服务器密码
        password: root
        #设置rabbitmq服务器连接端口
        port: 5672

生产者

@RequiredArgsConstructor
    @RestController
    @RequestMapping("publisher")
    public class PublisherController {
        
        private final RabbitTemplate rabbitTemplate;
        @GetMapping()
        public String sendMess(String queueName ,String  message ){
        
            rabbitTemplate.convertAndSend(queueName,message);
            return "发送成功";
        }
    }

消费者

@Component
    public class ConsuerListener {
        
    	//指定对列名称
        @RabbitListener(queues = "simple.queue")
        public void listener(String mess){
        
            System.out.println("接收到了来自消费者的消息："+mess);
        }
    }

注：指定的对列需要在RabbitMQ管理后台添加  
![在这里插入图片描述][85dd368ee58247fa862c019a99fdf1d0.png]  
使用postman往接口发送一条请求，携带对列名称以及mess

![在这里插入图片描述][e595b63f2ef54aa6bd18f378f7e5edae.png]

![在这里插入图片描述][f766be745fe3483fbc5dfff1cdcd2adc.png]  
到此，springboot使用RabbitMQ成功

[RabbitMQ]: https://blog.csdn.net/qq_33753147/article/details/127140680
[85dd368ee58247fa862c019a99fdf1d0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/6f806a9b9f1f4d3981ebe40dfd812100.png
[e595b63f2ef54aa6bd18f378f7e5edae.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/bc8f89c3e23045e690729595ac241418.png
[f766be745fe3483fbc5dfff1cdcd2adc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/1930ac0c9a844a919f0b3c053e0550e7.png