在 http://activemq.apache.org/message-groups.html 中,据说消息组提供了跨多个使用者的消息处理的负载平衡。
虽然我读了整篇文章,但我不明白消息组和负载平衡之间的关系。毕竟,在消息组之前就已经有了负载平衡:消息代理根据消费者的确认速度来分发消息。因此,如果消息组涉及负载平衡,就粒度而言,它是一个更大的负载平衡。
正确吗?
如有任何意见或见解,我们将不胜感激。
嗯,这并没有那么复杂,在文档中可能会有些混乱。
正如你所说,负载平衡是内置的,因为代理在可用的消费者之间分发消息。消息组通常必须代表一个需要由单个节点(或线程)处理的单元,甚至可能是由于应用程序逻辑而按顺序处理的。
如果有多个消息组发送到队列,它们将在多个使用者上进行负载平衡。
我正在尝试建立一个简单的 ActiveMQ 代理网络。我有2台机器,比如A和B。 在A的< code>activemq.xml文件中,我放置了networkConnector,它具有指向机器b的URI。在A的日志中,显示它连接到了b 我有一个向A发送消息的应用程序。在ActiveMQ的网络控制台的网络选项卡中,我可以看到我的消息正在排队和出队(我认为这意味着消息被转发到机器B)。 我的问题是消息在
如何配置我的以丢弃未使用的消息? 我不希望我的客户端在订阅服务器队列时收到服务器发送的所有旧消息。 这是我目前的经纪人: 目前,我的服务器首先启动并发送大约10条消息。之后,我的客户机订阅队列,并接收在没有客户机订阅时发送的所有10条消息。我不想要这种行为。 解决 然后我发出这样一条信息: 解决方案2 我创建了一个主题而不是队列。 http://Java sample approach . com
我们设置了一个中心辐射型拓扑,其中包含两个用于冗余的集线器。连接到网络的所有节点都具有到两个集线器的静态网络连接。 如果我们为另一个辐条产生的特定主题提供一个消费者,然后放弃其中一个集线器,有时消费者会停止获取数据。如果关闭hub A导致消费者停止接收数据,则进行备份将恢复消费者的订阅源。降低B对饲料没有影响。哪个枢纽可能影响消费者,这似乎是不一致的。 我们期望,对于代理网络,只要生产者在网络上并
我想通过ActiveMQ传递一条大消息。还有两个消费者/生产者。第一个是基于Spring MVC构建的,第二个使用Apache camel从队列中获取消息。问题是,我试图推送一条包含大约10 mb数据的短信,但ActiveMQ代理拒绝了它,并显示错误消息。 org.springframework.web.util.NestedServletException: 请求处理失败;嵌套异常是Java .
要求:一个activemq队列应该在一台机器(比如machine1)中运行。该队列应该从machine1和另一台机器(比如machine2)中访问。监听器将只在machine1中运行。因此,我发送到machine1和machine2的所有消息都应该进入machine1中可用的队列,并且应该被同一台机器(machine1)中可用的监听器接收。 问题:我发送到machine1和machine2的所有消
我在网络设置中有两个ActiveMQ代理。客户端配置为randomize=true,并且能够良好连接。但是,消息不会从一个代理转发到另一个代理,而是保留在队列中。例如,我有一个特定的队列,它有多个生产者和一个消费者。如果我查看一个消费者连接到的代理上的队列,所有消息都会立即退出队列。但是,在另一个代理上,消息会排队,不会被排出。 下面列出的是我为两个代理设置的网络连接器和传输连接器。我尝试过添加双