ActiveMQ生产者断断续续的连接和持久性
ActiveMQ是一个开源的消息中间件，用于实现消息的发送和接收。它支持多种消息协议，包括JMS（Java消息服务）和AMQP（高级消息队列协议）等。
ActiveMQ生产者断断续续的连接和持久性是指在使用ActiveMQ时，生产者与ActiveMQ之间的连接可能会出现断断续续的情况，并且消息的持久性可能会受到影响。
造成生产者断断续续的连接的原因可能有多种，包括网络故障、ActiveMQ服务器故障、生产者代码错误等。当生产者与ActiveMQ之间的连接断开时，生产者将无法将消息发送到ActiveMQ，直到连接恢复。
消息的持久性是指消息在发送后是否会被持久化存储，以确保即使在消息发送后发生故障，消息也不会丢失。在ActiveMQ中，可以通过设置消息的持久性属性来控制消息的持久化存储。当消息的持久性设置为持久化时，ActiveMQ会将消息存储在持久化存储中，以确保消息的可靠性。
对于解决生产者断断续续的连接和持久性的问题，可以采取以下措施：
- 检查网络连接：确保生产者与ActiveMQ之间的网络连接稳定，避免网络故障导致连接断开。
- 错误处理和重试机制：在生产者代码中实现错误处理和重试机制，当连接断开时，可以尝试重新建立连接并重新发送消息。
- 使用持久化消息：对于重要的消息，可以将消息的持久性设置为持久化，以确保消息在发送后不会丢失。
- 监控和报警：设置监控和报警机制，及时发现连接断开和持久性问题，并进行相应的处理。
腾讯云提供了一系列与消息队列相关的产品，例如腾讯云消息队列 CMQ（Cloud Message Queue），可以用于实现可靠的消息传递和处理。CMQ支持多种消息协议，包括JMS和AMQP，具有高可用性和可靠性。您可以通过腾讯云消息队列 CMQ来解决ActiveMQ生产者断断续续的连接和持久性的问题。
更多关于腾讯云消息队列 CMQ的信息和产品介绍，您可以访问以下链接： https://cloud.tencent.com/product/cmq
相关·内容
2回答
我在activemq.xml中找到了用于持久化DB中的队列的全局配置(persistenceadapter)。
我的应用程序中有5个队列在运行，而我只想持久化两个队列，在activemq.xml中有什么方法可以做到这一点吗？
致敬，BRK
浏览 4提问于2015-04-21得票数 0
3回答
我一直在评估作为候选消息代理的ActiveMQ。我已经编写了一些测试代码，试图了解ActiveMQ的性能限制。
我可以通过尽可能快地发送消息来在代理中产生失败状态，如下所示：
try {
while(true) {
byte[] payload = new byte[(int) (Math.random() * 16384)];
BytesMessage message = session.createBytesMessage();
message.writeBytes(payload);
producer.send(me
浏览 0提问于2008-12-05得票数 4
现在查看camel-jms文档，根本没有提到如何使用通用的camel JMS组件来生成和使用发往任何JMS2.0兼容代理的消息。
上的惟一示例是使用Spring DSL使用其专用的ActiveMQ组件配置ActiveMQ连接工厂。如何配置Camel JMS连接到我的Artemis实例？
考虑到尽管Artemis与JMS5.x兼容，但我将使用Camel路由来发布和订阅共享持久主题，因此我需要能够配置ActiveMQ连接，并使用它创建发布者和共享持久订阅者(仅在JMS2.0中支持，ActiveMQ仅支持JMS1.1)。
谢谢!
浏览 5提问于2016-01-22得票数 6
2回答
我正在学习如何使用java.I使用activemq，它使用stomp作为有线格式在运行在WebSockets broker和WebSocket中的WebSocket服务器之间发送ActiveMQ消息。
通知客户端他/她已连接到服务器很容易，但是否可以通知侦听的java服务器程序客户端已连接到服务器？
浏览 2提问于2014-01-21得票数 0
回答已采纳
1回答
我使用的是ActiveMQ 5.10.0。
我有许多消费者通过stomp连接连接到ActiveMQ。
我有大约2000名用户连接到唯一的队列。我现在的问题是，ActiveMQ总是在几个小时后崩溃/挂起，日志没有显示任何错误。这让我很难找到问题出在哪里。
据我所知，在ActiveMQ崩溃后，新的使用者不能为队列创建新的连接和订阅。我也不能打开网络控制台。
是否有任何方法可以提高ActiveMQ的性能以处理许多连接或其他性能调优？
浏览 7提问于2015-10-11得票数 0
4回答
我想在产生消息的服务器和接收消息的多个客户端之间建立一个基于发布者-订阅者的通信协议。经过一些研究后，我决定使用ActiveMQ。我查看了一些教程和ActiveMQ站点，并按如下方式设置了代理：
BrokerService broker = new BrokerService();
broker.setPersistent(false);
broker.addConnector("tcp://localhost:61616");
broker.start();
我只需要消息传递功能，没有数据库持久性或任何类似的东西。但是，当我启动应用程序时，无论配置如何，都会创建一个activ
浏览 1提问于2010-10-17得票数 2
回答已采纳
我有一个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
回答已采纳
2回答
如何增加AmazonMQ最大连接
、、、、
2019年-08-01 06:04:43,263收不到连接: org.apache.activemq.transport.tcp.ExceededMaximumConnectionsException:超过了允许的最大客户端连接数。请参阅transport上的“maximumConnections”属性，该属性位于ActiveMQ配置文件(例如，activemq.xml) \{##**$}\{e76f}\x{e76f}\x{e76f}{##**$$}
在amazonMQ的异常之上，之前我们使用的是activeMQ，我们在其中设置了以下内容
<transportConnectors
浏览 2提问于2019-08-02得票数 4
回答已采纳
1回答
ActiveMQ，多会话与多连接
、、、、
我想在我的当前项目中使用ActiveMQ，但是对于何时利用多个连接，我并不感到困惑。既然我们可以在一个连接中创建多个生产者，那么有什么必要有多个连接。
我试图在网上找到它，但找不到任何有用的资源，可以帮助我深入了解它。
如果有人能分享他与activemq合作的实际经验，帮助我们理解，何时为每个生产者创建多个连接，以及何时在同一个连接中创建多个生产者，这将是非常有帮助的。
浏览 0提问于2017-07-27得票数 3
我正在使用activemq创建连接。我正在创建线程，每个线程都有自己的连接、会话和生产者。我有两个问题: 1.我是否需要关闭连接，会话，生产者自己的代码或pooledConnectionFactory将关闭一旦消息发送成功生产者。2.为每个线程(最终为每个消息)创建连接将是性能瓶颈。有没有可能只有一个连接和多个会话(或者在会话和连接之间应该有一对一的映射，我想我是在activemq网站上读到的)
任何帮助都将不胜感激。
浏览 0提问于2013-01-11得票数 1
回答已采纳
我希望我的Java应用程序能够观察Apache ActiveMQ代理，并了解新创建的和关闭的连接。
我在org.apache.activemq包和子包中搜索了类，但不幸的是，我没有找到任何相关信息。
浏览 14提问于2022-11-27得票数 0
我在比较Apache Kafka和ActiveMQ (以及类似的消息队列产品)时发现的信息从来都不清楚每个解决方案的完整性属性(特别是一致性)。
使用Kafka，您可以获得即使在出现故障时也不会丢失消息的保证。使用"LazyPersistence“选项会失去这种保证吗？
所谓“无损失”，我的意思是消息将对客户端可用，即使在重启后出现故障-理想情况下，所有到达客户端的消息都以正确的顺序。
ActiveMQ ( "classic“或Artemis)是否保证失败时不会丢失消息？有没有什么配置选项可以保证这一点？如果"classic“和Artemis的答案不同，那就太好了。
浏览 3提问于2020-08-23得票数 0
我们正在使用WSO2 ESB进行ActiveMQ的传递。看来，WSO2将对每个请求使用一个新的连接，这使我们在一台机器上的吞吐量低于预期的吞吐量(500+并发用户)。在深入研究文档之后，我们发现您可以在JMSSender配置中使用缓存。这确实通过在生产者级别缓存(包括连接和会话缓存)来提高吞吐量，但缺点是如果Activemq机器被弹出，那么WSO2就不会重新连接，为了使它重新连接，就必须关闭缓存，从而使它对我们无法使用。
我很惊讶未能在ActiveMQ ESB中找到任何WSO2连接池设置。对于带有ActiveMQ ESB的WSO2连接池，是否真的没有任何配置，或者我们缺少一些明显的东西。在这里
浏览 0提问于2014-02-19得票数 0
2回答
有人知道一个将ActiveMQ连接到CXF的工作示例吗？我看到了许多将WebService连接到消息队列的例子，但我需要相反的方法。来自JMS队列的消息应转发到web服务，并将结果返回给调用方。
我的第一种方法只适用于只公开一种方法的web服务：
from("activemq:wsa").to("cxf:bean:webServiceA");
Status msg = producerTemplate.requestBody("activemq:wsa", params, Status.class);
但是对于具有多个方法的web服务，类似的
浏览 1提问于2012-10-17得票数 1
我在Apache中使用ActiveMQ。现在，我正在经历这样的问题:在ActiveMQ中，有大量的待定消息。消息处于挂起状态，排队列过程非常缓慢。
但看上去这并不能代表每一位消费者的数量。
我的理解是，通常有那么多挂起的消息，每个消费者的分派队列的大小应该已经接近默认的预取限制(即1000)，这是正确的吗？但对每个消费者来说只有20到80？
我对ActiveMq知之甚少。那么，我应该从哪里去了解如何解决这一问题呢？
连接配置 01为活动配置，02处于待机模式。
failover:(tcp://mq01:61616,tcp://mq02:61616)
Connection Fac
浏览 0提问于2018-03-05得票数 2
1回答
如果所有的消费者都被认为是缓慢的消费者，但如果只有少数消费者“缓慢”地使用AbortSlowConsumerStrategy断开他们(那些缓慢的)连接，那么在activeMQ中有没有办法“告诉”生产者放慢速度呢？
浏览 7提问于2014-11-06得票数 0
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
回答已采纳
我对ActiveMQ和Spring的CachingConnectionFactory有点问题。我这样设置它们：
<!-- A connection to ActiveMQ -->
<bean id="myConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="${jms.url}"/>
<property
浏览 0提问于2011-05-07得票数 7
回答已采纳
使用ActiveMQ v5.8
我使用javax.jms.MessageProducer.send()从我的生产者向ActiveMQ发送消息。
我想知道这个发送是同步的还是异步的？如果我使"useAsyncSend“标志变为真，行为将是什么？
谢谢，Anuj
浏览 1提问于2014-06-19得票数 1
回答已采纳
我应该在端口61616的地址10.7.1.10处向名为“ActiveMQ”的IngestGenericJSONQueue队列发送消息。我可以创建一个ActiveMQConnectionFactory对象，但是如何查找现有的队列呢？到目前为止，我只找到了session.createQueue()函数，但我不确定这是用来创建到现有队列的连接，还是只用于创建一个全新的队列。如何按名称连接到现有的activemq队列？
ConnectionFactory cFactory = new ActiveMQConnectionFactory("tcp://10.7.1.10:61616");
浏览 3提问于2015-07-09得票数 2
回答已采纳
1回答
我有一个场景：
生产者P产生消息，将它们全部发布到AMQ 'A‘(它是’P‘的本地)。
是否可以将消息从ActiveMQ A路由到远程活动MQs B或C？
基本上，我正在寻找'A‘端配置中的过滤器来路由这些消息。
提前谢谢你，马德哈夫
高拉夫
我的意思是，我在位置A、B和C分别有3个activeMQ实例，我在位置A有一个生产者bean 'P‘，它在本地将消息放在AMQ实例@A中，因为如果我远程连接到AMQ实例B或C，我在'P’中减轻了连接维护(减少)和消息丢失的可能性。
浏览 2提问于2012-09-20得票数 5
2回答
JMS消息过期不起作用
、、、
我需要在JMS主题中为我的消息设置消息过期时间。我尝试过设置message.setJMSExpiration()和producer.getTimeToLive()方法的属性。但我不这样认为，我发布的信息在我发布的主题中仍然活着。
我的疑问是，这些属性是否用于在到期时间到达后丢弃topic中的未订阅消息？或者在由特定订户订阅的消息之后。
我已经使用选择器来标识特定的客户端。
如果上面的任何一个属性不足以使消息过期，那么我是否需要任何其他配置来使消息在生产者端过期？
我正在使用带有JDK1.6的Apache ActiveMQ 5.8.0
浏览 0提问于2016-09-02得票数 0
我有一个关于ActiveMQ和producers的问题。
我应该为每一个消息的发送创建一个生产者吗？或者一直使用相同的一个？为每次发送创建一个生产者是否会对性能产生影响？
此外，在一段时间不活动后，连接会中断，但我不知道这是否与此有关，有什么建议吗？
浏览 3提问于2012-10-15得票数 0
回答已采纳
我已经定义了一个camel jetty-activemq路由，如下所示：
from("jetty:).to("activemq:queue:queue1)
camel是创建一个activemq连接，然后将该连接用于jetty接收的所有消息，还是为每个消息创建一个activemq连接。
我计划对activemq使用池连接，因为我每秒的消息流量相当高，我需要了解camel行为来定义最大连接池大小。
浏览 2提问于2012-10-29得票数 1
回答已采纳
2回答
因此，下面我有Camel (通过Spring )成功地将我的bean与ActiveMQ队列集成：
<!-- Note: this code is just a snippet; if you need to see more, please let me know! -->
<camelContext id="my-camel-context" xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="activem
浏览 2提问于2013-03-08得票数 5
当我试图连接到ActiveMQ 5.15.9并获取消息时，我遇到了以下错误。
2019-07-16 09:25:38.61 ERRORDTL 1563269138610javax.jms.JMSException:未能从内容构建主体.代理无法使用可序列化类。理由: java.lang.ClassNotFoundException:禁用类com.xxx.yyy.zzz.aaa！此类不受信任被序列化为ObjectMessage有效负载。有关如何配置受信任类的更多信息，请查看。在org.apache.activemq.util.JMSExceptionSupport.create(JMSExcept
浏览 0提问于2019-07-16得票数 2
回答已采纳
长时间侦听器，Stackoverflow上的第一个调用者:)
我有一个ActiveMQ经纪人，有一个生产者和消费者。生产者正在连接到一个activeMQ代理。有一个消费者依附于同一个经纪人。当我用这个设置发送消息时，P -> B -> C几乎没有延迟，消息以每条消息8ms的速率发送。
现在，我添加了另一个代理来创建代理网络，并使用以下配置发送消息:P -> B1 -> B2 -> C，每条消息需要多达80 as。
更多信息：
P和B1位于同一个数据中心，DC1。
B2和C位于同一个数据中心，DC2。
DC1和DC2是位于同一海岸的两个不同的数据中心，其ping延迟
浏览 3提问于2013-07-03得票数 1
回答已采纳
1回答
我使用的是ActiveMQ v5.10。
我无法理解在我的日志中出现异常的根本原因。
[20141116 13:07:30.288 EDT (ActiveMQ Broker[broker] Scheduler) org.apache.activemq.broker.region.Topic#doBrowse 615 WARN] - Failed to browse Topic: cometd.
ProxyPush
java.io.EOFException: Chunk stream does not exist, page: 34 is marked free
at org
浏览 1提问于2014-11-17得票数 2
1回答
涉及故障转移时(仅针对主题)，ActiveMQ会丢失大量消息。生产者在主题中写入1000条消息，而消费者(同时)从同一主题中阅读。在这个过程中，我关闭了ActiveMQ主服务器，这个过程在ActiveMQ从服务器上继续进行。在进行转换时，会丢失大量消息(大约100条消息)。我正在开发的产品涉及到不丢失消息。我可以为主题的持久化做些什么？制片人：
#include <activemq\library\ActiveMQCPP.h>
#include <cms\Connection.h>
#include <cms\Session.h>
#include <
浏览 45提问于2019-11-06得票数 0
1回答
ActiveMQ死连接问题
、、、、
嗨，我正在做ActiveMQ 5.10.0的工作，这是一个帷幕过程，它将通过一个TCP连接并发送消息到队列和主题订阅，总连接大约是10000。
当activeMQ中的最大连接超过最大连接时，在一些使用中遇到错误后，我已经通过了activemq控制台，发现许多TCP连接仍然处于活动状态为true的状态，此连接堆到10000和ActiveMQ抛出错误时超过了最大连接。
为什么这个连接永远保持状态为真，如何摆脱这个连接，有什么方法可以杀死这个死掉的连接，或者让连接在某个持续时间后过期。
谢谢..！
浏览 5提问于2017-04-19得票数 1
回答已采纳
3回答
我目前正在使用ActiveMQ来满足我的消息传递需求；除了几个db故障之外，它运行得很好。然而，我至少考虑尝试一下RabbitMQ。但在此之前，我想了解以下几点：
RabbitMQ与ActiveMQ有什么不同之处？RabbitMQ比ActiveMQ做的更好还是更糟？
相比之下，RabbitMQ配置的容易/困难程度如何？
RabbitMQ和Spring有多好的集成？
使用ActiveMQ，我只需将一个连接工厂bean连接到一个JmsTemplate中，并使用DefaultMessageListener bean将队列连接到它们各自的处理程序。我基本上可以对RabbitMQ做同样的事
浏览 0提问于2011-08-12得票数 52
我正在运行JDBC5.5.1，并且在配置日志ActiveMQ持久性时遇到了问题。使用时，我得到以下XML验证错误：
./activemq console xbean:my-activemq.xml
Java Runtime: Sun Microsystems Inc. 1.6.0_29 /home/aj/jdk1.6.0_29/jre
Heap sizes: current=253440k free=250641k max=253440k
JVM args: -Xms256M -Xmx256M -Dorg.apache.activemq.UseDedicatedTaskRun
浏览 0提问于2011-12-22得票数 2
回答已采纳
1回答
我有几台从Python生成xml文件的服务器，还有一些使用Java使用这些xml的其他服务器。我最近才研究过JMS和，并决定尝试使用它来传递xml文件。
因此，我在使用者服务器上设置了ActiveMQ守护进程，并认为我应该在产品上实现一些循环方法，以便在使用者之间均匀地分发xmls。
Python -----------------------------> ActiveMQ ---> Java
\ /
\ /
--------
浏览 2提问于2009-03-16得票数 2
回答已采纳
1回答
下面的代码尝试使用JMS在队列上发送消息。 connection = jmsConnectionFactory.createConnection();
connection.start();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue(queueName);
MessageProducer producer = session.createProducer(destination);
producer.s
浏览 85提问于2019-09-26得票数 0
回答已采纳
1回答
我是ActiveMQ的新手，在ActiveMQ中发送和存储大量的大消息(最大的消息大约是100 in )时遇到了一些困难。消息是持久化的，所以据我所知，它们存储在硬盘中，而不是内存中。但奇怪的是，当数据库大小( ActiveMQ文件夹)达到2.8Gb (占4GBJVM堆的70%)时，KahaDB就会崩溃。似乎ActiveMQ仍然将所有消息存储在内存中。我首先需要存储所有的信息，然后我将把它们全部消耗掉。
我的配置activemq.xml
<policyEntry queue=">" producerFlowControl="false" memory
浏览 1提问于2019-08-05得票数 1
回答已采纳
我正在使用ActiveMQ将电子邮件消息入队，消费者读取队列并发送电子邮件。
在启动时，我注册了一个生产者，并将其永久缓存。
PooledConnectionFactory factory = new PooledConnectionFactory(new ActiveMQConnectionFactory(jmsBrokerUserName, jmsBrokerPassword, activeMQBrokerURL));
Connection connection = factory.createConnection();
Session session = connection.creat
浏览 0提问于2014-06-30得票数 8
回答已采纳
1回答
当activemq收到大量消息或使用者失败时，一旦达到特定的(可配置的)限制，它将停止接受消息。在中，这一效应可以降低整个集群。
目前，我正在使用默认的内存限制配置，并体验了以下行为：
消费者失败或变得非常缓慢(已知的问题)
broker A(消费者连接的那个)被填充并停止接受消息
所有其他经纪人都会被填满，然后停下来接受消息。
星系团基本上是向下的
如果使用者现在恢复联机，它将尝试重新连接到其中一个集群节点，但节点将不接受连接，因为这将创建无法处理的咨询消息，因为代理已经满了。
如何配置内存限制，以使我的生产性目的地受到限制和阻塞，但代理仍然能够接受建议，以便我的消费
浏览 0提问于2012-01-02得票数 3
我有一个具有以下配置的DefaultMessageListenerContainer设置：
threadServiceListenerContainer(org.springframework.jms.listener.DefaultMessageListenerContainer) {
maxConcurrentConsumers = 10
concurrentConsumers = 1
destinationName = 'releaseThread'
pubSubDomain = false
浏览 4提问于2011-04-27得票数 0
回答已采纳
我们在Fuse ESB (7.1.0)中使用嵌入的activemq代理，消费者位于同一位置。
生产者客户端部署在远程GlassFish服务器上。它使用activeMQ资源适配器(5.6.0)和spring jms模板。客户端将消息发布到不同的队列。我希望一些消息(去往一个给定的队列)使用jms.useAsyncSend=true，而其他消息应该使用默认值。我看到下面的选项
1)我不能在资源适配器URL中附加'jms.useAsyncSend=true‘选项，因为这将对所有消息强制执行该选项。
2)连接工厂的JNDI查找返回'org.apache.activemq.ra.Acti
浏览 1提问于2013-10-16得票数 0
1回答
我正在使用ActiveMQConnectionFactory创建连接。我只创建了一个连接。我有许多线程在这个单一的连接下运行，创建会话和生产者(每个线程都有自己的会话和生产者)。
我的问题是:如果我只使用一个连接，那么我应该使用连接池(PooledConnectionFactory)还是应该坚持使用ActiveMQConnectionFactory。有没有人可以解释一下这两者之间的区别(可能是基本的，因为我在activemq中还处于学习曲线上)。
谢谢！
浏览 2提问于2013-01-08得票数 2
回答已采纳
我使用Apache Camel和ActiveMQ将消息路由到队列。为了实现高可用性，我们可以配置MQ服务器集群，以防系统出现故障。ActiveMQ还提供了failover功能。现在，我希望在TCP级别将两组MQ服务器的负载平衡到单个IP:端口。故障转移功能是否能够平衡两个MQ服务器的负载？
例如，一个IP是负载均衡的。
192.168.0.1:61616 --> 192.168.1.1:61616,192.168.1.2:61616
浏览 2提问于2016-08-30得票数 1
我有两个单独的Spring应用程序，它们使用骆驼-让我们称之为producer和consumer。
在producer过程中，骆驼ProducerTemplate向activemq:queue:consumer发送消息。
在consumer进程中，侦听该队列。
当我终止consumer进程时，我可以在AMQ控制台中看到队列没有使用者，producer向队列发送大约1000条消息，然后阻塞。
如果我清除队列，producer会解除并处理另外1000条消息，然后重复。
如果下游队列被备份，为什么producer进程会后退？我该怎么解决这个问题？
我使用的是Spring Boot 1.5.6，Cam
浏览 1提问于2017-10-26得票数 2
回答已采纳
我的MQ服务器是用ActiveMQ Artemis 2.17.0构建的。
最近，我意识到一些客户端连接到我的ActiveMQ Artemis，而不设置客户端id和订阅以及订阅某些主题。它们的队列变成了UUID，如下所示：
那么，我想知道如何强制ActiveMQ客户端设置客户端id和订阅名？如果它们不配置客户端id和订阅名称，ActiveMQ Artemis可以将它们踢出。
浏览 2提问于2021-12-23得票数 0
回答已采纳
2回答
我已经在上部署了一个Webservice，它使用Apache Camel调用ActiveMQ驱动的路由，代码类似于以下代码：
context.createProducerTemplate().sendBody("activemq:startComplex", xml);
调用工作正常，但过了一段时间后，我的Linux机器上的文件描述符达到了限制。资源被一大堆(几千个) ActiveMQ线程吞噬。在jmx控制台下，我可以看到许多类似以下内容的线程：
Name: ActiveMQ Transport: tcp://localhost/127.0.0.1:61616
State:
浏览 1提问于2012-05-11得票数 4
回答已采纳
1回答
当我需要在activemq中异步写入一个队列时，我有一个需求。我使用Spring Jms来做这件事。这是我的spring上下文文件中的连接
<bean id="amqProducerConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="${activemq.broker}"/>
</bean>
浏览 0提问于2013-05-11得票数 2
回答已采纳
我正在使用ActiveMQ主题。我的应用程序创建一些主题，并在这些主题上创建生产者和消费者。
当生产者发送一些东西时，它会收到返回的消息，因为在同一主题中也有一个关于此主题的消费者。
每个应用程序都有一个专门的主题(不同的代码，用于运行它的不同计算机)，并且有一个主要的中央核心进程，它将加入每个主题来处理消息，然后回复发布请求消息的主题。
一些主题是“通用”主题，其中一些消息不会有回复，但许多过程都会被考虑在内。
ActiveMQ中有没有什么东西可以阻止生产者接收回它发送的内容？
编辑:请注意，我是ActiveMQ的新手，我使用它的时间不长，并且只有非常基本的设置:没有持久性，就像简单的应用程
浏览 7提问于2016-08-19得票数 0
回答已采纳
1回答
客户希望通过ActiveMQ在应用程序和应用程序之间交换数据，因此我们希望创建一个接口规范文档，该文档描述两个应用程序必须使用的设置和属性，以便它们能够通信。我们不知道客户将使用哪种编程语言或API；因此，如果规范不完整，它们可能会隐式地使用我们不希望使用的设置。
因此，我想知道哪些设置必须在双方相同，哪些设置可以由每个应用程序自己决定。到目前为止，这就是我所拥有的：
必须在文件中具体说明：
连接器类型(开线，踏，.)
连接器设置(代理运行的主机名、TCP端口、用户名、密码)
消息类型(TextMessage，BytesMessage.)
有效载荷详细信息(XML与XSD，JS
浏览 3提问于2017-05-19得票数 1
我正在使用activeMQ tcp故障转移连接，并创建一个使用者，并订阅由生产者生成的主题。现在我如何管理网络故障？如果代理和客户端之间的连接中断，我如何知道何时再次建立连接？此外，我如何知道制片人是否已经启动和运行？如果制作人重新启动，我如何知道它，以便我可以重新订阅主题？
浏览 3提问于2017-04-25得票数 0
回答已采纳
我使用ActiveMQ作为我的JMS系统，它从logback的获取日志消息。客户端是一个网络应用程序。客户端和代理端都在不同的机器上。
我的要求是，如果客户端无法连接到代理，那么它应该存储消息直到它重新连接代理。我尝试使用中提到的故障转移。我的连接URL如下：
failover:(tcp://10.17.67.116:61616?wireFormat.maxInactivityDuration=0)?trackMessages=true&maxReconnectDelay=10000&timeout=3000
trackMessages=true属性应该在客户端缓存正在运行的消
浏览 1提问于2015-03-23得票数 0
回答已采纳
我有问题，开始我的春季网络应用与骆驼和ActiveMQ。
我得到的特别错误并不是非常描述性的：
16:18:53.552 [localhost-startStop-1] ERROR o.a.a.b.BrokerService - Failed to start Apache ActiveMQ ([activemq.myworkingdomain.com, ID:Ricardos-MacBook-Air.local-65257-1453738732697-0:2], {})
java.io.EOFException: null
at java.io.DataInputStream.readBoo
浏览 5提问于2016-01-25得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
