SpringBoot应用操作Rabbitmq

记录RabbitMQ的简单应用

1、springboot项目中引入maven包，也是springboot官方的插件

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

2、配置application.yml文件或者是properties文件

spring:
  application:
    #指定应用的名字
    name: rabbit-add
  #配置rabbitmq
  rabbitmq:
  #链接主机
    host: 127.0.0.1
  #端口
    port: 5672
  #已经授权的用户账号密码
    username: user
    password: user
  #指定的虚拟主机，默认/,
    virtual-host: my_vhost

3、如果想要发送消息就需要创建队列，接下来配置队列信息，注意：Queue引入的是springframework中的对象。

package com.niu.cloud.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author niunafei
 * @function
 * @email niunafei0315@163.com
 * @date 2020/4/28  4:06 PM
 */
@Configuration
public class RabbitMqConfig {

    /**
     * 创建消息队列
     *
     * @return
     */
    @Bean
    public Queue queue() {
        //设置队列名称叫 test-queue-name
        return new Queue("test-queue-name");
    }
}

4、创建消息发送方对象，进行发送消息

 1 package com.niu.cloud.modules;
 2 
 3 import org.springframework.amqp.core.Message;
 4 import org.springframework.amqp.core.MessageProperties;
 5 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 6 import org.springframework.beans.factory.annotation.Autowired;
 7 import org.springframework.stereotype.Component;
 8 
 9 /**
10  * @author niunafei
11  * @function 消息生产类
12  * @email niunafei0315@163.com
13  * @date 2020/4/28  4:09 PM
14  */
15 @Component
16 public class Sender {
17 
18     /**
19      * spring整合的操作类
20      * Message 发送的消息对象
21      * void send(Message var1) throws AmqpException;
22      * <p>
23      * var1 路由键 Message 发送的消息对象
24      * void send(String var1, Message var2) throws AmqpException;
25      * <p>
26      * var1 指定交换器名称 var2 路由键 Message 发送的消息对象
27      * void send(String var1, String var2, Message var3) throws AmqpException;
28      * 
29      *
30      * void convertAndSend() 方法不需要指定MessageProperties属性即可发布
31      */
32     @Autowired
33     private RabbitTemplate rabbitTemplate;
34 
35 
36     public void send(String msg) {
37         Message message = new Message(msg.getBytes(), new MessageProperties());
38         rabbitTemplate.send("test-queue-name", message);
39     }
40 }

View Code

5、创建消息接受消费方，消费消息

 1 package com.niu.cloud.modules;
 2 
 3 import lombok.extern.slf4j.Slf4j;
 4 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 5 import org.springframework.stereotype.Component;
 6 
 7 /**
 8  * @author niunafei
 9  * @function 监听这
10  * @email niunafei0315@163.com
11  * @date 2020/4/28  4:15 PM
12  */
13 @Component
14 @Slf4j
15 public class Receiver {
16 
17 
18     /**
19      * 指定监听队列的名字
20      */
21     @RabbitListener(queues = "test-queue-name")
22     public void process(String msg) {
23         log.info("接受到消息：{}", msg);
24     }
25 }

View Code

6、进行简单测试即可。

注意：ack确认机制，容易产生数据丢失，和产生内存泄漏，消费者进行死循环，配置这两个属性进行确认。

1、autoDelete属性设置为false

@Queue(value = "${mq.config.queue.orderName}", autoDelete = "false"

2、消费者进行死循环问题

docker安装rabbitmq：rabbitMQ安装docker版 /权限管理命令

简单应用来这里吧： SpringBoot应用操作Rabbitmq

简单应用来这里吧： SpringBoot应用操作Rabbitmq（direct高级操作）

简单应用来这里吧：SpringBoot应用操作Rabbitmq（topic交换器高级操作）

简单应用来这里吧：SpringBoot应用操作Rabbitmq（fanout广播高级操作）