Rabbitmq入门与应用(四)-RabbitMQ常见模式

这篇具有很好参考价值的文章主要介绍了Rabbitmq入门与应用(四)-RabbitMQ常见模式。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

RabbitMQ常见Queue模式

Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式

简单模式

点对点模式,一个生产者一个消费者

生产者将消息发送到队列,消费者从队列中获取消息,队列是存储消息的缓冲区

Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式

查看管理端效果
序列化解决方案
  • 基于java序列化
  • 基于Json
@Bean
public MessageConverter messageConverter() {
	return new Jackson2JsonMessageConverter();
}

@Bean
public RabbitTemplate rabbitTemplate() {
    RabbitTemplate rabbitTemplate = new RabbitTemplate(factory);
    rabbitTemplate.setMessageConverter(messageConverter());
    :
    :
}

基于json

Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式

Work queues

工作队列模式:

一个生产者,多个消费者

  • C1,C2 是否都收到
  • 假设只有一个收到,谁收到(先)

Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式

结果: 只有一个消费者消费,轮训(负载均衡)的方式进行消费

@Bean
public Queue workQueue() {
    return new Queue(RabbitMQConstants.WORK_QUEUE, DURABLE);
}
Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式

发布订阅/fanout模式

生产者通过fanout扇出交换机群发消息给消费者,同一条消息每一个消费者都可以收到。

Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式

@Bean
public Binding bindingFanoutA(){
    return BindingBuilder
            .bind(fanoutQueueA())
            .to(fanoutExchange());
}

/**

 * Fanout交换机和队列B绑定
 * @return
   */
   @Bean
   public Binding bindingFanoutB(){
   return BindingBuilder
           .bind(fanoutQueueB())
           .to(fanoutExchange());
   }
Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式

routing模式

Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式
配置
    @Bean
    public Queue routingYellowQueue(){
        return new Queue(RabbitMQConstants.ROUTING_YELLOW_QUEUE,DURABLE);
    }
    @Bean
    public Queue routingBlueQueue(){
        return new Queue(RabbitMQConstants.ROUTING_BLUE_QUEUE,DURABLE);
    }

    @Bean
    public DirectExchange routingExchange(){
        return new DirectExchange(RabbitMQConstants.ROUTING_EXCHANGE,DURABLE,AUTO_DELETE);
    }


    @Bean
    public Binding routingYellowBinding(){
        return BindingBuilder
                .bind(routingYellowQueue())
                .to(routingExchange())
                .with(RabbitMQConstants.ROUTING_YELLOW_KEY);
    }

    @Bean
    public Binding routingBlueBinding(){
        return BindingBuilder
                .bind(routingBlueQueue())
                .to(routingExchange())
                .with(RabbitMQConstants.ROUTING_BLUE_KEY);
    }
生产者
  @Override
    public void routingOrder() {

        Order order= new Order();
        order.setBook(41L);
        order.setStatus("未支付");
        order.setTotal(5);
        order.setTime(new Date());
        
        rabbitTemplate.convertAndSend(
                RabbitMQConstants.ROUTING_EXCHANGE,     
                RabbitMQConstants.ROUTING_YELLOW_KEY,  //routing到yellow线路
                order);
        log.debug("[routing工作模式: ] 产生一个订单-->{}",order);
    }

topic模式

Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式

* 任意个任意一字符串

# 0或一个任意字符串

cba.topic.abc

topic.* —只有一个字符串

  • topic.orange

topic.# ----> 0个字符串或者多个字符串(用户点号分开的)

  • topic
  • topic.abc
  • topic.abc.bananaRabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式
Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式

Rabbitmq入门与应用(四)-RabbitMQ常见模式,rabbitmq,rabbitmq,分布式文章来源地址https://www.toymoban.com/news/detail-826077.html

    @Bean
    public Binding topicOrangeBinding(){
        return BindingBuilder
                .bind(topicOrangeQueue())
                .to(topicExchange())
                .with("*.fruit.*");  //*.fruit.*
    }

    @Bean
    public Binding topicBananaBinding(){
        return BindingBuilder
                .bind(topicBananaQueue())
                .to(topicExchange())
                .with("#.fruit.*");
    }

