RabbitMq camel

真实的项目如果 交换器/ 队列很多  建议在管理页面新建exchange / queue/ rootingKey /vhost, 而不要写死在springboot项目里

camel按rooting key发送消息:  最推荐
.to("rabbitmq:sino.nannan?routingKey=sino.key&skipExchangeDeclare=true&skipQueueDeclare=true").log("${body}").end();按queueName发送消息:  推荐
.to("rabbitmq:sino.nannan?queue=sino.queueName&skipExchangeDeclare=true&skipQueueDeclare=true").log("${body}").end();按交换器名称和类型 发送消息: (不常用, 用在fanout)
.to("rabbitmq:sino.nan?exchangeType=fanout&skipExchangeDeclare=true&skipQueueDeclare=true").log("${body}").end();camel按queueName接收消息:  推荐
from("rabbitmq:sino.nannan?exchangeType=topic&autoDelete=false&queue=sino.queueName&skipQueueDeclare=true")camel整合rabbitmq引入依赖 <dependency><groupId>org.apache.camel</groupId><artifactId>camel-spring-boot-starter</artifactId><version>2.22.2</version></dependency><!-- 3.20.5 是camel-rabbitmq最新的jar --><dependency><groupId>org.apache.camel</groupId><artifactId>camel-rabbitmq</artifactId><version>2.22.2</version></dependency>

0. add virtual host

1. Connections

2. add exchange (需选择virtual host)

RabbitMQ 提供了四种主要的交换机类型(Exchange Types),用于将消息路由到适当的队列(Queues)。每种交换机类型都有其特定的行为和用途:Direct Exchange:
行为: 通过完全匹配路由键 (Routing Key) 将消息发送到与其绑定的队列。
用法: 当你希望消息被准确地路由到一个指定的队列时使用。
示例: 如果消息的路由键是 "info" 并且队列绑定的路由键也是 "info",则该消息会被路由到该队列。Fanout Exchange:
行为: 将消息广播到所有绑定到该交换机的队列,不考虑路由键。
用法: 当你希望消息复制并发送到所有绑定队列时使用,例如广播消息。
示例: 一个 Fanout 交换机可以用来将同一消息发送到多个服务或日志系统。Topic Exchange:
行为: 根据模式匹配路由键,将消息发送到符合模式的队列。模式可以包含通配符,例如 * 表示一个单词,# 表示零个或多个单词。
用法: 当你需要基于模式或主题进行复杂的路由时使用。
示例: 路由键 "user.*" 可以匹配 "user.info",而 "user.#" 可以匹配 "user.info" 和 "user.info.details"。Headers Exchange:
行为: 根据消息的属性(头部信息)进行路由,而不是依赖于路由键。头部信息可以包括任意键值对。
用法: 当你需要基于多个属性进行复杂路由时使用。
示例: 你可以配置交换机根据头部信息如 {"x-match": "all", "format": "pdf", "type": "report"} 进行路由,只有消息头部包含这些键值对时才会被路由到绑定的队列。
这四种交换机类型提供了不同的消息路由机制,使得 RabbitMQ 能够灵活地适应各种消息分发需求。选择合适的交换机类型可以有效地优化消息传递的效率和准确性

3. add a new queue (需选择virtual host)

 4. 对新建的queue  (交换器 和 rooting_key 绑定)

发布/订阅模式(Publish/Subscribe)是 RabbitMQ 中常见的一种消息传递模式,用于将消息广播给多个消费者。在这种模式中,消息发送者(发布者)将消息发送到一个交换机(exchange),交换机将消息广播到所有与之绑定的队列,然后消费者(订阅者)可以从这些队列中接收消息

根据路由键 和mq服务所有的路由键比对 附和  消息就到相匹配的队列里
如果多个队列的rooting_key都与某个消息的路由键匹配,那么这个消息就会被复制并发送到所有匹配的队列中
 

5.  * 和 # 在 RabbitMQ 中用作路由键的通配符

