WebSocket的那些事(6- RabbitMQ STOMP目的地详解)

news2025/1/11 17:12:51

目录

  • 一、目的地类型
  • 二、Exchange类型目的地
  • 三、Queue类型目的地
  • 四、AMQ Queue类型目的地
  • 五、Topic类型目的地

一、目的地类型

在上节 WebSocket的那些事(5-Spring STOMP支持之连接外部消息代理)中我们已经简单介绍了各种目的地类型,如下图:
在这里插入图片描述
这一节我们来详细探讨一下各种目的地类型的区别。

MESSAGE报文中请求头destination的格式如下:

  • 发布到默认交换机的消息目的地格式为:/queue/queue_name
  • 发布到amp.topic交换机的消息目的地格式为:topic/routing_key
  • 其它所有消息目的地格式为:/exchange/exchange_name/routing_key

如果队列名、交换机名、路由key包含了/%或者非ascii字符,这些字符将会被替换为%dddd的意思是16进制编码。


二、Exchange类型目的地

任何exchange/queue或者exchange/routing-key的组合都可以通过前缀为/exchange的目的地来访问。

对于SUBSCRIBE命令,目的地格式为:/exchange/<name>[/<pattern>],格式说明如下:

  • name交换机上创建一个排它,自动删除的队列。
  • 如果<pattern>有指定,则以<pattern>为路由key绑定到名称为name的交换机上。

对于SEND命令,目的地格式为:/exchange/<name>[/<routing-key>],格式说明如下:

  • 通过<routing-key>发送消息到名称为name的交换机上。

备注:Exchange类型的目的地不适用于从已存在的队列消费信息。对于每个订阅者都会创建一个新的队列,并且通过指定的路由key绑定到指定的交换机。如果要消费已存在队列的消息,可以使用/amq/queue目的地。


三、Queue类型目的地

对于简单队列,目的地格式为/queue/<name>

Queue类型目的地只会把消息传递给最多一个订阅者,发送的消息如果没有消费者订阅将会一直入队,直到订阅者进行消费。

  • 对于SUBSCRIBE命令,该类型目的地会创建一个共享的名称为name的队列。
  • 对于SEND命令,名称为name的共享队列会在第一次发送消息到该类型的目的地时创建,消息将会根据路由keyname发送到默认交换机上。

四、AMQ Queue类型目的地

如果要发送或者订阅不由STOMP适配器管理的已存在队列的消息,消息目的地格式为/amq/queue/<name>,说明如下:

  • 对于SENDSUBSCRIBE命令,不会创建队列。如果队列不能存在,使用SUBSCRIBE队列会报错。
  • 对于SEND命令,消息会经由默认交换机直接发送已经存在的名称为name的队列上。
  • 对于SUBSCRIBE命令,针对已存在的名称为name的队列订阅会基于当前STOMP会话建立。

备注:如果没有指定任何队列参数,队列将会被认定持久、非排它、非自动删除。


五、Topic类型目的地

STOMP客户端用的最多的目的地类型就是/topic/<name>,该类型的目的地可以路由消息到多个订阅者,发送到Topic类型目的地的消息如果没有订阅者订阅,将会被丢弃。

关于Topic类型目的地的格式说明如下:

  • 对于SEND命令,消息会通过路由key<name>发送到amp.topic交换机上。
  • 对于SUBSCRIBE命令,首先会创建一个自动删除和非持久化的队列,然后会将该队列通过路由key<name>绑定到amp.topic交换机上。

可以通过stomp.default_topic_exchange参数可以修改默认Topic交换机的名称,如下:

stomp.default_topic_exchange = some.exchange

更多关于目的地类型的说明可以参考:RabbitMQ STOMP插件说明。

在这里插入图片描述

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

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

相关文章

Pygame实现黑客帝国屏幕效果

