ActiveMQ的静态网络配置

static networkConnector是用于创建一个静态的配置对于网络中的多个Broker做集群，这种协议用于复合url，一个复合url包括多个url地址。

<networkConnectors>
             <networkConnector name="local network"  duplex="true"
              uri="static://(tcp://192.168.174.104:61616,tcp://192.168.174.104:61676)"/>
</networkConnectors>

常用networkConnector配置的可用属性：

　　conduitSubscriptions ：默认true，是否把同一个broker的多个consumer当做一个来处理

　　duplex ：默认false，设置是否能双向通信

消息发送代码

public class JmsSend {
    
    public static void main(String[] args) throws JMSException {
        ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.174.104:61616");
        Connection connection = connectionFactory.createConnection();
        
        connection.start();
        
        Session session=connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
        Destination queue=session.createQueue("my-queue4");
        
    
        MessageProducer producer=session.createProducer(queue);
        
        
        for(int i=0 ; i<20 ; i++){
             TextMessage message=session.createTextMessage("message"+i);
             //message.setStringProperty("queue", "queue"+i);
             //message.setJMSType("1");
             producer.send(message);
        }
        session.commit();
        session.close();
        
        connection.close();
        
    }

}

View Code