Java RabbitMQ的三种Exchange模式

更新时间：2022年08月18日 09:26:48 作者：剑圣无痕

这篇文章主要介绍了Java RabbitMQ的三种Exchange模式，分别为Direct模式、Fanout模式、Topic模式，Rabbit的Direct Exchange模式是指消息发送导RouteKey中指定的Queue，Direct模式可以使用Rabbit自带的Exchange

简介

RabbitMQ的Exchange通常有三种模式分别为：Direct模式、Fanout模式、Topic模式。

Direct模式

Rabbit的Direct Exchange模式是指消息发送导RouteKey中指定的Queue，Direct模式可以使用Rabbit自带的Exchange，所以不需要将Exchange进行任何绑定。消息传递时，RouteKey必须完全匹配，消息才会被队列接收，否则消息将会被抛弃。

原理如下图：

示例代码：

可以参考上一章的示例代码，本文就不在重复阐述。

Fanout Exchange

Fanout Exchange 模式不处理路由键，只需要简单的将队列绑定到交换机上发送到交换机的消息都会被转发到与该交换机绑定的所有队列上。因此Fanout交换机转发消息是最快的。

原理如下图：

示例代码

配置类

@Configuration
public class RabbmitFanoutConfig
{
    private final static String FANOUT_QUEUE_1 = "fanoutQueue1"; //队列名称1
    private final static String EXCHANGE_NAME = "fanoutExchange"; //交换器名称

    @Bean
    public Queue queue1() {
        return new Queue(FANOUT_QUEUE_1);
    }

    @Bean
    public FanoutExchange fanoutExchange() {
        return new FanoutExchange(EXCHANGE_NAME);
    }

    @Bean
    public Binding bindingExchange1() {
        return BindingBuilder.bind(queue1()).to(fanoutExchange());
    }
}

生产者

@Component
public class FanOutMqProduce
{
    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendMessage(String message)
    {
        rabbitTemplate.convertAndSend("fanoutExchange",null,message);

    }
}

说明：convertAndSend 第一个参数为Exchange的名称，第二参数为routekey的名称，由于Fanout不需要通过Routekey来绑定所以参数为空。

消费者

@Component
@RabbitListener(queues = "fanoutQueue1")
public class FanOutMqConsumer
{
    private static final Logger logger = LoggerFactory.getLogger(FanOutMqConsumer.class);

    @RabbitHandler
    public void receive(String message) 
    {
        logger.info("receive message content:{}",message);
    }
}

说明：监听队列的名称与配置的队列名称一致。

测试代码

  @RequestMapping("/sendFanOutMessage")
    public String sendFanOutMessage()
    {
        fanOutMqProduce.sendMessage("this is fanout message");
        return "success";
    }

运行结果：

c.s.f.r.consumer.FanOutMqConsumer - receive message content:this is fanout message

Topic模式

Topic模式是通过Routing Key来进行通配符匹配。

符号#代表可以匹配一个或多个词
符号*代表只能匹配一个词

原理如下图：

说明：例如：usa.#能够匹配导usa.news.huofu,而europe.*只能匹配europe.news或者europe.weather

示例代码

配置类

@Configuration
public class RabbmitTopicConfig
{
    private final static String TOPIC_QUEUE_A = "topic.QueueA"; //队列名称A
    private final static String TOPIC_QUEUE_B = "topic.QueueB"; //队列名称B
    private final static String EXCHANGE_NAME = "topicExchange"; //交换器名称


    @Bean
    public Queue queueA() {
        return new Queue(TOPIC_QUEUE_A);
    }

    @Bean
    public Queue queueB() {
        return new Queue(TOPIC_QUEUE_B);
    }

    @Bean
    public TopicExchange topicExchange() {
        return new TopicExchange(EXCHANGE_NAME);
    }

    /**
     *
     * @return
     */
    @Bean
    public Binding bindingExchangeA() {
        return BindingBuilder.bind(queueA()).to(topicExchange()).with("topic.QueueA");
    }

    @Bean
    public Binding bindingExchange() {
        return BindingBuilder.bind(queueB()).to(topicExchange()).with("topic.#");
    }
}

消息发送者

@Component
public class TopicMqProduce
{
    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendMessage(String message,String routeKey)
    {
        rabbitTemplate.convertAndSend("topicExchange",routeKey,message);

    }
}

消息接收者

#监听A队列
@Component
@RabbitListener(queues = "topic.QueueA")
public class TopicMqConsumerA
{
    private static final Logger logger = LoggerFactory.getLogger(TopicMqConsumerA.class);
    @RabbitHandler
    public void receive(String message) 
    {
        logger.info("receive topic QueueA message content:{}",message);
    }
}

#监听B队列
@Component
@RabbitListener(queues = "topic.QueueB")
public class TopicMqConsumerB
{
    private static final Logger logger = LoggerFactory.getLogger(TopicMqConsumerB.class);

    @RabbitHandler
    public void receive(String message) 
    {
        logger.info("receive topic QueueB message content:{}",message);
    }
}

测试代码

#测试只发送A队列
 @RequestMapping("/sendTopicMessageA")
    public String sendTopicMessageA()
    {
        topicMqProduce.sendMessage("topic.QueueA","this is fanout message");
        return "success";
    }

    @RequestMapping("/sendTopicMessageB")
    public String sendTopicMessageB()
    {
        topicMqProduce.sendMessage("topic.QueueB","this is fanout message");
        return "success";
    }

总结

到此这篇关于Java RabbitMQ的三种Exchange模式的文章就介绍到这了,更多相关 Java Exchange模式内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Java中集合关系图及常见操作详解
这篇文章主要为大家详细介绍了Java中集合关系图及常见操作，解析Java中的集合类型的继承关系图，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-11-11
jpa onetomany 使用级连表删除被维护表数据时的坑
这篇文章主要介绍了jpa onetomany 使用级连表删除被维护表数据时的坑，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-12-12
IDEA正则表达式全局搜索图文教程
当您要搜索和替换特定的文本模式时,请使用正则表达式,下面这篇文章主要给大家介绍了关于IDEA正则表达式全局搜索的相关资料,文中通过代码以及图文介绍的非常详细,需要的朋友可以参考下
2024-08-08
详解Spring MVC的异步模式（高性能的关键）
本篇文章主要介绍了详解Spring MVC的异步模式（高性能的关键），小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-02-02
redis分布式锁的实现原理详解
这篇文章主要为大家详细介绍了redis分布式锁，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助
2022-03-03
SpringBoot对Filter过滤器中的异常进行全局处理方案详解
这篇文章主要介绍了SpringBoot对Filter过滤器中的异常进行全局处理,在SpringBoot中我们通过 @ControllerAdvice 注解和 @ExceptionHandler注解注册了全局异常处理器，需要的朋友可以参考下
2023-09-09
mybatis中的if-else及if嵌套使用方式
这篇文章主要介绍了mybatis中的if-else及if嵌套使用方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-03-03
详解Java文件下载的几种实现方式
这篇文章主要介绍了详解Java文件下载的几种实现方式，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2016-12-12
Java遍历Properties所有元素的方法实例
这篇文章主要介绍了Java如何遍历Properties所有元素的方法，大家可以参考使用
2013-11-11
spring注解在自定义jar包中无法被扫描的解决方案
这篇文章主要介绍了spring注解在自定义jar包中无法被扫描的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-08-08