黑客帝国的屏幕效果如图1所示。 图1 黑客帝国屏幕效果 实现以上功能&#xff0c;实际上就是在Pygame中创建两个Surface&#xff0c;其中一个Surface是纯黑屏背景&#xff0c;用来覆盖之前的屏幕&#xff0c;达到数字逐渐消失的效果&#xff1b;另一个Surface用来显示数字&…

ChatGPT ,AIGC 办公函数案例用5种方法实现区间计算

区间判断一直是职场数据处理与数据汇总的一个永恒话题。 例如 请根据销售员业绩计算提成(1万以下提成1%,1万至2万提成2%,2万至10万提成3%,10万以上提成4%) 请根据学生成绩写评语(90分以上优秀,80分以上良好,70分以上一般,60分以上及,60以下不及格) 等等类似的需求还…

大数据Flink(九十三):DML:Order By、Limit 子句

文章目录 DML:Order By、Limit 子句 一、Order By 子句

嵌入式Linux应用开发-第十五章具体单板的按键驱动程序

嵌入式Linux应用开发-第十五章具体单板的按键驱动程序 第十五章 具体单板的按键驱动程序(查询方式)15.1 GPIO操作回顾15.2 AM335X的按键驱动程序(查询方式)15.2.1 先看原理图确定引脚及操作方法15.2.2 再看芯片手册确定寄存器及操作方法15.2.3 编程15.2.3.1 程序框架15.2.3.2 硬…

跨域问题详解:CORS问题+解决办法

跨域问题详解&#xff1a;CORS问题 1 概念&#xff1a;协议 域名 端口任意一个不同就会触发 CORS是一个W3C标准&#xff0c;全称是"跨域资源共享"&#xff08;Cross-origin resource sharing&#xff09;。 它允许浏览器向跨源服务器&#xff0c;发出XMLHttpReque…

微服务架构的黄金法则:拆分、重构、扩展

文章目录 1. 拆分&#xff08;Decompose&#xff09;1.1 单一责任原则&#xff08;Single Responsibility Principle&#xff09;1.2 松耦合&#xff08;Loose Coupling&#xff09;1.3 数据拆分 2. 重构&#xff08;Refactor&#xff09;2.1 单一代码库2.2 独立部署2.3 自动化…

CSP-J第二轮试题-2020年-1.2题

文章目录 参考&#xff1a;总结 [CSP-J2020] 优秀的拆分题目描述输入格式输出格式样例 #1样例输入 #1样例输出 #1 样例 #2样例输入 #2样例输出 #2 提示样例 1 解释数据规模与约定 答案1答案2 [CSP-J2020] 直播获奖题目描述输入格式输出格式样例 #1样例输入 #1样例输出 #1 样例 …

OIS、EIS原理

OIS概念 光学防抖OIS&#xff0c;全称Optical Image Stabilization&#xff0c;从字面理解就是稳定的光学图像。其工作原理是基于陀螺仪检测并进行位移补偿。即通过镜头内的陀螺仪侦测手机抖动产生的微小移动&#xff0c;然后将信号传至CPU处理&#xff0c;CPU会即刻计算需要补…

小白继续深入学习C++

第1节 指针的基本概念 1、变量的地址&#xff1a; 变量是内存地址的简称&#xff0c;在C中&#xff0c;每定义一个变量&#xff0c;系统就会给变量分配一块内存&#xff0c;内存是有地址的。 C用运算符&获取变量在内存中的起始地址。 语法&#xff1a; &变…

国庆作业 day1

C语言基础考题&#xff08;40&#xff09; 选择题 20分每题2分 1、已知字母A的ASCII码为十进制数值65&#xff0c;且S为字符型&#xff0c;则执行语句SA6-3&#xff1b;后S中的值为 ( ) A.D B.68 C.不确定的值 D.C 2、若有定义语句&#xff1a;int a12;&#xff0c;则执…

Java之线程池的详细解析

1. 线程池 1.1 线程状态介绍 当线程被创建并启动以后&#xff0c;它既不是一启动就进入了执行状态&#xff0c;也不是一直处于执行状态。线程对象在不同的时期有不同的状态。那么Java中的线程存在哪几种状态呢&#xff1f;Java中的线程 状态被定义在了java.lang.Thread.Stat…

