- 浏览: 958947 次
- 性别:
- 来自: 江西上饶
文章分类
- 全部博客 (460)
- p.spring (56)
- p.maven (20)
- p.ant (17)
- p.jee (18)
- p.jse (33)
- p.ofbiz (31)
- p.软件工程 (8)
- p.struts2 (5)
- p.hibernate (5)
- linux (25)
- 设计模式 (2)
- p.javascript (11)
- 硬件 (1)
- p.jsp (2)
- p.windows批处理 (1)
- 操作系统问题 (5)
- 算法 (1)
- p.mysql (7)
- p.sql (5)
- p.c (1)
- google产品 (0)
- 内存 (1)
- p.struts (1)
- p.freemarker (7)
- p.css (4)
- p.log4j (10)
- p.html (3)
- 淘宝产品 (0)
- 其他 (3)
- 编译器 (0)
- svn (4)
- p.spring.security (11)
- 图形 (0)
- p.xml (1)
- p.ssh (0)
- p.jquery (4)
- p.jdbc (3)
- p.flex (0)
- p.c++ (0)
- p.c#Net (0)
- p.assembly (0)
- p.sqlserver (0)
- p.其他 (3)
- p.webwork (21)
- p.wap (12)
- p.cglib (1)
- p.jee服务器 (11)
- windows (2)
- p.iphone (1)
- p.java.分布式与集群 (2)
- p.ibatis (16)
- p.eclipse (5)
- 架构 (2)
- http协议 (5)
- 我的个人标准 (2)
- 多线程 (1)
- 奇怪问题 (5)
- p.jira (13)
- p.httpclient (1)
- 服务器.apache (11)
- 安全防范 (1)
- p.PODAM (1)
- p.junit (16)
- fop (2)
- 硬盘安装 (1)
- powerdesigner (0)
- 单元测试 (1)
- apache commons (4)
- tomcat+apache集群 (10)
- 各类诡辩 (1)
- 安卓 (8)
- qvod (1)
- java编程基础知识考试考点及答案 (0)
- 工作总结 (4)
- oracle (0)
- spring的util工具 (3)
- json (2)
- maven (3)
- jms (19)
- p.bat (3)
- hadoop (2)
- git (3)
- nginx (1)
- p.移动开发 (1)
- shiro (3)
- 游戏破解 (1)
- react-native (7)
- ios开发 (1)
- webmagic (6)
- socks5 (1)
最新评论
-
weituotian:
说的不好,没人看的
公司系统中的菜单功能和权限功能 -
石不易:
非常详细的注解~
绑定端口和IP,Listen 与VirtualHost指令 -
spring_springmvc:
spring mvc demo教程源代码下载,地址:http: ...
spring mvc -
liyixing1:
PandaDONG 写道谢谢你啊,我已经下下来了,只是还有很多 ...
jira war安装 -
liyixing1:
PandaDONG 写道谢谢你啊,我已经下下来了,只是还有很多 ...
jira war安装
特点
1.通过话题通道进行交互。
2.可以有多个订阅者,订阅者可以是持久,非持久的,动态的。
3.发布者不知道订阅者是否收到消息。
4.一般情况不要求订阅者进行回复。
5.订阅者只能收到在其运行后发布的消息。
相关接口
长期订阅者
在订阅后,可以终止本身的运行,下次运行后依然可以收到消息,这很像email的模式,该模式不是很常用,会消耗更多资源。可以通过配置,或者jms中间件的管理界面,或者调用
TopicSubscriber subscriber = tSession.createDurableSubscriber(topic, "Borrower1");方式。这是动态创建方式。
动态的创建方式可以通过Session.unsubscribe来退订。当然在退订之前,需要通过subscriber.close();方法先关闭订阅者,然后再调用Session.unsubscribe方法来退订,否则会有异常抛出。
动态主题
推荐方式是临时主题,TopicSession的createTemporaryTopic
该主题只是在connection内有效。
1.通过话题通道进行交互。
2.可以有多个订阅者,订阅者可以是持久,非持久的,动态的。
3.发布者不知道订阅者是否收到消息。
4.一般情况不要求订阅者进行回复。
5.订阅者只能收到在其运行后发布的消息。
相关接口
General API | Publish-and-subscribe API |
ConnectionFactory | TopicConnectionFactory |
Destination | Topic |
Connection | TopicConnection |
Session | TopicSession |
MessageConsumer | TopicPublisher |
MessageProducer | TopicSubscriber |
长期订阅者
在订阅后,可以终止本身的运行,下次运行后依然可以收到消息,这很像email的模式,该模式不是很常用,会消耗更多资源。可以通过配置,或者jms中间件的管理界面,或者调用
TopicSubscriber subscriber = tSession.createDurableSubscriber(topic, "Borrower1");方式。这是动态创建方式。
动态的创建方式可以通过Session.unsubscribe来退订。当然在退订之前,需要通过subscriber.close();方法先关闭订阅者,然后再调用Session.unsubscribe方法来退订,否则会有异常抛出。
动态主题
推荐方式是临时主题,TopicSession的createTemporaryTopic
该主题只是在connection内有效。
发表评论
-
activemq in action 翻译
2014-11-20 10:45 856http://jackyin5918.iteye.com/ca ... -
高并发
2014-11-16 21:58 1596垂直扩展 垂直扩展是一种用于增加单个ActiveMQ代理连接数 ... -
删除不活动的队列(Delete Inactive Destinations)
2014-11-16 16:41 1352一般情况下,ActiveMQ的queue在不使用之后,可以通过 ... -
代理网络中消息传递
2014-11-13 21:21 791常见的方式是让所有客户端都连接到一个中心代理,而这不是使用消息 ... -
企业部署
2014-11-13 14:26 688主从备份方式 多个代理 ... -
REST和AJAX
2014-11-12 17:01 789REST 通过activemq提供的servlet < ... -
安全机制
2014-10-15 15:22 1247ActiveMQ中所有安全相关的概念都是通过插件的形式实现的. ... -
与spring结合
2014-10-15 14:06 791在Spring中嵌入ActiveMQ有四种方式:纯Spring ... -
activemq 消息存储
2014-10-13 17:03 2341JMS规范支持两种方式分发消息:持久化和非持久化。Active ... -
ActiveMQ配置 连接activemq
2014-10-08 10:13 39061activemq代理 JMS代理(如ActiveMQ bro ... -
ActiveMQ简介
2014-10-08 09:49 775支持跨平台跨语言等特点,由于它是用JAVA实现的一套中间件,跨 ... -
jms-spring
2014-09-30 10:37 935同步接收和同步发送的情况(使用JNDI) 异步接收消息 ... -
jms-事物
2014-09-29 16:52 681JMSRedelivered可以检查消 ... -
过滤器与消息选择器
2014-09-28 23:08 704过滤器 String filter = &quo ... -
jms-点对点
2014-09-27 23:45 983在点对点模式中,消息创建者称为发送者,消息消费者称为接收者。 ... -
jms-message对象
2014-09-26 14:40 1204message必须通过session创建,以便完成对应的初始化 ... -
jms基础,与例子
2014-09-24 22:14 1012MOM,面向消息中间件的交互模式 各个系统间,可以认为 ... -
jms的两种模式
2014-09-23 22:49 2275JMS有两种通信方式 P2P,点对点 方式和 发布/订阅模式P ...
相关推荐
在这个项目中,我们关注的是RabbitMQ的C++客户端库的封装以及如何实现发布订阅模式。 首先,我们要了解RabbitMQ的基本概念。RabbitMQ是一个消息代理,它接收和转发消息,充当生产者和消费者之间的桥梁。生产者是...
发布订阅模式是一种设计模式,常用于前端开发中解决模块间通信和异步处理的问题,以降低模块间的耦合度。这种模式将事件处理抽象为一个中心调度者,订阅者通过注册事件监听器来接收特定事件的通知,而发布者则通过...
基于Redis的消息队列之发布订阅模式 基于Redis的消息队列之发布订阅模式是指使用Redis作为消息队列的中间件,实现消息的发布和订阅。该模式下,消息的生产者将消息发布到Redis中,而消费者则可以从Redis中订阅和...
# 基于发布订阅模式的实时消息系统 ## 项目简介 本项目是一个基于发布订阅模式的实时消息系统,旨在提供一个高效、可靠的消息传递机制。通过该系统,用户可以轻松实现消息的发布和订阅功能,适用于多种实时通信场景...
发布订阅模式(Publish/Subscribe,简称Pub/Sub)是一种软件设计模式,它允许对象之间进行解耦通信。在JavaScript中,这种模式通常通过事件监听和触发来实现。在本例中,`pubAndSub.js`是一个封装了发布订阅模式的库...
Fig(无花果)项目是一款基于MQTT协议的发布订阅模式异步数据处理框架,旨在构建一个玩具级微服务框架。该框架源码采用Xtend语言编写,并兼容Java、JavaScript、Python、Shell、HTML、CSS、Ruby等多种编程语言。项目...
发布-订阅者模式,也称为观察者模式,是软件设计模式中的一种常用模式,它定义了对象之间的一对多依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都会得到通知并自动更新。这种模式广泛应用于事件驱动...
javaScript发布订阅模式代码实现思路,有平台,发布者,订阅者
本资源重点探讨的是发布订阅模式(也称为观察者模式)在C#窗体间数据传递的应用。 发布订阅模式是一种行为设计模式,它定义了对象之间的一对多依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都会得到...
发布订阅模式通过一个中间媒介,通常称为事件总线(Event Bus)或调度器(Dispatcher),来连接发布者和订阅者。这种松耦合的方式使得系统更易于扩展和维护。 在Java中实现发布订阅模型,我们可以利用Java的`java....
4. **发布订阅模式**:在HSF中,发布订阅模式主要是通过事件驱动的方式来实现。服务提供者可以通过HSF的EventTemplate发布事件,而服务消费者则可以订阅这些事件。当事件发生时,HSF会自动将事件分发给所有订阅者。 ...
主要技术包括Vue3.0、Tornado6.1以及Redis的发布订阅模式。接下来,我们将详细探讨这些技术及其在聊天系统中的应用。 首先,Vue3.0是前端框架的最新版本,它提供了性能优化、组件设计改进和更灵活的API。Vue3引入了...
航天测控数据交换系统在现代航空航天领域扮演着至关重要的角色,它通过条件约束发布订阅模式实现了高效、实时的信息传输。这种模式是分布式系统中的一个重要概念,尤其在处理大量实时数据和事件驱动的应用中,如航天...
发布订阅者模式是一种软件设计模式,它允许对象之间进行解耦,使得发送方(发布者)无需知道接收方(订阅者)的具体实现,只需要知道如何发布事件或消息,而订阅者则可以自主选择关注哪些事件并进行处理。...
本文将深入探讨原生JS实现的发布订阅模式,以及如何参考jQuery的callbacks模块来构建类似功能。 首先,我们需要理解回调函数的核心概念。回调函数是一种将函数作为参数传递给另一个函数,然后在适当的时间由该函数...
springboot整合rabbit实践操作(包括简单模式、工厂队列模式、发布订阅模式、路由模式、topic模式的使用)
使用C#封装的RabbitMQ队列,支持工作队列模式和发布订阅模式,只要在配置文件中配置RabbitMQ服务器相关信息,再在项目中引用进封装好的RabbitMQService类库,就能轻松操作RabbitMQ的工作队列模式和发布订阅模式
观察者模式,也被称为发布订阅模式,是一种设计模式,它允许对象在状态改变时自动通知其他依赖于它的对象。在JavaScript中,这种模式通常通过事件处理来实现,它提供了松散耦合的方式,使得对象之间可以相互通信,而...