ActiveMQ 学习札记一
Apache ActiveMQ™是最流行的开源，多协议，基于Java的消息服务器。它支持行业标准协议，因此用户可以通过广泛的语言和平台获得客户选择的好处。可以使用C，C ++，Python，.Net等连接。使用无处不在的AMQP协议集成您的多平台应用程序。使用STOMP通过websockets 在Web应用程序之间交换消息。使用MQTT管理您的IoT设备。支持您现有的JMS基础架构及其他。ActiveMQ提供强大的功能和灵活性，以支持任何消息传递用例。-----摘自
创建使用java 创建activeMQ：
一、创建ActiveMQConnectionFactory
ActiveMQConnectionFactory是一个受管理的对象，用于创建连接。该类还实现QueueConnectionFactory基于队列的不共享消息 和 TopicConnectionFactory-基于 发布/订阅 的消息队列。您可以使用此连接创建QueueConnections和TopicConnections。
二、根据连接工厂ActiveMQConnectionFactory创建连接
Connection connection=activeMQConnectionFactory.createConnection();
三、打开连接
connection.start();
四、创建会话session
/**
* createSession：可选参数有：
* param1：指示是否处理会话-true/false
* param2： Session.AUTO_ACKNOWLEDGE 自动确认
Session.CLIENT_ACKNOWLEDGE 客户端确定
Session.DUPS_OK_ACKNOWLEDGE 自动批量确认
*
*/
Session session=connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
五、创建消息队列
/**
* 可以允许创建不同的消息目标
* Topic topic=session.createTopic(MESSAGE_NAME);//基于发布-订阅 一个消息，多个客户端消费
Queue queue=session.createQueue(MESSAGE_NAME);--//基于 不可重复消费的 队列型消息
*/
Destination destination=session.createQueue(MESSAGE_NAME);
六、创建消息发布者或生产者
MessageProducer messageProducer=session.createProducer(destination);--消息发布者
//创建消费
MessageConsumer consumer=session.createConsumer(destination);
七、生产者生产消息
/**
* 消息类型可以有：
* ObjectMessage:对象消息
* TextMessage :文本类型
* MapMessage ：键值对类型
* StreamMessage ：流类型
* BytesMessage :字节型
*/
//文本型消息
TextMessage message=session.createTextMessage();
//若Session.CLIENT_ACKNOWLEDGE为客户端确认。客户端接收到消息后，
//必须调用javax.jms.Message的acknowledge方法。jms服务器才会删除消息。
//message.acknowledge();
message.setText("produect 发送消息 ：第"+i+"次");
//接收一个参数为Message的消息
messageProducer.send(message);
消费者创建消息侦听，侦听生产者生产消息
//消费者侦听消息
consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
/**
*Message类型可以有：
* ObjectMessage:对象消息
* TextMessage :文本类型
* MapMessage ：键值对类型
* StreamMessage ：流类型
* BytesMessage :字节型
*/
try {
TextMessage msg=(TextMessage) message;//与消息生成这消息类型一致
System.out.println("客户端B 侦听到 发送者消息："+msg.getText());
} catch (Exception e) {
}
}
});
八、关闭连接
一个简单的activeMQ消息队列demo就创建好了，分别运行生产者，消费者就可看到结果，代码图：
生产者：
消费者：