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模式内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

盘点MQ中的异常测试
这篇文章主要为大家介绍了盘点MQ中的异常测试，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-05-05
tomcat请求流程源码解进阶篇
这篇文章主要为大家介绍了tomcat请求流程源码解进阶,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
2023-09-09
Spring中的BeanDefinition注册流程详解
这篇文章主要介绍了Spring中的BeanDefinition注册流程详解, NamespaceHandler简单来说就是命名空间处理器,Spring为了开放性提供了NamespaceHandler机制,这样我们就可以根据需求自己来处理我们设置的标签元素,需要的朋友可以参考下
2023-12-12
maven模块化开发部署实现方案
有些用户有定制化需求,需要添加新的模块功能,因此需要平台主体功能迭代的同时,非主体功能和定制化功能插件化,本文给大家介绍maven模块化开发部署实现方案,感兴趣的朋友一起看看吧
2024-01-01
Java使用bcrypt实现对密码加密效果详解
bcrypt是一种自带盐值（自动加盐）的加密方案。本文将通过示例为大家详细介绍这一对密码进行加密的算法，感兴趣的小伙伴可以跟随小编一起学习一下
2022-03-03
Java实现STL中的全排列函数next_permutation()
在算法竞赛中,全排列问题是一个经典且常见的题目,传统的递归方法在处理较大的n时会遇到堆栈内存限制的问题,本文介绍了一种避免递归,使用next_permutation函数实现全排列的方法,感兴趣的朋友跟随小编一起看看吧
2024-09-09
Java编程中使用JDBC API连接数据库和创建程序的方法
这篇文章主要介绍了Java编程中使用JDBC API连接数据库和创建程序的基本教程,JDBC是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问需要的朋友可以参考下
2015-12-12
web项目WEB-INF下没有web.xml的解决方法
新手如果在web项目创建后WEB-INF下面没有出现web.xml，怎么办？别慌，没有web.xml文件的原因是因为在创建web项目的时候没有把创建web.xml勾上。这篇文章主要介绍了web项目WEB-INF下没有web.xml的解决方法,需要的朋友可以参考下
2022-12-12
Java线程休眠的5种方法
这篇文章主要介绍了Java线程休眠的5种方法，分别是Thread.sleep、TimeUnit、wait、Condition、LockSupport，下面文章将对这五种方法进行详细讲解，需要的小伙伴可以参考一下
2022-05-05
Java中与数字相关的常用类的用法详解
在我们的代码中，经常会遇到一些数字&数学问题、随机数问题、日期问题和系统设置问题等，为了解决这些问题，Java给我们提供了多个处理相关问题的类，比如Number类、Math类、Random类等等，本篇文章我们先从Number数字类和Math数学类学起
2023-05-05