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连接对象。

巴特西

ActiveMQ 初学-1：ActiveMQ 创建连接对象

最新文章

热门文章