ActiveMQ-P2P文本消息

使用ActiveMQ实现了JMS的点对点的消息模型，实现了同步的消息机制

package com.tgb.activemq;

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

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
/**
 * 消息的消费者（接受者）
 * @author liang
 *
 */
public class JMSConsumer {

	private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;//默认连接用户名
	private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;//默认连接密码
	private static final String BROKEURL = ActiveMQConnection.DEFAULT_BROKER_URL;//默认连接地址
	
	public static void main（String[] args） {
		ConnectionFactory connectionFactory;//连接工厂
		Connection connection = null;//连接
		
		Session session;//会话 接受或者发送消息的线程
		Destination destination;//消息的目的地
		
		MessageConsumer messageConsumer;//消息的消费者
		
		//实例化连接工厂
		connectionFactory = new ActiveMQConnectionFactory（JMSConsumer.USERNAME JMSConsumer.PASSWORD JMSConsumer.BROKEURL）;
		
		try {
			//通过连接工厂获取连接
			connection = connectionFactory.createConnection（）;
			//启动连接
			connection.start（）;
			//创建session
			session = connection.createSession（false Session.AUTO_ACKNOWLEDGE）;
			//创建一个连接HelloWorld的消息队列
			destination = session.createQueue（“HelloWorld“）;
			//创建消息消费者
			messageConsumer = session.createConsumer（destination）;
			
			while （true） {
				TextMessage textMessage = （TextMessage） messageConsumer.receive（100000）;
				if（textMessage != null）{
					System.out.println（“收到的消息:“ + textMessage.getText（））;
				}else {
					break;
				}
			}
			
			
		} catch （JMSException e） {
			e.printStackTrace（）;
		}
		
	}
}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2015-09-20 18:01  activeMQHelloWorld\
     文件         599  2015-09-20 15:45  activeMQHelloWorld\.classpath
     文件         394  2015-09-20 11:59  activeMQHelloWorld\.project
     目录           0  2015-09-20 18:01  activeMQHelloWorld\.settings\
     文件         598  2015-09-20 11:59  activeMQHelloWorld\.settings\org.eclipse.jdt.core.prefs
     目录           0  2015-09-20 18:01  activeMQHelloWorld\bin\
     目录           0  2015-09-20 18:01  activeMQHelloWorld\bin\com\
     目录           0  2015-09-20 18:01  activeMQHelloWorld\bin\com\tgb\
     目录           0  2015-09-20 18:01  activeMQHelloWorld\bin\com\tgb\activemq\
     文件        2342  2015-09-20 17:20  activeMQHelloWorld\bin\com\tgb\activemq\JMSConsumer.class
     文件        2980  2015-09-20 17:20  activeMQHelloWorld\bin\com\tgb\activemq\JMSProducer.class
     目录           0  2015-09-20 18:01  activeMQHelloWorld\lib\
     文件     6590659  2015-06-02 21:54  activeMQHelloWorld\lib\activemq-all-5.11.1.jar
     目录           0  2015-09-20 18:01  activeMQHelloWorld\src\
     目录           0  2015-09-20 18:01  activeMQHelloWorld\src\com\
     目录           0  2015-09-20 18:01  activeMQHelloWorld\src\com\tgb\
     目录           0  2015-09-20 18:01  activeMQHelloWorld\src\com\tgb\activemq\
     文件        1864  2015-09-20 17:20  activeMQHelloWorld\src\com\tgb\activemq\JMSConsumer.java
     文件        2429  2015-09-20 17:20  activeMQHelloWorld\src\com\tgb\activemq\JMSProducer.java
     文件          58  2018-02-03 23:20  下载地址.txt