到了这里,关于Rabbitmq入门与应用(四)-RabbitMQ常见模式的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Rabbitmq入门与应用(一)-rabbitmq安装(docker版)

    @Rabbitmq入门与应用-rabbitmq安装(docker版) 什么是RabbitMQ? RabbitMQ is a message broker: it accepts and forwards messages. You can think about it as a post office: when you put the mail that you want posting in a post box, you can be sure that the letter carrier will eventually deliver the mail to your recipient. In this analogy, RabbitMQ is a p

    2024年02月20日
    浏览(43)
  • Rabbitmq入门与应用(六)-rabbitmq的消息确认机制

    确认消息是否发送给交换机 配置 编码RabbitTemplate.ConfirmCallback ConfirmCallback 是一个回调接口,消息发送到 Broker 后触发回调,确认消息是否到达 Broker 服务器, 也就是只确认是否正确到达 Exchange 中。 在配置类中编码确认回调函数。tips: 设置 rabbitTemplate.setMandatory(true); 配置类

    2024年02月20日
    浏览(43)
  • RabbitMQ入门案例之Topic模式

    本文章将介绍RabbitMQ中的Topic(主题)模式,其中还会涉及 ‘#’ 和 ‘*’ 两个通配符在RabbitMQ中的区别。 官网文档地址:https://rabbitmq.com/getstarted.html RabbitMQ的Topic模式是一种基于主题的消息传递模式。它允许发送者向一个特定的主题(topic)发布消息,同时,订阅者也可以针

    2024年02月10日
    浏览(42)
  • RabbitMQ入门案例之Work模式

    本文章将介绍RabbitMQ的Work模式,其中这个模式又细分为轮询分发和公平分发,本文将会用Java代码结合RabbitMQ的web管理界面进行实操演示。 官网文档地址:https://rabbitmq.com/getstarted.html RabbitMQ的Work模式是一种简单的消息队列模式,也叫做“竞争消费者模式”或“任务分发模式”

    2024年02月11日
    浏览(52)
  • RabbitMQ入门案例之发布订阅模式

    本文章主要介绍RabbitMQ的发布订阅模式,该模式下,消息为广播形式,一经发布则会进入交换机绑定的队列中,详细介绍可以阅读官方文档。 官网文档地址:https://rabbitmq.com/getstarted.html RabbitMQ中的发布与订阅模式是一种消息传递的方式,用于在分布式系统中传递消息。 在该模

    2024年02月09日
    浏览(54)
  • RabbitMQ入门案例之Direct模式

    RabbitMQ的Direct模式是一种可以根据指定路由key,Exchang将消息发送到具有该路由key下的Queue下进行存储。也就类似于将数据写进指定数据库表中。这个路由Key可以类比为SQL语句中的:where routeKey = … 官方文档地址:https://www.rabbitmq.com/getstarted.html RabbitMQ中的Direct模式是一种消息传

    2024年02月09日
    浏览(38)
  • 『RabbitMQ』入门指南(安装,配置,应用)

    RabbitMQ 是在 AMQP (Advanced Message Queuing Protocol) 协议标准基础上完整的,可复用的 企业消息系统 。它遵循 Mozilla Public License 开源协议,采用 Erlang 实现的工业级的消息队列(MQ)服务器,建立在 Erlang OTP 平台上(因为采用 Erlang 开发,所以 RabbitMQ 稳定性和可靠性比较高 ) 其他主

    2024年02月05日
    浏览(67)
  • MQ的快速入门及RabbitMQ的五种工作模式

    目录 MQ基本知识 MQ基本概念 MQ概述 MQ的优势和劣势 优势 劣势 RabbitMQ 简介 基础架构 相关概念 JMS RabbitMQ安装 在线拉取镜像 安装MQ 访问控制台(http://ip地址:15672) 工作模式 简单模式(生产者消费者模式) Work Queues 工作队列模式 Pub/Sub 订阅模式 Routing 路由模式 Topics 通配符模式

    2024年02月13日
    浏览(36)
  • RaabitMQ(三) - RabbitMQ队列类型、死信消息与死信队列、懒队列、集群模式、MQ常见消息问题

    这是RabbitMQ最为经典的队列类型。在单机环境中,拥有比较高的消息可靠性。 经典队列可以选择是否持久化(Durability)以及是否自动删除(Auto delete)两个属性。 Durability有两个选项,Durable和Transient。 Durable表示队列会将消息保存到硬盘,这样消息的安全性更高。但是同时,由于需

    2024年02月14日
    浏览(168)
  • Rabbitmq入门与应用(五)-延迟队列的设计与实现

    在开发过程中涉及到延迟队列的应用,例如订单生成后有30分钟的付款时间,注册是有60秒的邮件或者短信的发送读取时间等。 常规使用rabbitmq设计延迟队列有两种方式 使用创建一个延迟队列阻塞消息 使用延迟队列插件 Dead Letter Exchanges — RabbitMQ 配置 To set the DLX for a queue, s

    2024年02月21日
    浏览(40)

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

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包