在 RabbitMQ 中,"routing key"(路由键)是用于消息路由的关键部分。当消息发布到交换机(exchange)时,交换机会根据消息的路由键将消息路由到相应的队列(或者其他交换机,取决于交换机类型)。符号 "*" 和 "#" 在 RabbitMQ 中有特定的意义,它们被用作路由键的通配符:"*"(星号):在路由键中表示一个单词(单词由点 "." 分隔)的通配符。
例如,路由键 *.info 匹配 app.info、api.info,但不匹配 app.error。
"#"(井号):在路由键中表示零个或多个单词的通配符。
例如,路由键 app.# 匹配 app.error、app.info、app.system.error 等。
这些通配符可以帮助在消息路由时进行灵活的匹配,使得你可以定义复杂的路由规则,而不需要为每个可能的情况都单独定义一个绑定。举例来说,如果你有一个交换机,它绑定了一个队列,绑定键为 *.error,那么这个队列将接收到所有以 .error 结尾的路由键的消息,例如 app.error、db.error 等。因此,"*" 和 "#" 是 RabbitMQ 中用来实现灵活消息路由的重要工具。

6. Channel的理解

 虽然你不能直接在管理界面上创建或关闭Channel,但你可以通过管理界面创建和管理队列、交换器、绑定等,这些都是通过Channel在后台执行的

7. rabbitmq 发布订阅模式 是指 fanout交换机吗? 是

topic交换机支持复杂的路由规则。

