activemq从节点获取不了主节点的队列内容?

activemq以jdbc持久化master+slave的方式配置(没有用zookeeper),启动时已看到链接成功

2019-05-14 11:15:28,562 | INFO  | Network connection between vm://slave#0 and tcp://0.0.0.0:61616 (master) has been established. | org.apache.activemq.network.DemandForwardingBridgeSupport | triggerStartAsyncNetworkBridgeCreation: remoteBroker=unconnected, localBroker= vm://slave#0

链接url,因为开发电脑虚拟出了两台虚机,所以都是61616端口,下面的ip实际上是不一样的

private String brokerURL = "failover://(tcp://0.0.0.0:61616,tcp://0.0.0.0:61616)";

两个节点启动完成后,程序发送信息

    public static void main(String[] args) {
        TestContro send = new TestContro();
        send.start();
    }

//    public static void main(String[] args) {
//      TestContro cons = new TestContro();
//      cons.consum();
//    }
//    
    public void start(){
        try {
            //根据用户名,密码,url创建一个连接工厂
            factory = new ActiveMQConnectionFactory(userName, password, brokerURL);
            //从工厂中获取一个连接
            connection = factory.createConnection();
            //测试过这个步骤不写也是可以的,但是网上的各个文档都写了
            connection.start();
            //创建一个session
            //第一个参数:是否支持事务,如果为true,则会忽略第二个参数,被jms服务器设置为SESSION_TRANSACTED
            //第二个参数为false时,paramB的值可为Session.AUTO_ACKNOWLEDGE,Session.CLIENT_ACKNOWLEDGE,DUPS_OK_ACKNOWLEDGE其中一个。
            //Session.AUTO_ACKNOWLEDGE为自动确认,客户端发送和接收消息不需要做额外的工作。哪怕是接收端发生异常,也会被当作正常发送成功。
            //Session.CLIENT_ACKNOWLEDGE为客户端确认。客户端接收到消息后,必须调用javax.jms.Message的acknowledge方法。jms服务器才会当作发送成功,并删除消息。
            //DUPS_OK_ACKNOWLEDGE允许副本的确认模式。一旦接收方应用程序的方法调用从处理消息处返回,会话对象就会确认消息的接收;而且允许重复确认。
            session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
            //创建一个到达的目的地,其实想一下就知道了,activemq不可能同时只能跑一个队列吧,这里就是连接了一个名为"text-msg"的队列,这个会话将会到这个队列,当然,如果这个队列不存在,将会被创建
            destination = session.createQueue("test");
            //从session中,获取一个消息生产者
            producer = session.createProducer(destination);
            //设置生产者的模式,有两种可选
            //DeliveryMode.PERSISTENT 当activemq关闭的时候,队列数据将会被保存
            //DeliveryMode.NON_PERSISTENT 当activemq关闭的时候,队列里面的数据将会被清空
            producer.setDeliveryMode(DeliveryMode.PERSISTENT);

            //创建一条消息,当然,消息的类型有很多,如文字,字节,对象等,可以通过session.create..方法来创建出来
            TextMessage textMsg = session.createTextMessage("呵呵");
            for(int i = 0 ; i < 3 ; i ++){
                //发送一条消息
                producer.send(textMsg);
            }
            System.out.println("发送消息成功");
            //即便生产者的对象关闭了,程序还在运行哦
            producer.close();

        } catch (JMSException e) {
            e.printStackTrace();
        }
    }

在主节点控制台能看到待消费数量增加,但是从节点看不到数量变化,而且杀死主节点后,程序自动连接从节点发送,mq报数据库主键冲突
配置文件

<networkConnectors>
<networkConnector uri="static:(tcp://x.x.x.x:61616)" duplex="false"/>
</networkConnectors>

求大神帮忙看看。

Lin245709189
Lin245709189 配置多了个Database lock driver override not found for,由于没贴出来,还是给分吧
大约一年之前 回复

1个回答

Lin245709189
Lin245709189 试过按照链接的配置,两个节点启动成功,也可以正常切换,但是关闭主节点切换到从节点时。从节点队列内同不会自动读取数据库内,导致插入信息时报数据库主键冲突
大约一年之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问
相关内容推荐