在故障转移时,使用Web服务将消息丢弃到ActiveMQ队列上会失败

dnulla 发布于 2019-03-09 activemq 最后更新 2019-03-09 14:39 3 浏览

我有两个activeMQ(5.6.0)经纪人。他们使用一个共享的kaha数据库,因此只有一个可以同时“运行”。 我有一个(asp.net)web服务,将消息放入队列,本地如果我启动并停止代理web服务正确地进行故障转移 当我在单独的机器上测试经纪人时,它有时会起作用,但我经常会遇到“socketException:连接重置”错误,并且信息丢失。 下面是我使用的连接字符串。请注意,我知道NMS不理解优先级备份命令,但我已将它留在将来。

failover:(tcp://MACHINE1:61616,tcp://MACHINE2:62616)?transport.initialReconnectDelay=1000&transport.timeout=10000&randomize=false&priorityBackup=true
我怎样才能让我的经纪人之间的失败证明无误?
已邀请:

eet

赞同来自:

共享的Kaha数据库只是一个简单的共享。目前,activeMQ(或windows)无法在此配置中可靠地获取或释放锁定。共享数据库必须位于“真正的”SAN上,以便队列软件的两个实例都将数据库视为位于本地文件存储上而不是网络位置。 有关详细信息,请参阅此页http://activemq.apache.org/shared-file-system-master-slave.html