RabbitMQ 实战(二)Spring Boot 整合 RabbitMQ

扫码关注公众号:Java 技术驿站

发送:vip
将链接复制到本浏览器,永久解锁本站全部文章

【公众号:Java 技术驿站】 【加作者微信交流技术,拉技术群】

这篇文章主要讲基本的整合。先把代码跑起来,再说什么高级特性。

RabbitMQ 中的一些术语

如果你打开 RabbitMQ web 控制台,你会发现其中有一个 Exhanges 不好理解。下面简单说明一下。

20191102100525\_1.png

交换器(Exchange)

交换器就像路由器,我们先是把消息发到交换器,然后交换器再根据路由键(routingKey)把消息投递到对应的队列。(明白这个概念很重要,后面的代码里面充分体现了这一点)

队列(Queue)

队列很好理解,就不用解释了。

绑定(Binding)

交换器怎么知道把这条消息投递到哪个队列呢?这就需要用到绑定了。大概就是:使用某个路由键(routingKey)把某个队列(Queue)绑定到某个交换器(Exchange),这样交换器就知道根据路由键把这条消息投递到哪个队列了。(后面的代码里面充分体现了这一点)

加入 RabbitMQ maven 依赖

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

再加入另外一个依赖(这个依赖可省略,主要是用来简化代码)

    <dependency>
        <groupId>cn.hutool</groupId>
        <artifactId>hutool-all</artifactId>
        <version>4.0.2</version>
    </dependency>

RabbitMQConfig.java 配置

    @Configuration
    public class RabbitMQConfig {

        public final static String QUEUE_NAME = "spring-boot-queue";
        public final static String EXCHANGE_NAME = "spring-boot-exchange";
        public final static String ROUTING_KEY = "spring-boot-key";

        // 创建队列
        @Bean
        public Queue queue() {
            return new Queue(QUEUE_NAME);
        }

        // 创建一个 topic 类型的交换器
        @Bean
        public TopicExchange exchange() {
            return new TopicExchange(EXCHANGE_NAME);
        }

        // 使用路由键(routingKey)把队列(Queue)绑定到交换器(Exchange)
        @Bean
        public Binding binding(Queue queue, TopicExchange exchange) {
            return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);
        }

        @Bean
        public ConnectionFactory connectionFactory() {
            CachingConnectionFactory connectionFactory = new CachingConnectionFactory("127.0.0.1", 5672);
            connectionFactory.setUsername("guest");
            connectionFactory.setPassword("guest");
            return connectionFactory;
        }

        @Bean
        public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
            return new RabbitTemplate(connectionFactory);
        }

    }

生产者

直接调用 rabbitTemplate 的 convertAndSend 方法就可以了。从下面的代码里也可以看出,我们不是把消息直接发送到队列里面的,而是先发送到了交换器,交换器再根据路由键把我们的消息投递到对应的队列。

    @RestController
    public class ProducerController {

        @Autowired
        private RabbitTemplate rabbitTemplate;

        @GetMapping("/sendMessage")
        public Object sendMessage() {
            new Thread(() -> {
                for (int i = 0; i < 100; i++) {
                    String value = new DateTime().toString("yyyy-MM-dd HH:mm:ss");
                    Console.log("send message {}", value);
                    rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME, RabbitMQConfig.ROUTING_KEY, value);
                }
            }).start();
            return "ok";
        }

    }

消费者

消费者也很简单,只需要对应的方法上加入 @RabbitListener 注解,指定需要监听的队列名称即可。

    @Component
    public class Consumer {

        @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME)
        public void consumeMessage(String message) {
            Console.log("consume message {}", message);
        }
    }

运行项目

运行项目,然后打开浏览器,输入 http://localhost:9999/sendMessage。在控制台就可以看到生产者在不停的的发送消息,消费者不断的在消费消息。

20191102100525\_2.png

打开 RabbitMQ web 控制台,也可以看到刚才我们在代码里面配置的交换器和队列,以及绑定信息。

20191102100525\_3.png

点击进入交换器的详情

20191102100525\_4.png

20191102100525\_5.png

源码地址

结语

由于本人知识和能力有限,文中如有没说清楚的地方,希望大家能在评论区指出,以帮助我将博文写得更好。


来源:http://ddrv.cn

赞(0) 打赏
版权归原创作者所有,任何形式的转载请联系博主:daming_90:Java 技术驿站 » RabbitMQ 实战(二)Spring Boot 整合 RabbitMQ

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