Spring STOMP-消息处理流程

一旦STOMP的接口被公布,Spring应用程序就成为连接客户端的STOMP代理。本节描述服务端消息处理的流程。

spring-messaging模块包含消息类应用的基础功能,这些功能起源于Spring Integration项目。并且,后来被提取整合到Spring框架,以便在更多的Spring项目和应用场景中更广泛地使用。下面列出了模块里包含的消息抽象:

  • Message: 消息的简单表示,包括头部和有效载荷。
  • MessageHandler: 消息处理器。
  • MessageChannel: 发送消息的渠道,实现生产者和消费者的解耦。
  • SubscribableChannel: 带有MessageHandler订阅者的MessageChannel
  • ExecutorSubscribableChannel: 使用Executor 线程池来发送消息的SubscribableChannel

Java配置(即@EnableWebSocketMessageBroker)和XML命名空间配置(即<websocket:message-broker>)使用前面的组件来组装消息工作流。下面的图表显示了,在使用程序内置的消息代理时用到的组件:

上图展示了三个消息通道:

  • clientInboundChannel: 用于接收来自WebSocket客户端的消息。
  • clientOutboundChannel: 用于将服务器的消息发送到WebSocket客户端。
  • brokerChannel: 用于从服务器端应用程序向消息代理发送消息。

下图展示了配置外部代理(如RabbitMQ)用于管理订阅和广播消息时用到的组件:

前面两幅图的主要区别是,第二幅图使用了“broker relay”,通过TCP链接将消息发送到外部的STOMP代理,并将消息从代理发送到订阅的客户端。

当从WebSocket连接接收到消息时,它们被解码为STOMP帧,转换为Spring Message 对象表示,并发送到clientInboundChannel进行进一步处理。例如,目的地头部以/app开头的STOMP消息可能会被路由到控制器中带了@MessageMapping 注解的方法,而/topic/queue 开头的消息可能会直接路由到消息代理。

带了@Controller 注解的程序,在处理客户端发的STOMP消息后,可以通过brokerChannel向消息代理发送消息,代理通过clientOutboundChannel将消息广播给匹配的订阅者。同一个controller也可以对HTTP请求做出相同的响应,因此客户端可以执行一个HTTP POST请求,处理请求的@PostMapping方法可以向消息代理发送消息,然后广播给订阅的客户端。

我们通过一个简单的例子来熟悉流程。下面是配置服务端的示例:

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {@Overridepublic void registerStompEndpoints(StompEndpointRegistry registry) {registry.addEndpoint("/portfolio");}@Overridepublic void configureMessageBroker(MessageBrokerRegistry registry) {registry.setApplicationDestinationPrefixes("/app");registry.enableSimpleBroker("/topic");}
}@Controller
public class GreetingController {@MessageMapping("/greeting")public String handle(String greeting) {return "[" + getTimestamp() + ": " + greeting;}
}

前面的示例支持以下流程:

  1. 客户端连接到http://localhost:8080/portfolio,一旦建立WebSocket连接,STOMP帧就开始在它上面传输。
  2. 客户端发送一个destination消息头值为/topic/greeting的SUBSCRIBE帧。一旦接收并解码,消息被发送到clientInboundChannel,然后被路由到消息代理,代理存储了客户端订阅信息。
  3. 客户端向/app/greeting发送一个SEND帧。/app前缀的消息会路由到带注解的控制器上。在删掉了/app前缀之后,destination值剩余的部分/greeting 会映射到GreetingController中的@MessageMapping方法上。
  4. GreetingController返回的值被转换成一个Spring Message 对象,方法的返回值放入消息的payload,消息的默认destination消息头是/topic/greeting(从输入的destination派生而来,规则是用/topic替换/app)。返回的消息被发送到brokerChannel并由消息代理处理。
  5. 消息代理找到所有匹配的订阅者,并通过clientOutboundChannel向所有订阅者发送一个MESSAGE帧,发送前消息被编码为STOMP帧,并通过WebSocket连接发送。

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

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

相关文章

LeetCode - 0001 两数之和

