ActiveMQ 初學-1：ActiveMQ 創建連接對象

 

縣創建mq的連接工廠對象 ActiveMQConnectionFactory

 

 

// 1 建立ConnectionFactory 工廠對象，需要填入，需要填入用戶名密碼，

// 用戶名 密碼 在 activemq.xml 中安全插件配置
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
         ActiveMQConnectionFactory.DEFAULT_USER,
        //"wator",
         ActiveMQConnectionFactory.DEFAULT_PASSWORD,
        //"wator",
        "tcp://http://192.168.152.142:8161/" // 在activemq.xml 配置文件中，有多種協議連接方式
);

 

 

 

這里的ConnectionFactory 是javax.jms.中的接口。

 

 

---

接下來

 
// 2 通過 ConnectionFactory 創建一個鏈接對象，打開鏈接
Connection connection = connectionFactory.createConnection();
connection.start();

 

 

connection 使用前需要調用 start() 方法。

 

這樣就創建了一個mq的connection連接對象。