ActiveMQ -故障切换和useAsyncSend

文章/答案/技术大牛

发布

1回答

activemq、failover

ActiveMQ关闭时，应用程序在连接时挂起。在尝试发送消息时，我可以以某种方式继续每个连接的故障转移和异步，而不阻塞线程吗？

浏览 14提问于2018-02-02得票数 0

回答已采纳

1回答

我有两个关于ActiveMQ故障转移协议的问题。failover:(tcp://192.168.1.111:61616)?nested.jms.useAsyncSend=true&initialReconnectDelay=1000&maxReconnectAttempts=-1 问题2：下面的url运行良好。它还在第一次重新启动时重新连接到ActiveMQ，但是当我第二次关闭Active

浏览 0提问于2016-04-30得票数 1

1回答

对一些消息使用'jms.useAsyncSend=true‘，并在消费者端验证它

glassfish、apache-camel、activemq、fuseesb

我们在Fuse ESB (7.1.0)中使用嵌入的activemq代理，消费者位于同一位置。生产者客户端部署在远程GlassFish服务器上。它使用activeMQ资源适配器(5.6.0)和spring jms模板。客户端将消息发布到不同的队列。2)连接工厂的JNDI查找返回'org.apache.activemq.ra.ActiveMQConnectionFactory'.的一个实例实际上，我期待的是org.apache.activemq.ActiveMQConnectionFac

浏览 1提问于2013-10-16得票数 0

2回答

PooledConnectionFactory和CachingConnectionFactory哪个更好？

java、spring、tomcat、jms、activemq

我们在Tomcat (7.0.41)中使用Spring (3.2.4)和ActiveMQ (5.8.0)，还不清楚最好的用法是什么。()在使用PooledConnectionFactory时需要将useAsyncSend=设置为“true”吗？()

浏览 6提问于2013-10-24得票数 32

回答已采纳

3回答

故障转移传输对单个URI有什么作用

activemq

在我的ActiveMQ客户机中，当我指定要连接到哪个代理时，指定和我已经尝试过停止和启动代理，在这两种情况下，客户端在重新启动时都会再次找到代理我还没有对流中的消息(我正在使用队列)或其他网络故障进行试验，以查看是否存在差异。谢谢

浏览 0提问于2013-06-22得票数 5

回答已采纳

2回答

当ActiveMQ关闭时，Camel消费者不能重新连接

apache-camel、activemq

我们有多个使用者连接到一个ActiveMQ代理。当ActiveMQ关闭或死亡时，消费者也会死亡。有没有办法让它们保持运行，并在ActiveMQ重启时自动重新连接？它还需要与故障转移一起工作。

浏览 0提问于2015-05-21得票数 1

2回答

Apache ActiveMQ* 5.10.0中仅在项目中的身份验证和授权问题*

spring、ssl、activemq

我试图仅在SSL上配置ApacheSS5.10.0，并在ActiveMQ上测试身份验证和授权。为了进行身份验证和授权，我在activemq.xml中使用了以下插件。我只希望“系统”用户能够连接，并且没有其他来宾用户或不正确的用户名可以访问： <!<property name="redeliveryPolicy" ref="redeliveryPolicy"/> <prop

浏览 1提问于2014-07-21得票数 0

回答已采纳

1回答

Apache Camel + ActiveMQ。两个代理之间的消息传输速度太慢

java、apache、apache-camel、activemq

我试图通过Apache Camel在2个ActiveMQ代理之间传输消息，问题是我只能达到大约每秒135条消息的传输速度。我想增加这个数字。情况是我在远程服务器上有2个ActiveMQ代理。

浏览 6提问于2015-10-08得票数 2

2回答

添加ActiveMQ* broker*

java、jms、activemq

我希望我的ActiveMQ有两个活动的代理。如何在activemq.xml文件中定义这个代理？我尝试通过复制并粘贴默认代理并更改端口和名称来添加代理，但在尝试运行activemq时会抛出异常。谢谢。

浏览 0提问于2013-01-29得票数 1

回答已采纳

1回答

JAX-WS连接不会关闭，并在x条消息后停止消息传递

java、spring、jms、activemq、messaging

我使用ActiveMQ作为妈妈和Spring。消息传递非常简单:一个jar应该向另一个jar发送包含一些数据的soap消息。org.apache.cxf.transport.jms.JMSConfiguration" p:targetDestination="activemqsessionCacheSize" value="40" />

浏览 0提问于2012-11-29得票数 2

