ActiveMQ群集,持久订阅者和虚拟主题可助您一臂之力
因此,您希望跨分布式主题使用ActiveMQ进行发布-订阅,并且要可靠。 您可以只使用永久订阅,对不对? 可以,但是,如果将群集与ActiveMQ一起使用,则可能会遇到意外行为。 我最近在一个客户端上,我注意到了这一行为,并且还注意到在使用Weblogic JMS集群时也存在相同的行为。 那么有什么问题,ActiveMQ可以解决什么问题呢? 好吧,我假设您阅读了标题,所以您可能有个主意……但我还是会继续前进……
考虑这种情况。 您有经纪人A和经纪人B。它们在两个方向上都联网在一起,形成一个完全网格类型的经纪人网络 。 又名,群集。 然后,您将使用故障转移URL failvoer:(tcp://hostA,tcp://hostB)
拥有一个订户FOO。 这意味着订户将从故障转移传输中的节点列表中随机选择一个URL,然后连接到该代理。 到目前为止,一切都很好。 假设故障转移URL选择了要连接的代理B,订阅者在代理B上创建了对主题TEST.TOPIC
的持久订阅。在TEST.TOPIC
,代理网络将确定B上有一个新的TEST.TOPIC
。因此,如果经纪人A上有任何生产者,那么经纪人A应该将消息转发给经纪人B(消费者在哪里)。
现在让我们说订户FOO决定断开与代理B的连接。这是很好的,因为这是持久预订,因此消息应该保留,并且如果订户FOO返回,它应该能够检索传递到主题TEST.TOPIC
任何消息。 TEST.TOPIC
不在时。 但是如果订户FOO使用故障转移传输直接连接到代理A,会发生什么? 最终将创建一个新的持久订阅(它不会使用与网络创建的持久订阅相同的..,因为该用户与网桥绑定),但是它将无法访问代理中可能存在的任何消息B.当制片人发送更多的消息给A,它也将尝试着给经纪人B的是在那里用户原是 。 现在想象一下可以连接,断开连接并重新连接到集群中不同代理的多个订阅服务器。 您最终将导致订阅泄漏,到处都是消息丢失。 uck 这同样适用于真实的故障情况,在这种情况下,订户FOO不会自愿断开连接,而是代理B崩溃,并且订户FOO被迫重新连接到代理A。您仍然会丢失消息。
好吧,事实证明,这种行为在具有分布式主题的Weblogic和集群JMS服务器上也存在(大致等同于我上面描述的代理网络)。 那么,我们将不能可靠地进行分布式发布订阅吗? 好吧,我不确定WLS如何解决它,但是ActiveMQ有一个很棒的解决方案,称为Virtual Topics 。 对于分布式pup-sub来说,这是一个很棒的功能,但即使在单代理部署中,它也克服了持久订阅者的限制。
有什么限制?
考虑一下…您正在使用主题TEST.TOPIC.
的持久订阅者TEST.TOPIC.
事实证明,对消息的处理要花很长时间,因此您希望让另一个订户在同一消息通道上侦听以“平衡”工作负载。 尝试一下。 您会很快发现JMS规范不允许这样做,因为持久订阅者必须具有唯一的clientId
和durableName
并且不能有多个订阅者在侦听相同的消息流。
那么,您如何在池化连接的应用程序服务器中部署订户。 您正在尝试在多个持久订户之间共享连接。 好了,您将再次遇到持久订阅者clientId和持久名称的限制。
回到我们的分布式发布订阅问题。 如果使用虚拟主题,则可以解决我上面描述的问题。 虚拟主题在幕后使用队列(对于消费者来说……请阅读虚拟主题上的Apache文档,它有一些很好的示例),使用队列,您可以将消息重播给您(例如,当订户重新连接到A时,它是消息不会丢失,因为可以重播消息),或者如果B代理由于某种原因而发生故障(失败),则可以让从属服务器在其位置等待重播否则可能丢失的消息。 有关更多详细信息,请查看有关具有持久订阅者的分布式主题的ActiveMQ常见问题解答,因为我现在就开始编写它。
参考: ActiveMQ群集,持久订阅者和虚拟主题,可从Christian Posta Software博客的JCG合作伙伴 Christian Posta那里抢救出来。
翻译自: https://www.javacodegeeks.com/2013/02/activemq-clustering-durable-subscribers-and-virtual-topics-to-the-rescue.html
ActiveMQ群集,持久订阅者和虚拟主题可助您一臂之力相关推荐
- activemq 持久订阅_ActiveMQ群集,持久订阅者和虚拟主题可助您一臂之力
activemq 持久订阅 因此,您希望使用ActiveMQ跨分布式主题进行发布-订阅,并且要可靠. 您可以使用永久订阅,对吗? 可以,但是,如果您将群集与ActiveMQ一起使用,则可能会遇到意外的 ...
- JMS学习七(ActiveMQ之Topic的持久订阅)
非持久化订阅持续到它们订阅对象的生命周期.这意味着,客户端只能在订阅者活动时看到相关主题发布的消息.如果订阅者不活动,它会错过相关主题的消息.如果花费较大的开销,订阅者可以被定义为durable(持久 ...
- ActiveMQ持久订阅设置
在JMS中,Topic实现publish和subscribe语义.一条消息被publish时,它将发到所有感兴趣的订阅者,所以零到多个subscriber将接收到消息的一个拷贝.但是在消息代理接收到消 ...
- JMS学习(五)--ActiveMQ中的消息的持久化和非持久化 以及 持久订阅者 和 非持久订阅者之间的区别与联系...
一,消息的持久化和非持久化 ①DeliveryMode 这是传输模式.ActiveMQ支持两种传输模式:持久传输和非持久传输(persistent and non-persistent deliver ...
- ActiveMq持久订阅必须指定clientId以及设置clientId源码分析
创建持久订阅时的代码: @Overridepublic TopicSubscriber createDurableSubscriber(Topic topic, String name, String ...
- 007_JMS中的持久订阅
1. 持久订阅时, 客户端需要首先向JMS提供者注册一个表面自己身份的id(clientId).这样当咱们这个客户端处于离线时, JMS提供者会为这个客户端保存所有发送到主题的消息.当客户端再次连接到 ...
- JMS学习(六)--提高非持久订阅者的可靠性 以及 订阅恢复策略
一,非持久订阅者 和 实时消费消息 在这篇文章中区分了Domain为Pub/Sub.Destination为Topic时,消费者有两种:持久订阅者 和 非持久订阅者. 对于持久订阅者而言,只要订阅了某 ...
- ActiveMQ Topic发布订阅消息
2019独角兽企业重金招聘Python工程师标准>>> ActiveMQ Topic发布订阅消息 博客分类: MQ package com.googlecode.garbagecan ...
- 使用java实现MQTT协议客户端的接收、发布消息和订阅、退订主题topic
记录一下我实习的第一个任务,学习MQTT协议 首先呢得了解MQTT是什么,这里推荐一个我学习MQTT的中文文档 MQTT协议的基于TCP/IP协议的一个物联网协议,有几个概念必须要弄懂得主题(topi ...
最新文章
- java百度api人脸识别_百度人脸识别api demo
- FFT算法8点12位硬件实现 (verilog)
- [转]arm汇编相关链接
- Nginx 的启动、停止、平滑重启、信号控制和平滑升级
- codeforces 1016C - Vasya And The Mushrooms 【构造 + 思维】
- 马拦过河卒(NOIP2002)
- Java 实现日期 Date 的赋值
- 鸿蒙系统平板界面,华为鸿蒙系统界面首次曝光!首款预装鸿蒙设备正式入网:发布在即...
- Oracle命令--如何查看oracle中创建的所有目录
- idea重写接口没有@override_细说 Java Overload 与 Override 差别
- React ~ 生命周期
- docker安装mysql【网易镜像方式】
- slickedit 设置
- 深度学习 —— 深度置信网络
- matlab空间计量AIC准则,空间计量经分析课件.ppt
- TLC5615 10位DA模块数模转换芯片驱动
- c语言解三色旗问题加注释,三色旗问题(Three
- JS随机漂浮广告代码
- 一些代码静态检查工具的简介
- TraceMe.exe注册码破解及注册机编写
热门文章
- cucumber测试_如何在Cucumber中进行后端测试
- jdk open jdk_JDK 14的迹象开始出现
- jdk11换jdk8版本_在JDK 9(以及8)以及更高版本中,所有内容都可以作为一个流
- 无处不再的广告_我的机器人现在无处可去。 无家可归。 无服务器。
- jsf el表达式_JSP,JSF和EL简介
- antlr4例子_ANTLR和网络:一个简单的例子
- aws sqs_在Spring中将AWS SQS用作JMS提供程序
- JDK 14 / JEP 305模式匹配“ Smart Casts”实例
- apache.camel_Apache Camel 2.14中的更多指标
- jvm能识别什么字符集_识别JVM –比预期要难