activeMQ集群常见问题

1、关于虚拟主题发送订阅

• 发送主题必须是topic
• 接收主题必须是queue

2、activeMQ插件编写

• 集群会产生NC开头的连接id，此连接用于对其他节点数据转发
• 重写send方法需要屏蔽包含localhost连接id，否则会覆盖掉其他节点设置的属性

 @Override
    public void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception {
        if(!producerExchange.getConnectionContext().getClientId().contains("localhost")){
            messageSend.setProperty(ptpClientID,producerExchange.getConnectionContext().getClientId());
        }
        super.send(producerExchange, messageSend);
    }

• 对连接ip控制进行屏蔽控制时也需要屏蔽包含localhost 的连接id，否则会导致集群失效