Hello world程序演示：
生产者：
代码语言：javascript复制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.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();
}
}
} 消费者：
代码语言：javascript复制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节点中的末尾增加下面的内容
代码语言：javascript复制 <plugins>
<simpleAuthenticationPlugin>
<users>
<authenticationUser username="bhz" password="bhz" groups="users,admins"/>
</users>
</simpleAuthenticationPlugin>
</plugins>然后，再访问MQ时就需要认证了，在生产者和消费者第一步中将default_user、default_password换成配置文件中自定义的username和password即可访问MQ。
生产者详解：
消费者详解：