回答已采纳

1回答

禁用Camel ActiveMQ消费者连接日志

apache-camel、activemq

我正在使用Spring DSL来消费消息。"Successfully connected to ssl://hostname:port"

浏览 0提问于2017-10-06得票数 0

1回答

ActiveMQ故障切换传输选项未按预期工作

activemq、failover、nms、apache-nms

我想使用中所述的ActiveMQ故障切换传输。然而，由于“永远”有时太长，我尝试设置一些选项，以便更早地终止重试。如何配置故障转移传输，使其在代理不可用的情况下在启动时终止重新连接尝试？我使用的是ActiveMQ版本5.15.9 ()和Apache.NMS.ActiveMQ库版本1.8。

浏览 14提问于2021-02-12得票数 0

1回答

AMAZON提供TCP端点吗？

amazon-web-services、activemq、amazon-mq

我在Amazon上创建了一个代理，并在端口61617上获得了一个SSL端点。我还在寻找一个非SSL端点(就像我们可以在Active MQ上使用61616的tcp )。Amazon只提供SSL吗？无论如何，我们也可以得到TCP端点吗？

浏览 0提问于2019-07-16得票数 2

回答已采纳

1回答

ActiveMQ:内存/数据存储区已满时的故障转移

java、activemq、messaging

如果其中一个代理实例停止运行，ActiveMQ中的故障转移传输就会正常工作-生产者会自动切换到下一个正常的代理实例。如果broker达到它的内存限制(通过activemq.xml中的systemUsage属性配置)，我预计也会出现同样的行为。convertAndSend上抛出org.springframework.jms.ResourceAllocationException: Usage Manager Store is Full异常，并且无论如何都没有切换到好的代理实例有人能建议如何在异常和<

浏览 5提问于2013-10-30得票数 2

1回答

在Grails中使用rabbitmq插件可以定义回退/故障转移地址吗？

grails-plugin-rabbitmq

我正在将一个Grails项目从使用ActiveMq转换为使用RabbitMq。是否可以使用多个回退/故障切换地址配置RabbitMQ？

浏览 1提问于2015-01-16得票数 1

1回答

当一个消费者崩溃时，ActiveMQ多用户停止消费

apache-camel、activemq、apache-karaf、jbossfuse、blueprint-osgi

检查当前的设计如下，根2- AMQ 2和骆驼2 骆驼1,2和3正在处理来自AMQ的信息。问题：我们在AMQ中处理了1000条信息，这些消息被所有消费者使用，即骆驼1、2和3，但当任何消费者(骆驼

浏览 2提问于2019-01-10得票数 0

1回答

用于生成持久文本消息的ActiveMQ性能

activemq、persistent

正如在网页上建议的那样，我尝试过(在带有Windows7OS和SSD驱动器的英特尔i7笔记本电脑上)在ActiveMQ队列中生成持久消息的性能：对应于默认安装的activemq 5.12.1 当在一个盒子上运行服务器，在另一个盒子上单独运行一个生产者

浏览 3提问于2015-10-27得票数 0

回答已采纳

2回答

在activemq中更改预取值的位置

jms、activemq

根据我的理解，如果我将activemq值=1分配给消费者A，我会阅读有关prefetch buffer.As的文档。Activemq向A推送一条消息activemq A向Prefetch发送确认，然后仅.once向A推送另一条消息。我的疑问是，我需要将预取值分配给消费者。

浏览 2提问于2013-09-05得票数 11

1回答

ActiveMQ -处理连接、会话、生产者和消费者操作故障切换

jms、activemq、failover

我通过在代理URL中使用以下模式来使用故障转移传输功能初始化代码如下：TextMessage msg = session.createTextMessage(message);发生故障切换时- [org.apache.activemq.transport.fail

浏览 2提问于2015-06-03得票数 0

1回答

ActiveMQ Artemis在HA失效期间发布消息丢失。

activemq-artemis

我使用ActiveMQ Artemis 2.17.0，并且我希望避免在故障转移期间生产者中的消息丢失。通过捕获ActiveMQUnBlockedException并再次发送消息，在Artemis主动切换到被动切换期间处理消息发布丢失。代理被配置为主动/被动HA共享存储。在主动到被动切换期间，发布代码会抛出ActiveMQUnBlockedException，而不是在被动切换到主动切换期间。我们使用Spring4.2.5和CachingConn

浏览 1提问于2021-03-20得票数 0

回答已采纳

点击加载更多