SpringBoot系列二十八：整合RabbitMQ

绝地灬酷狼 2022-01-14 06:45 337阅读 0赞

1、引入依赖

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

2、application.properties配置

#RabbitMQ配置
    spring.rabbitmq.host=192.168.106.130
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest

3、自动配置

/***
     * 自动配置
     *  1、RabbitAutoConfiguration
     *  2、自动配置了连接工厂ConnectionFactory
     *  3、RabbitProperties封装了RabbitMQ的配置
     *  4、RabbitTemplate：给RabbitMQ发送和接受消息
     *  5、AmqpAdmin：RabbitMQ系统管理功能组件
     *     AmqpAdmin：创建和删除Queue，Exchange，Binding
     *  6、@EnableRabbit + @RabbitListener监听消息队列的内容
     **/
    @EnableRabbit //开启基于注解的RabbitMQ模式
    @SpringBootApplication
    public class Springboot02AmqpApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(Springboot02AmqpApplication.class, args);
        }
    
    }

4、实体类 Book

public class Book {
    
        private String bookName;
        private String author;
    
        public Book() {
        }
    
        public Book(String bookName,String author) {
            this.bookName = bookName;
            this.author = author;
        }
    
    
        public String getBookName() {
            return bookName;
        }
    
        public void setBookName(String bookName) {
            this.bookName = bookName;
        }
    
        public String getAuthor() {
            return author;
        }
    
        public void setAuthor(String author) {
            this.author = author;
        }
    
        @Override
        public String toString() {
            return "Book{" +
                    "bookName='" + bookName + '\'' +
                    ", author='" + author + '\'' +
                    '}';
        }
    }

5、接收消息

import com.atguigu.amqp.bean.Book;
    import org.springframework.amqp.core.Message;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Service;
    
    @Service
    public class BookService {
    
        @RabbitListener(queues = "atguigu.news")
        public void receive(Book book){
            System.out.println("收到消息："+book);
        }
    
        @RabbitListener(queues = "atguigu")
        public void receive02(Message message){
            System.out.println(message.getBody());
            System.out.println(message.getMessageProperties());
        }
    }

6、自定义MessageConverter

@Configuration
    public class MyAMQPConfig {
    
        @Bean
        public MessageConverter messageConverter(){
            return new Jackson2JsonMessageConverter();
        }
    }

7、使用RabbitTemplate

@RunWith(SpringRunner.class)
    @SpringBootTest
    public class Springboot02AmqpApplicationTests {
    
        @Autowired
        RabbitTemplate rabbitTemplate;
        @Autowired
        AmqpAdmin amqpAdmin;
    
        @Test
        public void createExchange(){
           /* amqpAdmin.declareExchange(new DirectExchange("amqpadmin.exchange"));
            System.out.println("创建完成");*/
    
            //amqpAdmin.declareQueue(new Queue("amqpadmin.queue",true));
    
            //创建绑定规则
            amqpAdmin.declareBinding(new Binding("amqpadmin.queue", Binding.DestinationType.QUEUE,"amqpadmin.exchange","amqp.haha",null));
    
        }
    
        /***
         * 1、单播(点对点)
         **/
        @Test
        public void contextLoads() {
            //message需要自己构造一个；定义消息体内容和消息头
            //rabbitTemplate.send(exchange,routeKey,message);
    
            //object默认当成消息体，只需要传入要发送的对象，自动序列化发送给rabbitmq；
            //rabbitTemplate.convertAndSend(exchange,routeKey,object);
    
            Map<String,Object> map = new HashMap<>();
            map.put("msg","这是第一个消息");
            map.put("data", Arrays.asList("helloword",123,true));
            //对象被默认序列化以后发送出去
            rabbitTemplate.convertAndSend("exchange.direct","atguigu.news",new Book("西游记","吴承恩"));
        }
    
        @Test
        public void receive(){
            Object o = rabbitTemplate.receiveAndConvert("atguigu.news");
            System.out.println(o.getClass());
            System.out.println(o);
        }
    
        /***
         * 广播
         **/
        @Test
        public void sendMsg(){
            rabbitTemplate.convertAndSend("exchange.fanout","",new Book("三国演义","罗贯中"));
        }
    
    }