安全渗透测试基础之漏洞扫描工具之Nessus使用介绍

前置条件:Nessus工具使用前要确保工具是服务状态 systemctl start nessusd.service 启动nessus服务 systemctl status nessusd.service 查看nessus服务状态 1.配置扫描模板 2.新增高级扫描 2.1 设置日程表: 2.2设置邮件收件人(可选): 2.3主机发现: 2.

软件设计模式系列之二十一——观察者模式

1 观察者模式的定义 观察者模式&#xff08;Observer Pattern&#xff09;是一种行为型设计模式&#xff0c;它允许对象之间建立一对多的依赖关系&#xff0c;当一个对象的状态发生变化时&#xff0c;所有依赖于它的对象都会得到通知并自动更新。这个模式也被称为发布-订阅模式…

Android stdio的Gradle菜单栏无内容问题的解决方法

右边Gradle菜单栏里没有Tasks选项内容的问题 正常情况↓ 如果这个问题如果无法解决的话&#xff0c;Gradle打包就只能通过控制台输入命令来解决&#xff0c;但这无疑是把简单问题复杂化了&#xff0c;我们来看看怎么解决这个问题吧。 这里有几个方法提供&#xff0c;可以自行选…

Ipa Guard软件介绍:启动界面和功能模块全解析,保护你的iOS应用源码

ipaguard界面概览 ipaguard界面分左右2块&#xff1a;左边菜单导航栏&#xff0c;右边的功能区 左侧菜单&#xff1a;按模块分成启动界面&#xff0c;代码模块&#xff0c;文件模块&#xff0c;重签名与测试模块 右侧主功能区会随着功能变化&#xff0c;但是整体分3块&#xf…

Webpack 基础入门以及接入 CSS、Typescript、Babel

一、什么是 Webpack Webpack 是一款 JS 模块化开发的技术框架&#xff0c;其运作原理是将多个 JS 文件关联起来构成可运行的应用程序。 Webpack 拥有丰富的 plugins / loaders 插件生态圈&#xff0c;可以让 js 识别不同的语言如 .css, .scss, .sass, .json, .xml, .ts, .vue…

揭秘:机构招生电子传单制作的五个黄金法则

机构招生微传单制作一直都是让很多人在意的事情。一款好的微传单不仅可以吸引更多的学生&#xff0c;还可以省去很多招生工作的时间和精力。但是&#xff0c;很多人却不知道如何制作一款精美的微传单。下面就让我们来学习一下如何制作一款机构招生的微传单吧。 首先&#xff0c…

聊聊Go与依赖注入

如果你读过Robert C. Martin[1]的《敏捷软件开发&#xff1a;原则、模式与实践》[2](书的封皮见下图)&#xff0c;那么你一定知道经典的SOLID设计原则[3]中的“D”&#xff1a;依赖倒置原则&#xff08;Dependency Inversion Principle, DIP&#xff09;。 依赖倒置原则是面向对…

node版本问题:Error: error:0308010C:digital envelope routines::unsupported

前言 出现这个错误是因为 node.js V17及以后版本中最近发布的OpenSSL3.0, 而OpenSSL3.0对允许算法和密钥大小增加了严格的限制&#xff0c;可能会对生态系统造成一些影响. 在node.js V17以前一些可以正常运行的的应用程序,但是在 V17 及以后版本可能会抛出以下异常: 我重装系…

华为云云耀云服务器L实例评测|部署在线图表和流程图绘制工具drawio

华为云云耀云服务器L实例评测&#xff5c;部署在线图表和流程图绘制工具drawio 一、云耀云服务器L实例介绍1.1 云服务器介绍1.2 优势及其应用场景1.3 支持镜像 二、云耀云服务器L实例配置2.1 重置密码2.2 服务器连接2.3 安全组配置 三、部署 drawio3.1 drawio 介绍3.2 Docker 环…