ActiveMQ消息分组性能
ActiveMQ 是一个流行的开源消息代理，它支持消息分组，可以提高性能。
消息分组是一种将消息分成多个部分的技术，以便在多个节点之间并行处理。这可以显著提高性能，特别是在处理大量消息或大量数据的情况下。
ActiveMQ 支持两种消息分组方式：队列分组和主题分组。队列分组将消息分发给多个消费者，每个消费者都从一个共享的队列中读取消息。主题分组将消息分发给多个订阅者，每个订阅者都从一个共享的主题中读取消息。
ActiveMQ 的消息分组性能优势在于它可以并行处理多个消息，从而提高吞吐量和响应时间。此外，ActiveMQ 还支持持久性和事务，这意味着即使在系统故障时，消息也不会丢失。
推荐的腾讯云相关产品：
这些产品都支持消息分组，并且可以与其他腾讯云产品集成，以提供更强大的应用程序功能。
相关·内容
1回答
活动MQ消息顺序处理
、、、、
我们有两台服务器: server1和server2。这两台服务器都在Wildfly 11的域模式配置下运行。下面是我们如何配置这两台服务器的。
让我们以本例中的server1域节点为例。
问题：
如果具有相同组ID的两个消息同时到达server1和server2，它们将不知道消息应该发送给哪个消费者。因此，消息最终由不同的使用者处理，有时先到达的消息会在稍后得到处理，这是不可取的。我们希望对系统进行配置，使两个节点都知道消息应该由哪个使用者处理。
我们尝试过的解决方案：
已使用组处理程序本地配置server1，并使用远程配置server2。现在，只要消息到达，本地组处理程序就会识别出该特定组I
浏览 12提问于2019-11-14得票数 0
我正在从ActiveMQ“经典”5.15.4迁移到ActiveMQ Artemis 2.17.0，并观察到性能下降。我测试了一个主题的一个生产者和不同数量的消费者使用这个主题。我正在测量从信息创建到消费者接收消息之间的时间。
测试是在一个由3个节点组成的集群上进行的，每个节点都相互连接。每个代理都嵌入到一个JBoss中。我使用了一个由3个节点组成的集群，因为这是我们当前的生产设置。我对这个设置提出了挑战，因为我们很少有消费者和生产者(每次少于50人)，而且我们使用消息分组，但是我需要在只有2个节点处于活动/备用模式的设置上执行POC。
生产者总是以同一个节点为目标，而使用者则随机连接到其他两个
浏览 4提问于2021-10-05得票数 3
回答已采纳
1回答
我有两个服务器，server1和server2。server1是主服务器，server2是从服务器。两者都在集群环境中运行。
如果两个具有相同组ID的消息同时到达节点1和节点2，他们将不知道应该将该消息发送给哪个使用者。因此，消息最终会被不同的使用者处理，有时到达的消息会被处理得很晚，这是不可取的。
我想配置系统，以便两个节点都知道消息应该由哪个使用者处理。
我尝试过的解决方案:用组处理程序本地配置了server1，用远程配置了server2。现在，每当消息到达时，本地组处理程序就标识使用者在哪个节点上，并相应地选择消息。
此解决方案在server1运行良好之前是有效的。但是，如果server
浏览 2提问于2019-11-08得票数 0
我已经定义了一个camel jetty-activemq路由，如下所示：
from("jetty:).to("activemq:queue:queue1)
camel是创建一个activemq连接，然后将该连接用于jetty接收的所有消息，还是为每个消息创建一个activemq连接。
我计划对activemq使用池连接，因为我每秒的消息流量相当高，我需要了解camel行为来定义最大连接池大小。
浏览 2提问于2012-10-29得票数 1
回答已采纳
我们使用的是ActiveMQ (5.14.5)。我们只有一个生产者，而同一队列上有多个消费者。我们不时地将JMSXGroupID设置为将多个消息组合在一起，以便在单个使用者上使用。这与预期的一样。同时，生产者继续发送未分组的消息(即没有JMSXGroupID)
问题:我们注意到，一旦选择了一个消费者来处理特定的组，它就不再获得未分组的消息。即使它是完全空闲的。未分组的消息总是被发送到其他消费者。只有当我们关闭分配给它的组(通过设置JMSXGroupSeq=-1)之后，流氓消费者才会返回使用未分组的消息。
这是正常行为吗？我们预计，未分组的消息将继续以相同的轮询方式传递给所有消费者。我们无法在A
浏览 0提问于2017-10-01得票数 0
正如在网页上建议的那样，我尝试过(在带有Windows7OS和SSD驱动器的英特尔i7笔记本电脑上)在ActiveMQ队列中生成持久消息的性能：
mvn activemq-perf:producer -Dproducer.destName=queue://TEST.FOO -Dproducer.deliveryMode=persistent
对应于默认安装的activemq 5.12.1
我得到的表演大约是每秒300-400条短信。在页面上，我读到的数字要高得多：
当在一个盒子上运行服务器，在另一个盒子上单独运行一个生产者和消费者线程时，使用一个主题，我们使用1-2K消息获得大约21-22,
浏览 3提问于2015-10-27得票数 0
回答已采纳
1回答
骆驼是否能提高性能？
、、、
我使用简单的java代码从ActiveMQ队列接收消息。从队列中读取1000条消息需要1小时以上。
但是现在我使用Apache从ActiveMQ队列中读取消息。它甚至不需要一分钟(52秒)来读取1000条消息。
对于这两个程序，我尝试使用相同的消息。
我的问题是，骆驼是否也提高了的性能？
浏览 3提问于2016-09-09得票数 0
回答已采纳
在我的体系结构中，有许多生产者希望将消息发送到ActiveMQ队列。使用者将实时使用来自该队列的这些消息。虽然这些消息的生成非常快，但是队列似乎能够处理它们。没有信息丢失。
我在这里的目的是强调这个体系结构，但是我找不到一个文档来解释在这个场景中可能会发生什么样的问题。例如，消息丢失会发生吗？如果是，什么时候？一个生产者P1产生的消息的接收能被另一个生产者P2产生的大量消息所抑制吗？
我使用这个Maven依赖项发送持久JMS消息：
<dependency>
<groupId>org.apache.activemq</groupId>
<ar
浏览 3提问于2022-06-07得票数 0
回答已采纳
我正在使用Apache ArtemisMQ 2.17.0存储数百万条预定消息。由于消息的数量，分页被触发，几乎一半的消息存储在共享文件系统(主从共享文件系统存储(NFSv4) ha拓扑)上。这些消息每隔X小时调度一次，每个“批处理”大约有500 k条消息，每个消息的大小略大于1KB。
本质上，我的用例要求在午夜附近的某个时间点生成400万到500万条消息，这些消息计划在预定义的预定时段(例如上午11点、下午3点、下午6点)以分组的形式离开。所产生的消息不是按预定时间排序的，而是作为时隙消息在下午6点进行排序的。可以更早地从其他消息写入队列，因此可以按顺序将计划好的消息交织在一起。而且，由于消息
浏览 1提问于2021-03-31得票数 0
1回答
activemq性能/延迟
、、、、
我正在使用jdbc存储测试activemq，虽然我知道这不是最有效的方法，但我看到了非常奇怪的延迟。
代码基本上是用3k消息填充队列，然后单个使用者使用所有消息。消息是持久的，确认模式是AUTO_ACKNOWLEDGE。我还禁用了alwaysSessionAsync和dispatchAsync。
问题是消费速度变化很大。以下是使用100条消息所需的时间(30倍才能全部使用)：
2014-07-16 01:08:50,171 'consumer': 45.1 ms
2014-07-16 01:08:50,207 'consumer': 35.5 ms
2014
浏览 3提问于2014-07-16得票数 0
1回答
有人能分享一下垂直缩放ActiveMQ的经验吗？我特别感兴趣的是，性能如何受到以下因素的影响：
NIO运输
选项org.apache.activemq.UseDedicatedTaskRunner
禁用tightEncoding中的OpenWire
使用各种类型的消息存储(包括KahaDB)
浏览 2提问于2010-03-02得票数 5
回答已采纳
1回答
ActiveMQ嵌入式与独立性能
、、、、
我们有一个遗留系统，其中ActiveMQ配置为一个JVM中主应用程序的一部分。它已经使用tcp传输来配置，如下所示
<transportConnector name="tcp" uri="tcp://0.0.0.0:61616?wireFormat.tcpNoDelayEnabled=true&wireFormat.tightEncodingEnabled=false" />
我们希望改变体系结构，将ActiveMQ分离成一个独立的JVM；对于进程内消息传递还是进程外消息传递，存在一些争论。这样做对业绩有什么影响吗？
(当然，我们将进
浏览 3提问于2015-12-18得票数 1
回答已采纳
2回答
我使用Java、spring-boot和ActiveMQ。我需要在最短的时间内发送大量的消息。现在，使用JMSTemplate逐条发送消息需要花费大量时间。
有没有办法可以把消息捆绑在一起，一次发送if到activemq，保证消息的顺序？
提前感谢
浏览 17提问于2018-02-22得票数 1
回答已采纳
我使用这个脚本在本地启动ActiveMQ：
docker run -p 61616:61616 -p 61614:61614 -p 8161:8161 -it -v conf:/opt/activemq/conf -v data:/opt/activemq/data rmohr/activemq
它启动AMQ版本5.15.6。我通过websockets连接AMQ (v1.2)。通过我的“测试”队列中的web控制台，我创建了两条具有相同组"test_grp“的消息。我启动两个进程，每个进程运行相同的逻辑：
connectsubscribe到"/queue/test“，在新消息上使
浏览 11提问于2020-02-03得票数 0
回答已采纳
2回答
我将为一个项目使用activemq，并希望能够对应用程序进行压力测试。我可以用什么方式每秒发送x条消息，这样我就可以说明正常的消息传递周期，并查看它如何处理异常的消息传递速率？
谢谢
浏览 3提问于2012-11-03得票数 1
回答已采纳
目前，我们在ActiveMQ中使用KahaDB存储进行消息持久化，目前为止效果还不错。
根据ActiveMQ5.6的发行说明，LevelDB提供了增强的性能。
有没有人尝试过LevelDB，如果有，你能提供利弊吗？
浏览 1提问于2012-08-02得票数 6
回答已采纳
我们使用的是一个ActiveMQ Artemis节点集群，我们希望使用消息分组特性。从文档中，我们了解到我们需要识别将成为此功能的主节点的一个节点。是否有办法让集群本身自动和动态地进行此选择？
如果没有，假设我们自己做，是否有一种方法可以动态地更改节点的消息分组设置，而不必重新启动它？
我们正在使用EmbeddedActiveMQ。
问候尼古拉斯
浏览 1提问于2021-07-05得票数 0
回答已采纳
我们希望使用来延迟粒子事件。 AMQ_SCHEDULED_DELAY是如何内部工作的?文档中的是关于调度程序的信息，但没有使用什么机制来延迟消息的信息。因此，我们不确定延迟将如何影响activeMQ。activeMQ是否利用池或异步来实现延迟。
我问这个问题是因为我的组织里的人想选择不同的技术。我没有任何证据证明activeMQ的延迟更好。
是指向源代码的链接。我正在考虑查找代码，但我不擅长java。有人能帮忙吗？
浏览 5提问于2016-11-24得票数 0
1回答
我有一个基于骆驼的应用程序，它可以将消息发布/订阅到/来自ActiveMQ实例，其路由如下：
<from uri="activemq:myQueue" />
或者：
<to uri="activemq:someOtherQueue" />
我试图确定是否无意中将我的应用程序设置为“同步模式”，这种情况发生在以下两种情况之一：
ActiveMQConnectionFactory#setAlwaysSyncSend为真；或
"MessageProducer“设置为”持久“。
我相信，无骆驼，我通常会手动设置这些属性。这
浏览 1提问于2013-03-12得票数 1
下面的ActiveMQ实现存在于代码中。有时，系统停止工作，变得非常缓慢。当我使用JavaMelody检查线程转储时，我已经看到太多线程处于可运行状态很长时间了，并且没有被终止。
ActiveMQ版本- activemq-all-5.3.0.jar
请参阅以下代码：
Broker :
public class ActiveMQ extends HttpServlet {
private static final long serialVersionUID = -1234568008764323456;
private static final Logger logger = Logger.g
浏览 1提问于2016-10-24得票数 5
当我们使用ActiveMQ时，我们可以信任ActiveMQ服务器的可靠性。例如，在开发非实时软件时(不需要立即发送数据)。但它应该发送)。我们是否可以相信activeMQ是确认消息传递的可靠来源。例如，我正在从生产者发送一个xml文件。将该文件发送到ActiveMQ确认的ActiveMQ传递。那么我可以信任ActiveMQ并删除xml的本地副本吗？
编辑
当消息到达ActiveMQ服务器时，它是可靠的。如何确保生产者服务器链接的可靠性。万一生产者是一个java应用程序。ActiveMQ客户端如何处理这些场景
在准备发送数据时强制关闭应用程序。
发送消息时发生网络故障。
浏览 6提问于2015-05-25得票数 3
我是C++的新手，但在Java方面有很多经验。
我需要编写一个小应用程序，它是严重异步的。它接收来自HTTP的数据，并将其存储在队列中(需要有保证的传递和非常高的吞吐量)，比如ActiveMQ或OpenMQ，可能是通过JMS。
然后，另一个C++应用程序/侦听器从队列中取出数据(通过由队列直接激活的监听器，而不是通过我的池)，连接到MySQL数据库并进行一些业务逻辑计算，并将消息发送到另一个队列。
在Java中，这将是一个将消息发送到JMS队列的web应用程序。消息驱动Beans将是EJB模块中这些消息的使用者，会话EJB将向传出JMS队列发送消息。
有C++经验的人能向我解释一些基本知识吗：
浏览 1提问于2012-09-02得票数 6
回答已采纳
2回答
是否有可能在ActiveMQ中实现类似于多播的Tibco RV？即，如果生产者在X.Y.Z发布，并且有向X.Y.>注册的订阅者，他们将收到消息。
根据我的knowledge ActiveMQ没有提供类似订阅的X.Y.>，它总是使用主题/队列的点对点消息传递。
浏览 18提问于2015-09-18得票数 1
1回答
我的ActiveMQ堆大小不断增加，最终耗尽了内存。为一个仍在运行的实例获取堆转储，并得到以下类具有许多实例(其余的类非常小)。寻找关于这里可能出什么问题的指示。
170866 instances of class org.apache.activemq.command.ProducerId
170526 instances of class org.apache.activemq.broker.jmx.AnnotatedMBean
170519 instances of class org.apache.activemq.command.SessionId
170518 instances
浏览 3提问于2017-02-06得票数 0
回答已采纳
1回答
在我们的一个项目中，当我们使用大量消息(1M或更多)的调度工具(启用ActiveMQ配置中的schedulerSupport )时，我们的性能下降了。这个项目是基于Spring的，我们也在使用骆驼进行路线管理。
我们的路由配置如下：
生产者P生成800条消息/秒，并通过非持久性ActiveMQ队列q发送它们
使用者Cq根据以下规则处理来自q的消息:对于每条消息，它验证消息是否可以立即被处理(每个消息都有一个时间窗口属性来定义该消息)。如果可能，Cq将消息转发给节流队列T；如果不是，Cq将消息转发到支持队列S
使用者Cs处理来自S的消息，并根据其时间窗口(用以下语句设置ActiveM
浏览 2提问于2015-05-21得票数 5
我有一个wso2 ESB正在与activeMQ (持久性消息传递)进行通信。有时，ESB上的线程会堆叠起来，因为所有线程都在等待activeMQ响应对它的各种调用。最终呼叫出错了。
同时，在ActiveMQ日志中，我看到了许多“缓慢的Kaha访问”日志。下面是一些例子：
缓慢的KahaDB访问:清理花费了5138
缓慢的KahaDB访问:日志附加: 1635 ms，索引更新用2330 ms
这在我们的系统中是一个大问题，因为一旦AMQ停止足够快的响应，我们就锁定线程。由于IO/access花费的时间太长，activeMQ似乎停止了对ESB的响应。由于我们继续尝试在ActiveM
浏览 0提问于2015-05-04得票数 0
回答已采纳
正如标题所说，它们的区别是什么，如何做出选择？我想知道有什么东西是相同的吗？如果我想建立一个保持活动的连接？也就是说，一旦我连接到activemq服务器，我就可以随时使用该连接来发送/接收消息。我想我可以叫它daemonProducer或daemonConsumer。activemq能实现这一点吗？
浏览 3提问于2012-07-11得票数 2
回答已采纳
1回答
我刚接触ActiveMQ，正在做一个从队列中读取消息，然后对它们进行批处理的项目。(我将它们放到第三方API中，一次只能处理100个，但少于100个就可以了)
我发现的每个示例都包含事件驱动的代码，这些代码以原子方式处理每条消息。是否有gem、plugin或其他方法允许表单的伪代码
while(!queue.empty?) do
chunk = []
while(!queue.empty? && chunk.size < 100) do
chunk << queue.read
end
do_something_with
浏览 2提问于2012-06-07得票数 0
回答已采纳
以下是配置：
2个JBoss应用节点
应用程序节点上的5个侦听器，每个线程50个，支持集群，并被设置为活动活动侦听器，因此它们在两个应用程序节点上运行。
侦听器只获取消息并将信息记录到数据库中。
使用ActiveMQ将50000条消息发布到JMeter中。
下面是对第一次执行的观察：
总共50000条消息在大约22分钟内被消耗。
在大约1分钟内使用的第一个0-10000消息。
大约2分钟内消耗的10000-20000条消息。
大约4分钟内消耗的20000-30000条消息。
大约6分钟内消耗的30000-40000条消息。
40000-50000
浏览 3提问于2015-04-13得票数 1
回答已采纳
1回答
我们对AMQ使用以下配置
<bean id="jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="${brokerURL1}"/>
</bean>
<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.Poole
浏览 3提问于2012-07-18得票数 10
使用ActiveMQ v5.8
我使用javax.jms.MessageProducer.send()从我的生产者向ActiveMQ发送消息。
我想知道这个发送是同步的还是异步的？如果我使"useAsyncSend“标志变为真，行为将是什么？
谢谢，Anuj
浏览 1提问于2014-06-19得票数 1
回答已采纳
1回答
如何将JWT附加到JMS消息？
、、、、
我们需要在每个JMS消息旁边发送一个JWT令牌。除了将其打包到有效负载本身之外，我不确定在JMS和/或ActiveMQ消息结构中是否可以使用附件或标头。
查看了ActiveMQMessage，但没有找到附件或标头。
浏览 0提问于2019-08-06得票数 0
回答已采纳
最近，我开始在我的新项目中使用ActiveMQ作为消息中间件，这是我第一次尝试使用ActiveMQ，我之前参与过的项目使用了我们公司的内部消息框架，比如燕子。因此，在开始实现该系统之前，我需要明确一些设计要点。
在我们的系统中，使用ActiveMQ的案例包括发送邮件、向队列发送任务和从队列执行任务、异步请求/响应、，那么什么样的协议和网络连接才是我们的正确选择？I在这里列出了一些协议和网络连接选项：
ActiveMQ协议
MQTT
WS
Openwire
Stomp
Stomp
ActiveMQ网络连接
VM
TCP
UDP
HTTP
Failo
浏览 0提问于2015-09-14得票数 2
我正在尝试实现一种策略，当activemq队列中的消息到期时，它们将转到另一个死信队列，而不是移动到默认的死信队列ActiveMQ.DLQ。
我的应用程序使用camel-context进行路由和bean定义。我看过，但我不确定如何实现individualDeadLetterStrategy。
我想尝试创建一个重新交付策略bean，并将其添加到我的连接工厂中，但在这里我没有看到死信策略的属性
我也考虑过使用错误处理程序，但我的用例不是错误场景。
我的问题是如何为单个队列配置/指定死信队列。
我已经将我的应用程序配置为生成队列，如下所示
<route id="myRo
浏览 2提问于2018-07-12得票数 1
在使用ActiveMQ Artemis和Spring应用程序进行一些负载测试时，我陷入了性能问题。
我正在做的是，以每秒12,000条消息的速度向代理发送JMSeter，然后应用程序接收这些消息并将它们保存到DB中。效果很好。但是，当我使用过滤器机制扩展我的应用程序时，它将保存后的事件转发给DB，然后使用jmsTemplate.send(destination, messageCreator)将事件转发给代理，它运行得非常慢。
我首先使用了ActiveMQ 5.x，在那里，这个机制工作得很好。在那里，您可以配置ActiveMQConnectionFactory和setAsyncSend(tru
浏览 4提问于2020-12-08得票数 0
回答已采纳
在你标记这份副本之前，我试过查看这里所有的相关帖子，但找不到相关的帖子。
我的问题是：
根据MapMessage正文内容中的某些键/值对过滤。
建议
然后，消息使用者只接收标题和属性与选择器匹配的消息。消息选择器不能根据消息正文的内容选择消息。
但是，由于JMS实现是特定于供应商的，所以我想知道是否可以根据activemq实现中的键/值过滤MapMessage。
(例如，在处理包含XPath主体的消息时，active MQ支持基于XPath的选择器。检查)
或
是否有可能覆盖选择器(通过继承或实现新的选择器)并将其插入activemq以获得结果？
谢谢。
浏览 1提问于2014-07-25得票数 1
1回答
我是性能测试的新手。
在我接下来的项目中，我必须通过Jmeter将XML消息传递到ActiveMQ。
我如何实现这一点？
任何指向任何网站的提示都会有所帮助。
浏览 1提问于2013-02-01得票数 0
我正在开发一个应用程序。我使用的是activemq。有没有办法做到这一点:一个生产者总是向一个代理发送消息，而在另一边，有3个consumers.Each消费者监听代理，并可以从queue.Is获取任何消息。
我正在使用activemq编写我的应用程序。logs to db.As你知道将日志写入db是一个耗时的过程，这就是为什么消费者比producer.For ex更慢的原因。I send 100.000 message (大型对象).Producer在20 mins.But内完成发送消息当生产者完成时，消费者已经完成了4.000消息的处理。
浏览 4提问于2013-09-19得票数 0
我正在努力提高通过ActiveMQ broker发送消息的速度。
问题是，我的性能并没有得到很大的提升。通过我的服务将10000条持久消息从队列№1发送到队列№2大约需要2分40秒。发送10000条非持久化消息大约需要2分20秒。我期望在非持久模式下至少获得x10速度性能。实际上，我可以将transacted属性设置为"false"：
<property name="transacted" value="false"/>
但这不是一个选项，我需要交易模式的消息是临时的。
我对ActiveMQ进行了如下配置：
<bean clas
浏览 2提问于2019-05-14得票数 0
我们在我们的项目中使用ActiveMQ，我们有一个要求，属于一个组的一组消息应该由一个消费者线程消费。
例如，我们有3条(M1，M2，M3)消息属于人A，3条(M4，M5，M6)消息属于人B。
我们的需求是:所有属于个人A的消息应该由消费者线程1消费，所有属于个人B的消息应该由消费者线程2消费。
基于ActiveMQ文档，根据我们的理解，我们在ActiveMQ中使用了JMXGroupId概念。例如，对于属于人员A的所有消息(M1、M2、M3)，我们将JMSXGroupId设置为123；对于属于人员B的所有消息(M4、M5、M6)，我们将其设置为234。
对于JMXGroupId，在某些情况下，
浏览 2提问于2020-03-01得票数 0
我们正在编写新的C/C++代码，需要集成到ActiveMQ消息总线中。这有很多选择：
是一个易于使用的C++类JMS。
OpenWire C客户机(仅在ActiveMQ 4.x或更高版本中可用)。
OpenWire C++客户端
Stomp C客户端(libstomp)
然后是“更疯狂”的选项，比如REST，使用JNI、SOAP、XMPP链接到ActiveMQ Java客户端.那么，我应该使用什么来将我的C/C++应用程序与ActiveMQ集成，为什么呢？
浏览 3提问于2011-02-08得票数 4
1回答
DLQ消息无序
、、
我有两个ActiveMQ JMS使用者队列consumer1和consumer2。 两个队列都启用死信队列，主要是为了避免有毒消息连续重试。 问题是现在应该按顺序处理consumer2消息。其中去往DLQ的消息稍后可能被无序地处理。 有什么建议如何处理这种情况吗？
浏览 11提问于2019-02-28得票数 0
我们正在从IBM MQ迁移到Amazon MQ，至少我们愿意这样做。问题在于，与IBM MQ相比，Amazon MQ在使用JMS producer将较大的消息放入队列时的性能较差。
所有消息都是持久的，系统关于IBM MQ是高可用性的，Amazon MQ是多AZ的。
如果我们将这个大小的XML文件放到IBM MQ (2个cpu和8 8GB HA实例)中，我们会得到这样的性能：
256 KB = 15ms
4,6 MB = 125ms
9,3 MB = 141ms
18,7 MB = 218ms
37,4 MB = 628ms
74,8 MB = 1463ms
如果我们将相同的文件放在Amaz
浏览 3提问于2020-03-26得票数 1
1回答
我希望比较不同的消息队列经纪人，如activeMQ，rabbitMQ和卡夫卡。考虑到我是这个领域的新手，是否有可能使用Gatling工具来测试所有这些？
我不确定，执行这类测试的过程应该是什么。
这是否就像用我的脚本用Gatling使用的Scala测试它们的每个源代码？
浏览 0提问于2018-10-02得票数 1
1回答
客户希望通过ActiveMQ在应用程序和应用程序之间交换数据，因此我们希望创建一个接口规范文档，该文档描述两个应用程序必须使用的设置和属性，以便它们能够通信。我们不知道客户将使用哪种编程语言或API；因此，如果规范不完整，它们可能会隐式地使用我们不希望使用的设置。
因此，我想知道哪些设置必须在双方相同，哪些设置可以由每个应用程序自己决定。到目前为止，这就是我所拥有的：
必须在文件中具体说明：
连接器类型(开线，踏，.)
连接器设置(代理运行的主机名、TCP端口、用户名、密码)
消息类型(TextMessage，BytesMessage.)
有效载荷详细信息(XML与XSD，JS
浏览 3提问于2017-05-19得票数 1
2回答
分布式数据存储的体系结构
、、、
目前我有两个独立的应用程序。
首先是RESTful接口。
第二种是数据存储，它可以处理原始数据并将处理后的数据存储在文件系统上。此数据按文件夹和文件夹ids分组，并按用户ids分组。
这些应用程序使用queueCount队列通过消息队列(ActiveMQ)连接。
也可以使用嵌入式文件服务器通过此队列发送文件。
我想将这个数据存储分布在几个节点上。
1)第一个变体
在n个节点中的每个节点上设置ActiveMQ和当前存储应用程序。创建将为这些分片提供查询服务的主节点。这样，不同用户的数据将存储在不同的节点上。
2)第二
使用存储应用程序设置n个节点。为ActiveMQ设置一个实例。在ActiveM
浏览 2提问于2014-12-11得票数 0
当任何消息发布到AWS SNS主题时，侦听器(java代码)可以使用来自SNS主题的消息，而无需创建任何订阅者。我希望使用AWS实现像ActiveMQ这样的发布订阅模式。
浏览 12提问于2022-08-19得票数 -1
在activemq 5中，每个队列都有一个包含其数据和消息的文件夹。这意味着，在出现问题时，例如磁盘空间外的错误。有些文件会在服务器崩溃前损坏。在这种情况下，在activemq 5中，我们可以找到指示损坏文件的日志，并且可以删除已损坏的队列文件夹，从而导致消息的少量丢失，而不是所有的消息。
在artemis中，消息似乎存储在相同的文件中，与存储在其中的队列无关。这意味着，如果我得到一个磁盘空间错误，我可能不得不删除我的所有消息。
第一，你能否确认行为的改变，第二，是否有办法恢复？另外，如果有人知道为什么会发生这种变化，我想了解一下。
浏览 0提问于2019-08-12得票数 0
回答已采纳
1回答
我使用的是当前的Apache.NMS 1.7.1和Apache.NMS.ActiveMQ 1.7.2。我使用的是IndividualAcknowledge，所以我试图将加载的消息数量保持在很低的水平，因为如果我加载了>>1000消息而没有添加它们(它每次都在搜索所有消息的链接列表)，它会变得非常慢。
我有以下代码：
BlockingCollection<IMessage> _collection = new BlockingCollection<IMessage>();
var factory = new ConnectionFactory("act
浏览 3提问于2017-04-19得票数 0
3回答
我正在进行一项关于(Java)消息传递和排队系统的交易研究，为即将到来的一个主要web应用程序的后端框架重新设计(在亚马逊的EC2云上，x-large实例)。我目前正在评估ActiveMQ和RabbitMQ。
计划是有5个不同的队列，其中一个是死信队列。每天发送的消息数量将在40K到400K之间。由于我计划将消息内容作为指向数据存储上的XML文件位置的指针，因此预计消息大约为64个字节。但是，出于评估目的，我还希望考虑在消息中发送平均文件大小为3KB的原始XML。
我的主要问题是:什么时候/每天应该保存多少消息？考虑到我上面指定的数量，持久化所有消息是否合理？我知道坚持会降低性能，也许会降低很
浏览 1提问于2012-10-01得票数 8
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
