- 综合排序
- 最热优先
- 最新优先
- 来自专栏Goboy
发布-订阅模式思考
messageBroker; public BathCenter(MessageBroker messageBroker) { this.messageBroker = messageBroker messageBroker) { messageBroker.subscribe(topic, this); } public void unsubscribe(String topic, MessageBroker messageBroker) { messageBroker.unsubscribe(topic, this); } public messageBroker = new MessageBroker(); BathCenter bathCenter = new BathCenter(messageBroker); Customer zhangSan = new Customer("张三"); zhangSan.subscribe("discount", messageBroker);
1.1K21编辑于 2024-07-26 - 来自专栏Goboy
异步消息队列设计与实现 · 构建高效解耦的平台消息通信机制
在电商平台中，我们的消息发布/订阅机制是通过一个 MessageBroker 实现的。MessageBroker 管理着不同类型的消息及其订阅者，并将发布的消息分发给所有订阅者。 MessageBroker 类在 MessageBroker 中，使用了一个映射表 subscribers 来存储消息类型与其对应的订阅者列表。 每当消息被发布时，MessageBroker 会遍历订阅者列表并通知每个订阅者处理消息。 (MessageBroker messageBroker) { this.messageBroker = messageBroker; this.messageQueue = messageBroker = new MessageBroker(); // 创建订阅者 MyMessageSubscriber paymentSubscriber =
1.2K20编辑于 2025-01-20 - 来自专栏云计算linux
Flex与外部的数据通信
Integration 需要的软件环境： Ø Java 5 或更高 Ø Spring 2.5.6 或更高 Ø BlazeDS 3.2 或更高 Spring BlazeDS Integration 特征 Ø MessageBroker （BlazeDS 的核心组件）被配置为 Spring 管理的 Bean Ø Flex 客户端发出的 HTTP 消息通过 Spring 的 DispatcherServlet 路由给 MessageBroker servlet> <servlet-mapping> <servlet-name>Spring MVC Dispatcher Servlet</servlet-name> <url-pattern>/messagebroker schema/flex http://www.springframework.org/schema/flex/spring-flex-1.0.xsd"> </beans> 3）为了把请求路由给 MessageBroker -- MessageBroker Servlet --> <servlet> <servlet-name>Spring MVC Dispatcher Servlet</servlet-name>
65310编辑于 2024-12-17 - 来自专栏Goboy
面试大揭秘：发布订阅与观察者模式的区别
大规模分布式系统 GUI事件监听、模型视图同步等小规模系统实现复杂度 较高，需要引入消息代理或事件总线 较低，通过对象引用和方法调用实现 示例代码发布订阅模式class MessageBroker subscriber.update(data)class Subscriber: def update(self, data): print(f"Received data: {data}")broker = MessageBroker
60310编辑于 2024-07-30 - 来自专栏JAVA葵花宝典
Springboot整合websocket实现一对一消息推送和广播消息推送
responseMessage; } 配置websocket @Configuration // @EnableWebSocketMessageBroker注解用于开启使用STOMP协议来传输基于代理（MessageBroker
3.5K10发布于 2021-01-04 - 来自专栏鸿的学习笔记
流处理
第二个传递消息的方式就是通过中介messagebroker，采用这种方式就不需要考虑producer和consumer的网络问题，也可以把消息的存储在broker，相应的trade-off就是放弃了producer
54910发布于 2018-08-06 - 来自专栏业余草
Springboot整合Websocket实现一对一消息推送和广播消息推送
responseMessage; } 配置websocket @Configuration // @EnableWebSocketMessageBroker注解用于开启使用STOMP协议来传输基于代理（MessageBroker
2.3K10发布于 2020-06-23 - 来自专栏狗哥的 Java 世界
SpringBoot 实战 (十七) | 整合 WebSocket 实现聊天室
@Configuration // @EnableWebSocketMessageBroker 注解用于开启使用 STOMP 协议来传输基于代理（MessageBroker）的消息，这时候控制器(controller
1.8K20发布于 2019-10-17 - 来自专栏狗哥的 Java 世界
SpringBoot 实战 (十六) | 整合 WebSocket 基于 STOMP 协议实现广播消息
WebSocketMessageBrokerConfigurer 接口，注册一个 STOMP 节点，配置一个广播消息代理 @Configuration // @EnableWebSocketMessageBroker注解用于开启使用STOMP协议来传输基于代理（MessageBroker
5.1K40发布于 2019-10-17 - 来自专栏电光石火
springboot整合websocket实现消息推送
org.springframework.web.socket.config.annotation.StompEndpointRegistry; @Configuration // @EnableWebSocketMessageBroker注解用于开启使用STOMP协议来传输基于代理（MessageBroker
82510发布于 2019-12-07 - 来自专栏技术汇总专栏
Agent 间消息太乱？试试基于 Topic 的角色级路由优化方案
四、架构设计：Topic+Router的协作方式一个典型的多Agent通信优化架构如下（文字描述）：1.架构分层Agent层：负责具体任务处理MessageBroker层：Topic管理、消息过滤Router
30310编辑于 2025-12-11 - 来自专栏电光石火
springboot整合websocket实现消息推送
org.springframework.web.socket.config.annotation.StompEndpointRegistry; @Configuration // @EnableWebSocketMessageBroker注解用于开启使用STOMP协议来传输基于代理（MessageBroker
2.8K51发布于 2018-06-20 - 来自专栏web全栈
RabbitMQ学习笔记（一）——消息中间件入门
Broker:接收和分发消息的应用，RabbitMQ就是MessageBroker b. Virtual Host:虚拟Broker，将多个单元隔离开 c.
75020编辑于 2022-09-26 - 来自专栏超级架构师
「微服务架构」面向CTO的微服务设计模式：API网关、前端的后端等
对于内部通信，一些最流行的模式包括REST、gRPC、messagebroker或远程过程调用。
75910发布于 2020-07-20 - 来自专栏人工智能应用
利用腾讯云MCP提升跨平台协作效率的实践与探索
self.retry_with_backoff()消息代理服务使用RabbitMQ实现跨平台异步通信，支持高并发消息路由代码示例:from concurrent.futures import ThreadPoolExecutorclass MessageBroker
52520编辑于 2025-05-16 - 来自专栏云计算linux
Cairngorm开发框架
function ProService(){ ro=new RemoteObject("biz"); ro.endpoint="http://localhost:8080/CairngormDemo/messagebroker RemoteObject id="productService" destination="productServiceImpl" endpoint="http://localhost:8400/store/messagebroker RemoteObject id="productService" destination="productServiceImpl" endpoint="http://localhost:8080/sj51/messagebroker
47100编辑于 2024-12-17 《人工智能导论》第 9 章 智能体与多智能体系统详解
self.receive_message(message) responses.append(response) return responses class MessageBroker agent3 = CommunicationAgent("A3") agents = [agent1, agent2, agent3] # 创建消息代理 broker = MessageBroker
25810编辑于 2026-01-21- 来自专栏云计算linux
Flex应用性能优化
远程获取基本权限--> <mx:RemoteObject id="initRight" destination="rightbiz" endpoint="http://localhost:8400/jxc4/<em>messagebroker</em> 远程获取基本权限--> <mx:RemoteObject id="initRight" destination="rightbiz" endpoint="http://localhost:8400/jxc4/<em>messagebroker</em> )"/> <mx:RemoteObject id="userremoting" destination="userbiz" endpoint="http://localhost:8400/jxc4/<em>messagebroker</em>
92710编辑于 2024-12-17 - 来自专栏大数据文摘
为什么大数据应用需要敏捷？敏捷大数据方法论
各类微服务通过REST、RPC等轻量级通信机制和MessageBroker等消息服务进行交互和联系[14]，构建微服务簇网络，并通过服务路由进行统一管理和调度。
1.2K40发布于 2018-05-24
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号