ActiveMQ入门代码

Hello world程序演示：

生产者：

package com.mq.helloworld;import ja����,����vax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.DeliveryMode;import javax.jms.Destination;import javax.jms.JMSException;import javax.jms.MessageProducer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;public class Sender {    public static void main(String[] args) throws JMSException {        //第一步：建立ConnectionFactory工厂对象，需要填入用户名、密码、以及要连接的地址，均使用默认即可。默认端口为"tcp://localhost:61616"        ConnectionFactory connectionfactory=new ActiveMQConnectionFactory(                ActiveMQConnectionFactory.DEFAULT_USER,                ActiveMQConnectionFactory.DEFAULT_PASSWORD,                "tcp://localhost:61616"                );        //第二步：通过ConnectionFactory工厂对象，我们创建一个Connection连接，并且调用Connection的start方法开启连接，Connection默认是关闭的        Connection connection = connectionfactory.createConnection();        connection.start();        //第三步：通过Connection对象创建Session会话（上下文环境对象），用于接收消息，参数配置1为是否启用事务，参数配置2为签收模式，一般设置为手动签收        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);        //第四步：通过Session创建Destination对象，指的是一个客户端用来指定生产消息目标和消费消息来源的对象，在PTP模式中，Destination被称为Queue即队列；在Pub/Sub模式中，Destination被称作Topic即主题，在程序中可以使用多个Queue和Topic        Destination destinition=session.createQueue("queue1");        //第五步：我们需要通过Session对象创建消息的发送和接收对象（生产者和消费者）MessageProducer/MessageConsumer        MessageProducer messageProducer = session.createProducer(destinition);        //第六步：我们可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性(DeliveryMode)        messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);        //第七步：最后我们使用JMS规范的TextMessage形式创建数据（通过Session对象）,并用MessageProducer的send方法发送数据        TextMessage textMessage = session.createTextMessage();        textMessage.setText("Hello World!");        messageProducer.send(textMessage);        if(connection!=null){            connection.close();        }    }}     

消费者：

package com.mq.helloworld;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.DeliveryMode;import javax.jms.Destination;import javax.jms.JMSException;import javax.jms.MessageConsumer;import javax.jms.MessageProducer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;public class Receiver {    public static void main(String[] args) throws JMSException {        //第一步：建立ConnectionFactory工厂对象，需要填入用户名、密码、以及要连接的地址，均使用默认即可。默认端口为"tcp://localhost:61616"        ConnectionFactory connectionfactory=new ActiveMQConnectionFactory(                ActiveMQConnectionFactory.DEFAULT_USER,                ActiveMQConnectionFactory.DEFAULT_PASSWORD,                "tcp://localhost:61616"                );        //第二步：通过ConnectionFactory工厂对象，我们创建一个Connection连接，并且调用Connection的start方法开启连接，Connection默认是关闭的        Connection connection = connectionfactory.createConnection();        connection.start();        //第三步：通过Connection对象创建Session会话（上下文环境对象），用于接收消息，参数配置1为是否启用事务，参数配置2为签收模式，一般设置为自动签收        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);        //第四步：通过Session创建Destination对象，指的是一个客户端用来指定生产消息目标和消费消息来源的对象，在PTP模式中，Destination被称为Queue即队列；在Pub/Sub模式中，Destination被称作Topic即主题，在程序中可以使用多个Queue和Topic        Destination destinition=session.createQueue("queue1");        //第五步：我们需要通过Session对象创建消息的发送和接收对象（生产者和消费者）MessageProducer/MessageConsumer        MessageConsumer messageConsumer = session.createConsumer(destinition);        //第六步：最后我们使用JMS规范的TextMessage形式接收数据        while (true) {            TextMessage msg=(TextMessage) messageConsumer.receive();            System.out.println(msg.getText());            if(msg==null) break;        }                if(connection!=null){            connection.close();        }    }}

 安全认证机制：

在activemq.xml文件中的broker节点中的末尾增加下面的内容

        <plugins>            <simpleAuthenticationPlugin>                <users>                    <authenticationUser username="bhz" password="bhz" groups="users,admins"/>                </users>            </simpleAuthenticationPlugin>        </plugins>

然后，再访问MQ时就需要认证了，在生产者和消费者第一步中将default_user、default_password换成配置文件中自定义的username和password即可访问MQ。

生产者详解：

消费者详解：