ActiveMQ简介
ActiveMQ是Apache出品，最流行的，能力强劲的开源消息总线。
ActiveMQ是一个完全支持JMS1.1和J2EE 1.4规范的JMS Provider实现，
尽管JMS规范出台已经是很久的事情了，但是JMS在当今的J2EE应用中间仍
然扮演着特殊的地位，可以说ActiveMQ在业界应用最广泛，当然如果想要有
更强大的性能和海量数据处理能力，ActiveMQ还需要不断的升级版本，80%
以上的业务我们使用ActiveMQ以及足够满足需求，当然后续如天猫、淘宝网
这种大型的电商网站，尤其是双11这种特殊时间，ActiveMQ 需要进行很复杂
的优化源码以及架构设计才能完成。
DEMO
Sender/Receiver:
生产者
第一步:建立ConnectionFactory工厂 对象，需要填入用户名、密码、以及要连接的地址，
均使用默认即可，默认端口为"tcp://localhost:61616
ConnectionFactory connectionFactory = new Ac tiveMQconnectionFactory(
ActiveMQConnectionFactory. DEFAULT USER,
ActiveMQConnectionFactory. DEFAULT PASSWORD,
“tcp://localhost:61616");
第二步:通过ConnectionFactory工厂对象我们创建一- 个Connection连接，并且调用
Connection的start方法开启连接，Connection默认是关闭的.
Connection connection =connectionFactory.createConnection();
connection.Start();
第三步:通过Connection对象创建Session会话(上下文环境对象)，用于接收消息，参数配置1为是否启用是事务（true为启用，false不启用），参数配置2为签收模式，-般我们设置自动签收。
Session session = connection. createSession (Boolean. FALSE, Session . AUTO ACKNOWLEDGE);
第四步:通过Session创建Destination对象， 指的是-一个客户端用来指定生产消息目标和消费消息来源的对象，在PTP模式中，Destination被 称作Queue即队列;在Pub/Sub模式，Destination被称作Topic即主题。在程序中可以使用多个Queue和Topic.(queue1 为消息队列名称，生产者和消费者必须一致)
Destination desiDestination = session.createQueue ( "queue1 ");
第五步:我们需要通过Session对象创建消息的发送和接收对象(生产者和消费者)Message Producer/MessageConsumer.
MessageProducer messageProducer = session.createProducer(desiDes tination) ;
第六步:我们可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性(DeliveryMode)，我们稍后详细介绍。（DeliveryMode.NON PERSISTEN 非持久化 DeliveryMode.PERSISTEN 持久化）
messageProducer.setDeliveryMode(DeliveryMode.NON PERSISTENT) ;
第七步:最后我们使用JMS规范的TextMessage形式创建数据(通过Session对象)，并用MessageProducer的send方法发送数据。同理客户端使用receive方法进行接收数据。最后不要忘记关闭Connection连接。
for(inti = 1; 1<= 5; 1++){
TextMessage textMessage = session.createTextMessage () ;
textMessage.setText ("我是消息内容,id为:”+ i);
messageProducer.send(textMessage);
}
if (connection != null) {
connection.close();
}
消费者
第一步:建立ConnectionFactory工厂 对象，需要填入用户名、密码、以及要连接的地址，
均使用默认即可，默认端口为"tcp://localhost:61616
ConnectionFactory connectionFactory = new Ac tiveMQconnectionFactory(
ActiveMQConnectionFactory. DEFAULT USER,
ActiveMQConnectionFactory. DEFAULT PASSWORD,
“tcp://localhost:61616");
第二步:通过ConnectionFactory工厂对象我们创建一- 个Connection连接，并且调用
Connection的start方法开启连接，Connection默认是关闭的.
Connection connection =connectionFactory.createConnection();
connection.Start();
第三步:通过Connection对象创建Session会话(上下文环境对象)，用于接收消息，参数配置1为是否启用是事务（true为启用，false不启用），参数配置2为签收模式，-般我们设置自动签收。
Session session = connection. createSession (Boolean. FALSE, Session . AUTO ACKNOWLEDGE);
第四步:通过Session创建Destination对象， 指的是-一个客户端用来指定生产消息目标和消费消息来源的对象，在PTP模式中，Destination被 称作Queue即队列;在Pub/Sub模式，Destination被称作Topic即主题。在程序中可以使用多个Queue和Topic.(queue1 为消息队列名称，生产者和消费者必须一致)
Destination desiDestination = session.createQueue ( "queue1 ");
第五步:我们需要通过Session对象创建消息的发送和接收对象(生产者和消费者)Message Producer/MessageConsumer.
MessageConsumer messageConsumer = session.createConsumer (desiDestina tion) ;
第六步:接收生产者生产的数据
while (true ){
TextMessage msg = (TextMessage) messageConsumer.receive();
if (msg == null) {
break;
system.out.println ("收到的内容:”+ msg.getText());
}
if (connection != null) {
connection.close();
}