脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Java Exchange模式

Java RabbitMQ的三种Exchange模式

 更新时间：2022年08月18日 09:26:48   作者：剑圣无痕​​​​​​​  
这篇文章主要介绍了Java RabbitMQ的三种Exchange模式，分别为Direct模式、Fanout模式、Topic模式，Rabbit的Direct Exchange模式是指消息发送导RouteKey中指定的Queue，Direct模式可以使用Rabbit自带的Exchange

前言：

上一章讲解RabbitMq的相关知识和如何使用Spring Boot集成Rabbitmq发送消息，本文将讲解RabbitMQ三种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实现读取txt文件并以在每行以空格取数据

    java实现读取txt文件并以在每行以空格取数据

    今天小编就为大家分享一篇java实现读取txt文件并以在每行以空格取数据，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2018-07-07
  • java爬虫Gecco工具抓取新闻实例

    java爬虫Gecco工具抓取新闻实例

    本篇文章主要介绍了JAVA 爬虫Gecco工具抓取新闻实例，具有一定的参考价值，感兴趣的小伙伴们可以参考一下。
    2016-10-10
  • spring+shiro 整合实例代码详解

    spring+shiro 整合实例代码详解

    本文通过实例代码给大家介绍spring+shiro 整合的过程，非常不错，具有一定的参考借鉴价值,需要的朋友可以参考下
    2018-10-10
  • idea远程debug调试部署在tomcat上项目

    idea远程debug调试部署在tomcat上项目

    本文主要介绍了idea远程debug调试部署在tomcat上项目，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2021-08-08
  • springboot整合Mybatis-plus的实现

    springboot整合Mybatis-plus的实现

    这篇文章主要介绍了springboot整合Mybatis-plus的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-09-09
  • 从零开始Mybatis连接数据库的方法

    从零开始Mybatis连接数据库的方法

    这篇文章主要介绍了Mybatis连接数据库的方法，本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-02-02
  • java开发_图片截取工具实现原理

    java开发_图片截取工具实现原理

    本文将详细介绍java开发_图片截取工具实现原理，需要了解的朋友可以参考下
    2012-11-11
  • Java中队列Queue和Deque的区别与代码实例

    Java中队列Queue和Deque的区别与代码实例

    学过数据结构的,一定对队列不陌生,java也实现了队列,下面这篇文章主要给大家介绍了关于Java中队列Queue和Deque区别的相关资料,需要的朋友可以参考下
    2021-08-08
  • 一篇文章带你详解Spring的概述

    一篇文章带你详解Spring的概述

    这篇文章主要为大家介绍了Spring的概述，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助
    2022-01-01
  • Java实现ATM银行管理系统(控制台版本)

    Java实现ATM银行管理系统(控制台版本)

    这篇文章主要为大家详细介绍了如何利用Java语言实现控制台版本的ATM银行管理系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2022-06-06

最新评论