ActiveMQ的最简单应用-队列消息

有一段时间不使用JMS了。现在的项目又有可能需要应用JMS，来提高服务质量和提高系统资源的利用率。

提高服务质量，主要是保证不间断的服务。用JMS服务器接收任务，排成队列。应用服务可以暂停做维护，不影响接收的任务。应用服务运行后，再从队列中获取任务。

提高系统资源的利用率，主要是任务的派发不是24小时平均的，而是高峰时期任务量很多，比如1秒1000多个，有的时候很低，比如十几秒钟才来一个。应用服务通过JMS队列一个一个的取任务，做完一个再领一个，使系统资源的运用趋于平均。而JMS，比如JMS接收消息的效率是很高的，比如ActiveMQ，在赛扬（2.40GHz）机器上能够达到2000/s，消息大小为1-2k。好一些的服务器可以达到2万以上/秒。

ActiveMQ是开源免费的JMS实现，并且有很多扩展功能。地址：

​​http://activemq.apache.org​​

安装和运行很简单，下载后解压缩，执行：

activemq.bat

将启动默认配置的activemq。可以通过：

​​http://localhost:8161/admin​​

访问activemq的管理界面。查看队列（queue）和主题（topic）下的消息内容。

编写ActiveMQ程序前需要准备类库，如果使用maven就简单了：

<
   dependency
   >
   
  
   <
   groupId
   >
   org.apache.activemq
   </
   groupId
   >
   
  
   <
   artifactId
   >
   activemq-core
   </
   artifactId
   >
   
  
   <
   version
   >
   5.2.0
   </
   version
   >
   

   </
   dependency
   >

编写最简单的向JMS队列发送文本消息的程序：

ActiveMQConnectionFactory connectionFactory 
   =
    
   new
    ActiveMQConnectionFactory(
        
   "
   tcp://localhost:61616
   "
   );
Connection connection 
   =
    connectionFactory.createConnection();
connection.start();
System.out.println(
   "
   start...
   "
   );

Session session 
   =
    connection.createSession(
   true
   ,
        Session.AUTO_ACKNOWLEDGE);
Queue destination 
   =
    session.createQueue(
   "
   example.C
   "
   );

MessageProducer producer 
   =
    session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.PERSISTENT);

TextMessage message 
   =
    session.createTextMessage(
   "
   中文
   "
   );
producer.send(message);
session.commit();

connection.close();
System.out.println(
   "
   send text ok.
   "
   );

执行程序后可通过上面提到的web界面查看example.C队列中收到的消息。不过中文信息显示的是??。这没有关系，是admin web应用自身的问题（使用的是iso-8859-1编码）。队列里的数据是对的。

异步接收数据的代码如下：

ActiveMQConnectionFactory connectionFactory 
   =
    
   new
    ActiveMQConnectionFactory(
        
   "
   tcp://localhost:61616
   "
   );
Connection connection 
   =
    connectionFactory.createConnection();
connection.start();

   final
    Session session 
   =
    connection.createSession(
   true
   ,
        Session.AUTO_ACKNOWLEDGE);
Queue destination 
   =
    session.createQueue(
   "
   example.C
   "
   );

MessageConsumer consumer 
   =
    session.createConsumer(destination);
consumer.setMessageListener(
   new
    MessageListener(){
    @Override
    
   public
    
   void
    onMessage(Message message) {
        System.out.println(message);
        
   try
    {
            session.commit();
        } 
   catch
    (JMSException e) {
            e.printStackTrace();
        }
    }
});