程序员经验分享-hwhale

集群应用程序服务器中的 JMS 主题订阅者如何接收消息？

2024-05-08

假设我创建了一个带有一个订阅者 (PropertiesSubscriber) 的 JMS 主题 (PropertiesTopic)。 PropertiesSubscriber 运行在负载平衡的应用程序服务器集群中，如下图所示。

替代文本 http://www.freeimagehosting.net/uploads/be28c03781.png http://www.freeimagehosting.net/uploads/be28c03781.png

当一条消息传递到 PropertiesTopic 时，是否在不同应用程序服务器上运行的所有 PropertiesSubscriber 实例都会获取该消息，或者该消息是否仅传递到在负载均衡器确定的应用程序服务器上运行的一个 PropertiesSubscriber 实例？


JMS 2.0介绍共享订阅 http://www.oracle.com/technetwork/articles/java/jms2messaging-1954190.html。这些允许多个消费者（例如：在集群的不同节点上）共享单个主题订阅。只有一个共享订阅的消费者才会收到每条消息。

要指定多个消费者共享订阅，他们需要使用相同的共享订阅名称 https://jms-spec.java.net/2.0/apidocs/javax/jms/JMSContext.html#createSharedConsumer(javax.jms.Topic,%20java.lang.String)

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

JMS

loadbalancing

publishsubscribe

clustercomputing

Subscriber

集群应用程序服务器中的 JMS 主题订阅者如何接收消息？ 的相关文章

  • Spring集成MQTT发布订阅多个主题

    我正在尝试构建一个订阅多个 mqtt 主题的应用程序 获取信息 处理它并形成 xml 并在处理时触发一个事件 以便这些可以发送到某个云服务器 并将成功的响应从那里发送回MQTT 通道

  • 是否可以仅从复制因子为 3 的 Cassandra 集群中的单个节点读取数据？

    我知道 Cassandra 有不同的读取一致性级别 但我还没有看到一种一致性级别允许仅从一个节点按键读取数据 我的意思是 如果我们有一个复制因子为 3 的集群 那么我们在读取时总是会询问所有节点 即使我们选择一致性级别 1 我们也会询问所有

  • 在 GCP PubSub 中收到任何响应之前重试总超时时间已超过

    我正在尝试使用 Node js 推送到 PubSub 主题 google cloud pubsub模块 这是 JavaScript 代码 const pubsub require google cloud pubsub class MyPu

  • 切换到负载均衡器后，django 帖子收到 CSRF 验证失败

    我有一个有效的登录模板 可以发布帖子 如下所示

  • ActiveMQ 的 @SendTo 注释无提示地失败

    我试图使用 SendTo 注释将 JMS 消息推送到 SpringBoot 应用程序中的独立 ActiveMQ 代理 但是执行完成时没有错误 异常 但消息未排队 相反 如果我使用 JmsTemplate 在代码中注释 消息将排队 使用 Se

  • 目的地为必填项

    在 Wildfly 8 1 0 服务器中部署 Ear 时出现以下错误 1 Error Caused by javax resource spi InvalidPropertyException Destination is mandator

  • 会话亲和性和粘性会话之间的区别？

    有什么区别会话关联性 and 粘性会话在负载平衡服务器的上下文中 我见过这些术语可以互换使用 但有不同的实现方式 在第一个响应中发送 cookie 然后在后续响应中查找它 cookie 表明要发送到哪个真实服务器 Bad如果您必须支持无 c

  • 发布者-订阅者与观察者[关闭]

    就目前情况而言 这个问题不太适合我们的问答形式 我们希望答案得到事实 参考资料或专业知识的支持 但这个问题可能会引发辩论 争论 民意调查或扩展讨论 如果您觉得这个问题可以改进并可能重新开放 访问帮助中心 help reopen questi

  • Bluemix 负载均衡器算法

    使用什么算法来平衡 Bluemix 上运行的多个实例之间的 HTTP 负载 看来我可以使用自动伸缩服务来水平扩展 想知道平衡负载时使用什么算法 Cloud Foundry 使用循环负载平衡在应用程序的运行实例之间分配请求

  • Wildfly 10 Final 无限期地创建 ActiveMQ-client-global-threads

    我有一个Wildfly AS设置 JMS 我正在使用 Jconsole 监视它 并注意到在我在我的设备上创建会话之前Consumer or Producer线程数正在稳步增加 我之前使用过Wildfly 9 final出于同样的目的 即使在

  • 如何将使用消息侦听器接收到的 JMS 消息转换为域对象

    我在用 春季3 1 1 ActiveMQ 5 6 0 我有两个 JMS 应用程序 应用程序 A 使用 JmsTemplate 使用 jmsTemplate convertAndSend msg 发送域对象 App B 使用消息监听器并注册了

  • WebSphere MQ v7.1 安全用户凭证

    运行 WebSphere MQ Server v7 1 的 Linux Server Box 我在 Linux 中创建了一个属于 mq users 组的用户 mq user 然后我创建了一个队列管理器QM TEST 并使用 MQSC 发出以

  • JMS 中的 MessageListener 和 Consumer 有什么区别？

    我是新来的JMS 据我了解Consumers能够从队列 主题中挑选消息 那么为什么你需要一个MessageListener因为Consumers会知道他们什么时候收到消息吗 这样的实际用途是什么MessageListener 编辑 来自Me

  • 如何连接到 NAT 后面的 JMS 队列 JBoss EAP 7？

    我已经配置了位于 NAT 网关后面的 JBoss EAP 7 0 我的 JMS 客户端可以从同一服务器或同一网络的另一台服务器成功连接到 JMS 队列 但是当同一 JMS 客户端移出该网络并尝试通过 NAT 网关连接到 JMS 时 它无法连

  • 如何使用redis发布/订阅

    目前我正在使用node js和redis来构建应用程序 我使用redis的原因是因为发布 订阅功能 该应用程序只是在用户进入用户或离开房间时通知经理 function publishMsg channel mssage redisClien

  • Nginx 作为负载均衡器，具有 75% 和 25% 加权路由

    我是 Nginx 新手 我有两台服务器 serverA 和 serverB 我希望 75 的请求发送到 serverA 其余 25 的请求发送到 serverB 这可能吗 使用nginx加权路由 stream upstream stream

  • IIS6 中托管的 WCF 服务在生产中收到 404

    我已经构建了一个简单的 WCF 服务并将其部署到 IIS6 我注意到它可以在我的开发和登台环境中运行 但不能在生产环境中运行 每次我尝试点击服务元数据链接时 都会收到 404 页面 我检查了我能想到的所有 IIS 配置 它们是相同的 所以我

  • 如何修复 /usr/bin/env 参数处理？

    我遇到了一个奇怪的问题 usr bin env 我设计了一个简单的脚本来显示问题 该脚本使用 Ruby 编写 但使用 Python 编写的类似脚本也会发生同样的情况 这是脚本 usr bin env ruby p ARGV 还有一个没有 u

  • 如何在 Spring JMS 监听器中从 JMS 消息获取自定义属性

    我知道您可以通过以下方式访问 Spring JMS 侦听器中的标准标头 public void receive String in Header JmsHeaders MESSAGE ID String messageId 是否有类似的注释

  • Spark - 如何在本地运行独立集群

    是否有可能运行Spark独立集群仅在一台机器上进行本地操作 这与仅在本地开发作业基本上不同 即local 到目前为止 我正在运行 2 个不同的虚拟机来构建集群 如果我可以在同一台机器上运行一个独立的集群 该怎么办 例如三个不同的 JVM 正

随机推荐

热门标签