题目地址&#xff1a;https://leetcode.cn/problems/two-sum/description/ 我&#xff1a;你好&#xff0c;面试官&#xff0c;我对算法了解的不多&#xff0c;只刷过LeetCode第一题&#xff0c;你不要问的太难了&#xff0c;好&#xff0c;我准备好了。 面试官&#xff1a;啊…

Spring Boot 调用外部接口的几种方式

Spring Boot 调用外部接口的几种方式 在微服务架构中&#xff0c;服务间的调用是不可或缺的环节。Spring Boot 为开发者提供了多种方式来实现这一任务&#xff0c;这个文章将为你详细介绍这些方式。 一、使用RestTemplate RestTemplate是 Spring Boot 早期版本中常用的 REST 客…

十个最适合论文写作的GPTs及其应用

文章目录 一、GPTs让一切皆有可能二、最适合论文写作的GPTs及其应用1、[Paper Search Engine](https://chat.openai.com/g/g-9v5gHG9Bo)2、[Academic Paper Specialist&#xff08;学术论文撰写专家&#xff09;](https://chat.openai.com/g/g-jryw3pfsH)3、[Paper Connect 论文…

【八十七】【算法分析与设计】单调栈全新版本,右大于,左小于右小于等于,739. 每日温度,907. 子数组的最小值之和

739. 每日温度(右大于) 给定一个整数数组 temperatures &#xff0c;表示每天的温度&#xff0c;返回一个数组 answer &#xff0c;其中 answer[i] 是指对于第 i 天&#xff0c;下一个更高温度出现在几天后。如果气温在这之后都不会升高&#xff0c;请在该位置用 0 来代替。 示…

微信公众号接入chatGPT自动回复(2)

微信公众平台 配置自动回复的服务器 application.properties中的配置 验证服务器接口配置 其实就两个接口(相同的url地址,只不过请求方式不一样) 1.验证接口(get请求) 2.自动回复接口(post请求) 完整代码 这个地址就是上面URL配置的地址 如果使用Nginx的话自动配置 将该代…

[原创](Modern C++)现代C++的字符串与Windows API交互的正确方式.

[简介] 常用网名: 猪头三 出生日期: 1981.XX.XX QQ联系: 643439947 个人网站: 80x86汇编小站 https://www.x86asm.org 编程生涯: 2001年~至今[共22年] 职业生涯: 20年 开发语言: C/C、80x86ASM、PHP、Perl、Objective-C、Object Pascal、C#、Python 开发工具: Visual Studio、D…

11个免费的 android数据恢复应用程序功能分析

在手机上丢失数据是一个很大的错误。但是&#xff0c;在这种情况下&#xff0c;除了惊慌失措之外&#xff0c;最好开始使用android数据恢复应用程序搜索以查找将其取回的方法。您可以检查手机的备份存储以在Android上进行数据恢复&#xff0c;但是如果数据仍然无处可寻&#xf…

@PostConstruct

PostConstruct initializeBean方法–> PostProcessor.postProcessMergedBeanDefinition --> InitDestroyAnnotationBeanPostProcessor.postProcessBeforeDestruction 被PostConstruct注解的方法会在Bean初始化的时候被调用&#xff0c;如下图&#xff1a; 继承关系如下…

jenkins连接ubuntu普通用户节点

1.创建credentials 2.创建node 3.在jenkins服务器还需要进行的操作&#xff08;jenkins服务器中&#xff09; mkdir /var/lib/jenkins/.ssh ssh-keyscan -H 192.168.110.204 >> /var/lib/jenkins/.ssh/known_hosts chown -R jenkins:jenkins /var/lib/jenkins/.ssh/ 4.…

相交链表(数据结构)

160. 相交链表 - 力扣&#xff08;LeetCode&#xff09;https://leetcode.cn/problems/intersection-of-two-linked-lists/description/ 题目 解决思路 1&#xff0c;找到相交的点 相交链表的关键也就是找到相交的点&#xff0c;所以我们需要首先判断有没有相交的节点&#…

程序员必读书籍推荐

在快速发展的编程领域&#xff0c;不断学习和积累是每位程序员的必修课。以下是几本对于程序员来说&#xff0c;不容错过的必读书籍。 《代码大全》是一本编程界的经典之作&#xff0c;书中不仅详细介绍了编程的最佳实践&#xff0c;还深入探讨了软件构建的艺术。对于想要提升…

最新的云渲染100活动有哪些?渲染100邀请码1a12

随着科技的进步&#xff0c;云渲染已经成为设计行业的必备工具&#xff0c;各个云渲染平台为了吸引用户也推出各种各样的活动&#xff0c;今天我们以广受好评的渲染100为例&#xff0c;来说下它们的活动体系。 1、新用户活动 渲染100对新用户很友好&#xff0c;提供了充足的测…

K-RTD01和利时FW248中控卡件

K-RTD01和利时FW248中控卡件。 系统概述 的全称为保护工程师站及录波分析后台”是利用现代计算机和网络技术&#xff0c;K-RTD01和利时FW248中控卡件。实时收集变电站运行和故障信息&#xff0c;并通过对变电站的故障信息进行综合分析&#xff0c;K-RTD01和利时FW248中控卡件。…

Ps 滤镜:便条纸

Ps菜单&#xff1a;滤镜/滤镜库/素描/便条纸 Filter Gallery/Sketch/Note Paper 便条纸 Note Paper滤镜用于模拟手工纸张的质感和视觉效果。此滤镜将图像简化并添加浮雕和颗粒效果&#xff0c;使图像看起来像是在手工制作的纸上绘制或打印。 “便条纸”滤镜通过结合使用浮雕效果…

【代码】matlab调用COM端口获取传感器数据

参考链接 原始代码 clc clear close all fclose(instrfind)%先关闭所有串口 % scom serial(COM7); %建立串口对象函数&#xff08;需要手动和自己电脑的端口匹配&#xff09; fclose(scom); %关闭串口设备对象 scom.InputBufferSize 512;%输入缓冲区 scom.O…

为什么一个项目在idea中的配置文件设置端口号为8000,在vue中设置端口号为8080,项目可以运行成功?

在学习一个前后端分离开发的项目中&#xff0c;突然发现该项目在idea的配置文件中&#xff0c;设置的端口号为8000 application.properties&#xff1a; server.port8000 而在vue的配置文件中&#xff0c;设置的项目端口号为8080&#xff1a; devServer: {port: 8080,clien…

Copilot for Microsoft 365 扩充新增 16 种语言

最近&#xff0c;微软公司发布公告&#xff0c;进一步扩大 Copilot for Microsoft 365 语言支持&#xff0c;新增 16 种&#xff0c;支持的语言总数达到 25 种。 新支持的语言如下&#xff1a; 阿拉伯语 捷克语 丹麦语 荷兰语 芬兰语 希伯来语 匈牙利语 韩语 挪威语&am…

Sass详解:CSS预处理器的强大之处

Sass详解&#xff1a;CSS预处理器的强大之处 Sass&#xff0c;全称为Syntactically Awesome Style Sheets&#xff0c;是一种CSS预处理器&#xff0c;它扩展了CSS的功能&#xff0c;提供了变量、嵌套规则、混合&#xff08;Mixins&#xff09;、函数等强大的编程特性&#xff…

生活中的网络

加zkhengyang&#xff0c;可申请进数字音频系统研究开发交流答疑群(课题组) 最熟悉的是计算机网络&#xff0c;集线器&#xff0c;交换机&#xff0c;网桥&#xff0c;路由器&#xff0c;电脑主机&#xff0c;同轴电缆&#xff0c;双绞线&#xff0c;光纤等组成。 电视机网络…

网络安全科普:保护你的数字生活

# 网络安全科普&#xff1a;保护你的数字生活 ## 引言 在数字化时代&#xff0c;网络安全已成为每个人都必须面对的问题。从个人隐私保护到金融交易安全&#xff0c;网络的安全性直接关系到我们的日常生活。因此&#xff0c;普及网络安全知识&#xff0c;提高公众的网络安全意…