@Override
public void configure() {from("timer://foo?period=10000").setBody().constant("22222").to("direct:sendToFanout");from("direct:sendToFanout").to("rabbitmq:sino.nan?exchangeType=fanout&autoDelete=false&skipQueueDeclare=true").log("csx data:" + "${body}");}将队列名称分别为 nan1  nan2的队列与fanout类型的交换机sino.nan 绑定.一个项目里对nan1  nan2 同时监听消费就会报错,
Caused by: org.apache.camel.FailedToStartRouteException: Failed to start route route2 because of Multiple consumers for the same endpoint is not allowed: rabbitmq://sino.nan?autoDelete=false&exchangeType=fanout&queue=nan1&skipQueueDeclare=true@Override
public void configure() {from("rabbitmq:sino.nan?exchangeType=fanout&autoDelete=false&queue=nan1&skipQueueDeclare=true")// 这里可以添加更多异常处理逻辑,如重试、路由到错误队列等.log("推送到soa1: ${body}").end();}@Override
public void configure() {from("rabbitmq:sino.nan?exchangeType=fanout&autoDelete=false&queue=nan2&skipQueueDeclare=true")// 这里可以添加更多异常处理逻辑,如重试、路由到错误队列等.log("推送到soa1: ${body}").end();}

是的,RabbitMQ中的发布订阅模式通常指的是使用fanout类型的交换机。在发布订阅模式下,消息生产者发送消息到fanout交换机,交换机并不处理任何路由键(routing key),而是简单地将消息广播到所有与之绑定的队列上。每个绑定到fanout交换机的队列都会收到消息的一个拷贝,进而可以供给绑定到这些队列的消费者进行处理。

是的,RabbitMQ的发布订阅模式通常指的是使用fanout交换机。这种交换机类型将消息广播到所有绑定到该交换机的队列,而不考虑路由键。这使得fanout交换机非常适合实现发布订阅模式。


direct (发布与订阅完全匹配)
fanout 广播 (没有路由键RouteKey的概念)
topic 主题,规则匹配direct交换器相对来说比较简单,匹配规则为:如果路由键匹配,消息就被投送到相关的队列
fanout交换器中没有路由键的概念,他会把消息发送到所有绑定在此交换器上面的队列中。
topic交换器你采用模糊匹配路由键的原则进行转发消息到队列中交换器和队列的关系:
交换器是通过 路由键 和 队列 绑定在一起的, 如果消息拥有的 路由键 跟队列 和 交换器 的路由建匹配, 那么消息就会被路由到该绑定的队列中也就是说, 消息首先会经过交换器, 接下来交换器在通过路由键值 匹配分发消息到具体的队列中。路由键 可以理解为 匹配的规则总结
fanout交换机:它将消息广播到所有绑定到它的队列,不考虑路由键。
发布订阅模式:通过使用fanout交换机,可以实现一个生产者将消息发送给多个消费者的模式,每个消费者都有自己的队列来接收消息。

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Python 挖坑式填充Excel模板内容(包括页眉/SheetName/logo)

纵览 Python处理Excel的方式--解压缩方式1、导包2、对模板文件进行解压缩3、对解压缩后文件层级进行介绍4、准备需要载入的数据5、模板挖坑6、运行替换代码7、压缩文件8、生成文件9、完成代码10、可能遇到的问题 结语 Python处理Excel的方式–解压缩方式 在处理Excel中过程中&…

《人人都是产品经理》:项目的坎坷一生

《人人都是产品经理》&#xff1a;项目的坎坷一生 产品VS项目产品经理和项目经理 一切项目从kick off 开始工作量预估Kick Off的大致也就15分钟 写文档咯UML图用例文档UCdemo也得做 需求活在项目中bug等级有多高bug流转过程 以终为始 产品VS项目 项目定义&#xff1a;是只会进…

navict sql 复制出来 带逗号分隔的,如:(1, 2, 3, 4, 5)

1. 假如我们要查询一个表中所有的id, 拼接成括号逗号分隔形式 select id from student1 2 3 4 5 2. 解决办法&#xff1a;使用函数创建一个对应的函数 如下是sql代码&#xff1a; # 删除函数 drop FUNCTION if EXISTS sm; # 创建函数 CREATE FUNCTION sm(s TEXT) RETURNS …

怎么压缩pdf文件大小,如何压缩pdf文件大小

pdf文件怎么压缩&#xff1f;在当下这个信息爆炸的时代&#xff0c;无论是在工作场所还是校园中&#xff0c;我们经常会面临需要处理大文件的情况&#xff0c;而PDF格式作为一种保留文档结构和布局完整性的理想选择&#xff0c;有时候pdf文件太大&#xff0c;因此&#xff0c;对…

【vdbench性能测试】Slaver连Master显示连接超时,大概率etc/hosts文件出问题

报错类似&#xff1a; slavejvm execution parameter: -m 127.0.1.1 slavejvm execution parameter: -n xx.xx.xx.xx-11-240626-15.21.50.164 slavejvm execution parameter: -l hd2-0 15:21:50.833 15:21:50.832 slavejvm execution parameter: -p 5570 slavejvm positio…

typec密封胶防水用什么胶好?

typec密封胶防水用什么胶好&#xff1f; 对于Type-C连接器的防水密封&#xff0c;行业内普遍推荐使用单组份环氧型热固化胶。这种胶水具有以下优点&#xff0c;使其成为Type-C防水密封的理想选择&#xff1a; 粘稠度易于调整&#xff1a;这有助于胶水在点胶过程中更好地渗透到T…

基于深度学习的点云包围盒检测

基于深度学习的点云包围盒检测 点云包围盒检测是一项关键任务&#xff0c;主要用于三维场景中物体的检测和定位。与传统的二维图像目标检测不同&#xff0c;点云数据包含了三维空间的信息&#xff0c;能够提供更加丰富的细节和准确的位置。基于深度学习的方法在点云包围盒检测…

2024年二级建造师机电工程专业考试题库分享。

1.调查表法通常与&#xff08;&#xff09;结合使用&#xff0c;以便更快地发现问题原因。 A.经验法 B.分层法 C.样本调查法 D.对比分析法 答案&#xff1a;B 解析&#xff1a;题干内容提示调查表法往往会与分层法结合起来应用&#xff0c;故B选项正确。 2.在质量统计分…

nestjs从零到一,快速上手(七) 拦截器的使用

演示代码&#xff1a; 1. logs.controller.ts import { Body, Controller, Post, UseInterceptors } from nestjs/common; import { IsNotEmpty, IsString } from class-validator; import { SerializeInterceptor } from ../interceptors/serialize/serialize.interceptor; …

压缩图片png格式该怎么操作?试试下面这3个图片压缩工具吧

png是经常用于储存图片的一种格式&#xff0c;随着现在图片在日常工作和生活中的广泛使用&#xff0c;在很多的使用场景中都有应用。png的图片质量高而且支持无损压缩&#xff0c;在缩小图片的时候不会因为压缩而影响图片的清晰度&#xff0c;更适合在网上的存储、分享或者传输…

论文阅读MVBench: A Comprehensive Multi-modal Video Understanding Benchmark

摘要(Abstract)&#xff1a; 论文介绍了MVBench&#xff0c;这是一个全新的多模态视频理解基准测试&#xff0c;旨在评估多模态大型语言模型&#xff08;MLLMs&#xff09;在视频理解方面的能力。 目前许多基准测试主要集中在静态图像任务的空间理解上&#xff0c;而忽视了动…

c++进程间通信--zeromq

ZeroMQ&#xff08;也写作 MQ、0MQ 或 zmq&#xff09;是一个高性能的异步消息队列库&#xff0c;提供了一种灵活的方式来实现进程间通信&#xff08;IPC&#xff09;以及网络通信。在C中使用ZeroMQ进行进程间通信非常直观和高效。zmq的通信模式如下&#xff1a; 下面先说明请求…

保护你的代码堡垒:精通npm audit命令

保护你的代码堡垒&#xff1a;精通npm audit命令 在当今快速发展的软件开发领域&#xff0c;安全漏洞如同暗夜中的刺客&#xff0c;随时可能对我们的应用程序发起致命一击。幸运的是&#xff0c;npm提供了一个强大的安全审计工具——npm audit命令&#xff0c;它能帮我们检测和…

第 11 课:组件介绍与自定义开发

本讲主要介绍了隐语的组件标准、已有的组件能力以及进一步的自定义开发流程。经过本讲的学习&#xff0c;可以为将隐语集成到任意调度系统&#xff0c;基于Kusica/SecretPad进行二次开发&#xff0c;以及参与隐语开放标准共建建立基础。 一、隐语开放标准 隐语提出的适用于隐私…

2024.06.26【读书笔记】|医疗科技创新流程(前言)【AI增强版】

目录 《BIODESIGN》第二版前言详细总结前言概述新增重要内容价值导向 (Value Orientation)全球视角 (Global Perspectives)更好的教学和学习方法 (Better Ways to Teach and Learn)全新视频集合 (New Videos)扩展的“实地”案例研究 (Expanded “From the Field” Case Studies…

产品3D展示有哪些优势?3D能替代2D展示吗?

随着科技的飞速发展和经济的持续增长&#xff0c;我们见证了一个从2D到3D的产品展示革命。与传统的2D图片展示相比&#xff0c;3D产品展示正以其独特的优势逐渐崭露头角。 一、3D产品展示的独特优势 1、更逼真的视觉效果&#xff1a; 3D展示技术能够以更为真实、立体的方式展…

证件照制作工具有哪些?这6个帮你自制证件照

许多人可能认为&#xff0c;制作一张符合标准要求的证件照&#xff0c;必须亲自前往照相馆。 然而&#xff0c;事实上&#xff0c;我们完全可以使用手机或电脑上的证件照制作app&#xff0c;自己轻松完成证件照的制作。无论是更换背景颜色&#xff0c;还是调整照片尺寸&#x…

qt qml-http之XMLHttpRequest介绍详解使用

文章目录 QML中的XMLHttpRequest详解与示例基本用法示例代码代码详解更复杂的示例:POST请求代码详解结论QML中的XMLHttpRequest详解与示例 XMLHttpRequest 是 QML 中用于执行HTTP请求的一种机制,类似于Web中的AJAX。它可以用来进行异步的数据传输,可以从服务器获取数据,也…

【ARM】Ulink不同的系列对于芯片的支持和可以支持keil软件

【更多软件使用问题请点击亿道电子官方网站】 1、 文档目标 了解不同版本的ULINK可以支持的芯片架构&#xff0c;和ULINK可以和哪个系列的keil软件进行在线调试 2、 问题场景 用于了解不同ULINK仿真器对于芯片的支持是不一样的&#xff0c;并不是ULINK可以支持所有的keil软件…

typescript 枚举类型

枚举类型 枚举类型是为数不多的特有类型之一&#xff0c;它允许开发者定义一组命名常量&#xff0c;这些常量可以是数字或字符串类型。枚举类型提供了一种方式来组织和管理一组相关的值&#xff0c;使得代码更加清晰和易于理解。 数字枚举类型 enum Direction1 {Up 1, //初…