JMS 中间件：activeMQ, JMS 入门

JMS入门，使用activeMQ 发送，接收消息。
首先，下载 apache-activemq-5.4.0。http://activemq.apache.org/download.html，
解压，然后双击 bin/activemq.bat。
把 activemq-all-5.3.0.jar 加入 classpath.

构建Sender.java 和Receiver.java ：

import java.util.Date;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.MapMessage;
import javax.jms.MessageProducer;
import javax.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory;

public class Sender {

 public static void main(String[] args){
    try{
  ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(); 
   
     Connection connection = connectionFactory.createConnection(); 
     connection.start(); 
  
     Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); 
     Destination destination = session.createQueue("queue"); 
  
     MessageProducer producer = session.createProducer(destination); 
     System.out.println("init");
     for(int i=0; i<3; i++) { 
         MapMessage message = session.createMapMessage(); 
         message.setLong("count", new Date().getTime()); 
         Thread.sleep(1000); 
         //通过消息生产者发出消息 
         producer.send(message); 
        
     } 
     session.commit(); 
     session.close(); 
     connection.close(); 
    }
    catch(Exception e){
     
    }
 }
}

接收者：

import java.util.Date;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.MapMessage;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory;

public class Receiver {

 public static void main(String[] args) {
 try{
  ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(); 
   
     Connection connection = connectionFactory.createConnection(); 
     connection.start(); 
  
     final Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); 
     Destination destination = session.createQueue("queue"); 
  
     MessageConsumer consumer = session.createConsumer(destination); 
     /*//listener 方式
     consumer.setMessageListener(new MessageListener() {
 
         public void onMessage(Message msg) {
             MapMessage message = (MapMessage) msg;
             //TODO something....
             System.out.println(" 收到消息：" + new Date(message.getLong("count")));
             session.commit();
         }
 
     });
     Thread.sleep(30000);
     */ 
     int i=0; 
     while(i<3) { 
         i++; 
         MapMessage message = (MapMessage) consumer.receive(); 
         session.commit(); 
  
         //TODO something.... 
         System.out.println("收到消 息：" + new Date(message.getLong("count"))); 
     } 
  
     session.close(); 
     connection.close(); 
 }
 catch(Exception e){
  
 }
 }

}