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

RabbitMQ常见Queue模式

image-20230722102545586 image-20230722102605912 image-20230722102641436

简单模式

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

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

image-20230617192522553

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

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

基于json

image-20230722180149630

Work queues

工作队列模式:

一个生产者,多个消费者

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

image-20230617192808675 image-20231031093805938

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

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

@Bean
public Queue workQueue() {
    return new Queue(RabbitMQConstants.WORK_QUEUE, DURABLE);
}
image-20230725100649432

发布订阅/fanout模式

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

image-20230617193442071

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

/**

 * Fanout交换机和队列B绑定
 * @return
   */
   @Bean
   public Binding bindingFanoutB(){
   return BindingBuilder
           .bind(fanoutQueueB())
           .to(fanoutExchange());
   }
image-20230725100900868

routing模式

image-20230725103347564
配置
    @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模式

image-20231031121640085

* 任意个任意一字符串

# 0或一个任意字符串

cba.topic.abc

topic.* —只有一个字符串

  • topic.orange

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

  • topic
  • topic.abc
  • topic.abc.bananaimage-20230725140907058
image-20230725140727896

image-20231218145310089

    @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.*");
    }

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/403935.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【Java从入门到精通】Java Character 类

Java Character 类 Character 类用于对单个字符进行操作。 Character 类在对象中包装一个基本类型 char 的值 实例 char ch a;// Unicode 字符表示形式 char uniChar \u039A; // 字符数组 char[] charArray { a, b, c, d, e }; 然而,在实际开发过程中&#xf…

利用Python email的MIMEBase及MIMEApplication发送邮件附件

**MIMEBase、 MIMEApplication背景知识点总结** MIMEBase 和 MIMEApplication 都是用于创建 MIME 消息的类,但它们之间有一些异同点。 异同点如下: 用途: MIMEBase 是一个基类,用于表示任何类型的 MIME 消息部分。它提供了一种通…

Video generation models as world simulators-视频生成模型作为世界模拟器

原文地址:Video generation models as world simulators 我们探索在视频数据上进行大规模生成模型的训练。具体来说,我们联合训练文本条件扩散模型,同时处理不同持续时间、分辨率和长宽比的视频和图像。我们利用一个在视频和图像潜在编码的时…

Redis信创平替之TongRDS(东方通),麒麟系统安装步骤

我的系统: 银河麒麟桌面系统V10(SP1)兆芯版 1.先进入东方通申请使用 2.客服会发送一个TongRDS包与center.lic给你(我这里只拿到.tar.gz文件,没有网上的什么安装版) 3.上传全部文件到目录中 4.服务节点安装,并启动 tar -zxvf TongRDS-2.2.1.2_P3.Node.tar.gz cd pmemdb/bin/…

c++实现栈和队列类

c实现栈和队列类 栈(Stack)Stack示意图Stack.cpp 队列(queue)queue 示意图queue.cpp 栈(Stack) Stack示意图 Stack.cpp #pragma once #include "ListStu.cpp"template<typename T> class Stack { public: /* * void push(T& tDate)* 参数一 &#xff1a;…

【Linux从青铜到王者】 基础IO

本篇重点&#xff1a;文件描述符&#xff0c;重定向&#xff0c;缓冲区&#xff0c;磁盘结构&#xff0c;文件系统&#xff0c;inode理解文件的增删查改&#xff0c;查找一个文件为什么一定要有路径&#xff0c;动静态库&#xff0c;有的时候为什么找不到库&#xff0c;动态库的…

SQL面试题及答案

介绍 在快节奏的数据管理和信息技术世界中,导航和操作结构化数据的能力是一项非常重要的技能。SQL,即结构化查询语言,是关系数据库的基石,掌握这种语言的专业人员的需求量很大。SQL 面试在科技行业很常见,潜在的候选人会接受测试以展示他们的知识和解决问题的能力。为了帮…

酷开科技丨新年新玩法!酷开系统壁纸模式给客厅“换”新

甲辰龙年即将到来&#xff0c;新年新家新气象&#xff0c;快到酷开系统壁纸模式中挑选一款喜欢的壁纸&#xff0c;为新的一年增添一份美好和喜悦吧&#xff01; 酷开科技将更多的电视新玩法带给你&#xff0c;让你的电视成为家庭中的焦点&#xff01;酷开系统壁纸模式&#xf…

【前端素材】推荐优质后台管理系统APP Zina平台模板(附源码)

