SpringBoot整合RabbitMQ 实现五种消息模型

全栈自学社区

共 1081字,需浏览 3分钟

 ·

2021-01-29 00:38

点击上方蓝色字体,选择“置顶或者星标” 


优质文章第一时间送达!


SpringBoot中使用RabbitMQ

搭建初始环境

引入依赖

    
    <dependency>
        <groupId>org.springframework.bootgroupId>
        <artifactId>spring-boot-starter-amqpartifactId>
    dependency>

配置配置文件

server:
  port: 9090

spring:
  application:
    # 微服务系统有意义, 养成好习惯, 先写出来
    name: rabbitmq-02-springboot
  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: codingce
    password: 123456
    virtual-host: /codingce

测试类 注入 rabbitTemplate

    // 注入 rabbitTemplate
    @Autowired
    private RabbitTemplate rabbitTemplate;

消息队列RabbitMQ之五种消息模型

第一种直连模型使用

开发生产者

    /**
     * 直连
     */

    @Test
    void contextLoads() {
        rabbitTemplate.convertAndSend("hello""hello word");
    }

开发消费者

/**
 * @author mxz
 */

@Component
@RabbitListener(queuesToDeclare = @Queue("hello"))
public class HelloCustomer {

    /**
     * @param message
     */

    @RabbitHandler
    public void receivel(String message) {
        System.out.println("message: " + message);
    }

}

第二种work模型使用

开发生产者

    /**
     * work
     */

    @Test
    void testWork() {
        for (int i = 0; i < 10; i++) {
            rabbitTemplate.convertAndSend("work""work模型");
        }
    }

开发消费者

/**
 * 第二种模型 work 模型
 *
 * @author mxz
 */

@Component
public class WorkCustomer {
    /**
     * 第1个消费者
     *
     * @param message
     */

    @RabbitListener(queuesToDeclare = @Queue("work"))
    public void receivel(String message) {
        System.out.println("message1 = " + message);
    }

    /**
     * 第2个消费者
     *
     * @param message
     */

    @RabbitListener(queuesToDeclare = @Queue("work"))
    public void receivel2(String message) {
        System.out.println("message2 = " + message);
    }
}

第三种 Fanout 广播模型

开发生产者

    /**
     * fanout 广播
     */

    @Test
    void testFanout() {
        rabbitTemplate.convertAndSend("logs""""Fanout模型发送的消息");
    }

开发消费者

/**
 * fanout
 *
 * @author mxz
 */

@Component
public class FanoutCustomer {

    @RabbitListener(bindings = {
            @QueueBinding(
                    value = @Queue,  // 创建临时队列
                    exchange = @Exchange(value = "logs", type = "fanout")     // 绑定的交换机
            )
    })
    public void receivel(String message) {
        System.out.println("message1 = " + message);
    }

    @RabbitListener(bindings = {
            @QueueBinding(
                    value = @Queue,  // 创建临时队列
                    exchange = @Exchange(value = "logs", type = "fanout")     // 绑定的交换机
            )
    })
    public void receive2(String message) {
        System.out.println("message2 = " + message);
    }
}

第四种 Route 路由模型

开发生产者

    /**
     * route 路由
     */

    @Test
    void testRoute() {
        // exchange 交换机名称
        rabbitTemplate.convertAndSend("directs""info""info的key的路由消息");
    }

开发消费者

/**
 * @author mxz
 */

@Component
public class RouteCustomer {

    @RabbitListener(bindings = {
            @QueueBinding(
                    value = @Queue// 绑定临时队列
                    exchange = @Exchange(value = "directs", type = "direct"), // 自定义交换机名称和类型
                    key = {"info""error""warn"}
            )
    })
    public void receivel(String message) {
        System.out.println("message1 = " + message);
    }

    @RabbitListener(bindings = {
            @QueueBinding(
                    value = @Queue// 绑定临时队列
                    exchange = @Exchange(value = "directs", type = "direct"), // 自定义交换机名称和类型
                    key = {"error"}
            )
    })
    public void receivel2(String message) {
        System.out.println("message1 = " + message);
    }

}

第五种 Topic 订阅模型(动态路由模型)

开发生产者

    /**
     * topic 订阅模式 动态路由
     */

    @Test
    void testTopic() {
        rabbitTemplate.convertAndSend("topics""user.save""user.save 路由消息");
    }

开发消费者

/**
 * 订阅模型
 *
 * @author mxz
 */

@Component
public class TopicCustomer {

    @RabbitListener(bindings = {
            @QueueBinding(
                    value = @Queue,
                    exchange = @Exchange(type = "topic", name = "topics"),
                    key = {"user.save""user.*"}
            )
    }
    )
    public void receivel(String message) {
        System.out.println("message1" + message);
    }

    @RabbitListener(bindings = {
            @QueueBinding(
                    value = @Queue,
                    exchange = @Exchange(type = "topic", name = "topics"),
                    key = {"produce.#""order.#"}
            )
    }
    )
    public void receivel2(String message) {
        System.out.println("message2" + message);
    }
}

文章已上传gitee https://gitee.com/codingce/hexo-blog
项目地址github: https://github.com/xzMhehe/codingce-java




更多推荐内容

↓↓↓

Elasticsearch应用之京东搜索

IK分词器详解

30个编程领域的趣图

如果你喜欢本文

请长按二维码,关注公众号

转发朋友圈,是对我最大的支持哟

以上,便是今天的分享,希望大家喜欢,觉得内容不错的,欢迎「分享」「」或者点击「在看」支持,谢谢各位。

浏览 53
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报