JMS ActiveMQ简单介绍+简单实例

    与点到点模型不一样，发布/订阅模型中，消息生产者产生一个消息后，把这个消息发送到一个Topic中，这个Topic能够同时有多个接收者在监听，当一个消息到达这个Topic以后，全部消息接收者都会收到这个消息。html

2.编程的结构java

2.1消息产生者向JMS发送消息的步骤 
(1)建立链接使用的工厂类JMS ConnectionFactory 
(2)使用管理对象JMS ConnectionFactory创建链接Connection 
(3)使用链接Connection 创建会话Session 
(4)使用会话Session和管理对象Destination建立消息生产者MessageSender 
(5)使用消息生产者MessageSender发送消息 
2.2消息消费者从JMS接受消息的步骤 
(1)建立链接使用的工厂类JMS ConnectionFactory 
(2)使用管理对象JMS ConnectionFactory创建链接Connection 
(3)使用链接Connection 创建会话Session 
(4)使用会话Session和管理对象Destination建立消息消费者MessageReceiver 
(5)使用消息消费者MessageReceiver接受消息，须要用setMessageListener将MessageListener接口绑定到MessageReceiver 
消息消费者必须实现了MessageListener接口，须要定义onMessage事件方法。
apache

3.ActiveMQ的下载编程

下载地址：http://activemq.apache.org/download.html
解压缩到本地，而后启动/bin/activemq.bat
服务器

而且有的Eclipse没有自带jms.jar，须要去下载session

4.发送端代码：tcp

package com.xkey.JMS;

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 javax.jms.Topic;

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

public class JmsSender {
	
	private ConnectionFactory connectionFactory = null;
	private Connection connection = null;
	private Session session = null;
	private Destination destination = null;
	private MessageProducer producer = null;
	
	
	JmsSender(){
		
	}
	
	public void init(){
		connectionFactory = new ActiveMQConnectionFactory(
				ActiveMQConnection.DEFAULT_USER,
				ActiveMQConnection.DEFAULT_PASSWORD,"tcp://localhost:61616");
		
		try{
			
			connection = connectionFactory.createConnection();
			connection.start();
			session = connection.createSession(Boolean.TRUE.booleanValue(),  
                    Session.AUTO_ACKNOWLEDGE);
			//Queue
			destination = session.createQueue("xkey");
			producer = session.createProducer(destination);
			//Topic
			/**
			 * Topic topic = session.createTopic("xkey.Topic");
			 * producer = session.createProducer(topic);
			*/
			producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
			sendMessage(session,producer);
			session.commit();
			
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			try {
				connection.close();
			} catch (JMSException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
	
	private void sendMessage(Session session,MessageProducer producer) throws JMSException{
		for (int i = 1; i <= 5; i ++) {  
            TextMessage message = session.createTextMessage("First ActiveMQ Test:::: " + i);  
            // 发送消息
            System.out.println("Sender：" + "First ActiveMQ Test::: " + i);  
            producer.send(message);  
        }  
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		JmsSender jms = new JmsSender();
		jms.init();
	}

}

package com.xkey.JMS;

import javax.jms.Connection;  
import javax.jms.ConnectionFactory;  
import javax.jms.Destination;  
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;  
import javax.jms.MessageListener;
import javax.jms.Session;  
import javax.jms.TextMessage;  

import org.apache.activemq.ActiveMQConnection;  
import org.apache.activemq.ActiveMQConnectionFactory;  

public class JmsReceiver {

	private ConnectionFactory connectionFactory = null;
	private Connection connection = null;
	private Session session = null;
	private MessageConsumer consumer = null;
	private Destination destination = null;
	
	public JmsReceiver(){
		
	}
	
	public void init(){
		connectionFactory = new ActiveMQConnectionFactory(
				ActiveMQConnection.DEFAULT_USER,
				ActiveMQConnection.DEFAULT_PASSWORD,"tcp://localhost:61616");
		try{
			connection = connectionFactory.createConnection();
			connection.start();
			session = connection.createSession(Boolean.TRUE.booleanValue(),  
	                Session.AUTO_ACKNOWLEDGE); 
			destination = session.createQueue("xkey");
			consumer = session.createConsumer(destination);
			consumer.setMessageListener(new MessageListener(){

				@Override
				public void onMessage(Message msg) {
					// TODO Auto-generated method stub
					TextMessage message = (TextMessage)msg;
					try{
						System.out.println("Receiver " + message.getText());  
					}catch(Exception e){
						e.printStackTrace();
					}
				}
				
			});
			/**while (true) {  
                TextMessage message = (TextMessage) consumer.receive(1000);  
                if (null != message) {  
                    System.out.println("Receiver " + message.getText());  
                } else {  
                    break;  
                }  
            }  */
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			try {
				connection.close();
			} catch (JMSException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		JmsReceiver jms = new JmsReceiver();
		jms.init();
	}

}