一、需求分析 当我们从多个层次来详细分析后台管理系统时&#xff0c;可以将其功能和定义进一步细分&#xff0c;以便更好地理解其在不同方面的作用和实际运作。 1. 功能层次 a. 用户管理功能&#xff1a; 用户注册和登录&#xff1a;管理用户账户的注册和登录过程。权限管…

easyui 手风琴Accordion 面板的高度设置

今天接到一个新的小需求&#xff0c;如下图&#xff0c;当预算表单只有一个时&#xff0c;要求不显示预算表单这块的内容。 考虑到页面创建时用到了表单的回调和点击方法&#xff0c;所以不能单纯的移除&#xff0c;移除右侧表格的创建会报错&#xff0c;所以只能隐藏。 隐藏…

突破挑战:利用沃尔玛跨境智星实现批量注册与下单

在进行沃尔玛测评时&#xff0c;确保环境安全至关重要。每个账号都应使用独立的运行环境&#xff0c;这样可以避免浏览器指纹、字体以及浏览器数据之间的关联问题。此外&#xff0c;账号的资料也需要特别注意。最好是自己注册自己下单&#xff0c;这样可以确保所有资源都掌握在…

JAVA工程师面试专题-并发编程篇

目录 一、线程 1、并发与并行的区别 2、同步和异步的区别 3、Java中创建线程有哪些方式? 4、Thread和Runnable的区别 5、Java中的Runnable、Callable、Future、FutureTask的区别和联系&#xff1f; 6、说一下你对 CompletableFuture 的理解 7、volatile关键字有什么用&…

如何下载 VisualStudio2022 离线包

1.概要&#xff0c;有些场景下&#xff0c;不允许联网&#xff0c;需要下载离线安装包。 2.过程 2.1 下载地址 创建基于网络的安装 - Visual Studio (Windows) | Microsoft Learn 2.2 选择引导程序 2.3 执行命令 2.3.1 下载全部&#xff1a; vs_Enterprise.exe --layout …

芯科科技与Arduino携手推动Matter普及化

双方的合作可助力开发人员在两分钟内将新开发板配置入网 致力于以安全、智能无线连接技术&#xff0c;建立更互联世界的全球领导厂商Silicon Labs&#xff08;亦称“芯科科技”&#xff0c;NASDAQ&#xff1a;SLAB&#xff09;日前宣布&#xff0c;公司与开源硬件和软件领域的…

如何判断领导是在培养你,还是在压榨你?

在职场中&#xff0c;判断领导的真实意图并非易事。有时&#xff0c;他们的行为可能让人困惑&#xff0c;不清楚他们是在真心培养你&#xff0c;还是在过度压榨你。 在职场提高工作效率&#xff0c;我们可以使用进度猫这样的项目管理工具来管理任务。通过使用进度猫甘特图&am…

【linux进程间通信(二)】共享内存详解以及进程互斥概念

&#x1f493;博主CSDN主页:杭电码农-NEO&#x1f493;   ⏩专栏分类:Linux从入门到精通⏪   &#x1f69a;代码仓库:NEO的学习日记&#x1f69a;   &#x1f339;关注我&#x1faf5;带你学更多操作系统知识   &#x1f51d;&#x1f51d; 进程间通信 1. 前言2. 共享内…

2024高效神器:思维导图,让你的思维飞翔!

在信息爆炸的时代&#xff0c;如何高效地处理、整合和记忆海量信息成为了摆在我们面前的一大挑战。而在这个关键时刻&#xff0c;思维导图凭借其独特的优势&#xff0c;正逐渐成为2024年最受欢迎的高效神器。那么&#xff0c;思维导图究竟有何魅力&#xff0c;能够助我们一臂之…

【Linux进程】冯·诺依曼体系结构以及操作系统的深入理解

&#x1f4d9; 作者简介 &#xff1a;RO-BERRY &#x1f4d7; 学习方向&#xff1a;致力于C、C、数据结构、TCP/IP、数据库等等一系列知识 &#x1f4d2; 日后方向 : 偏向于CPP开发以及大数据方向&#xff0c;欢迎各位关注&#xff0c;谢谢各位的支持 目录 1.冯诺依曼体系结构特…

igolang学习2,golang开发配置国内镜像

go env -w GO111MODULEon go env -w GOPROXYhttps://goproxy.cn,direct

问题1-spring-boot版本和org.springframework的spring-web兼容的版本

报错问题如下&#xff1a; Description: An attempt was made to call a method that does not exist. The attempt was made from the following location: org.springframework.web.servlet.handler.AbstractHandlerMethodMapping.createHandlerMethod(AbstractHandlerMeth…