package?com.rick.queue;

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?Receiver?{
????public?static?void?main（String[]?args）?{
????	System.out.println（“QueueReceiver啟動了...“）;
????????//?ConnectionFactory?：連接工廠，JMS?用它創建連接
????????ConnectionFactory?connectionFactory;
????????//?Connection?：JMS?客戶端到JMS?Provider?的連接
????????Connection?connection?=?null;
????????//?Session：?一個發送或接收消息的線程
????????Session?session;
????????//?Destination?：消息的目的地;消息發送給誰.
????????Destination?destination;
????????//?消費者，消息接收者
????????final?MessageConsumer?consumer;
????????connectionFactory?=?new?ActiveMQConnectionFactory（
????????????????ActiveMQConnection.DEFAULT_USER
????????????????ActiveMQConnection.DEFAULT_PASSWORD
????????????????“tcp://localhost:61616“）;
????????try?{
????????????//?構造從工廠得到連接對象
????????????connection?=?connectionFactory.createConnection（）;
????????????//?啟動
????????????connection.start（）;
????????????//?獲取操作連接
????????????session?=?connection.createSession（Boolean.FALSE
????????????????????Session.AUTO_ACKNOWLEDGE）;
????????????//?獲取session注意參數值xingbo.xu-queue是一個服務器的queue，須在在ActiveMq的console配置
????????????destination?=?session.createQueue（“FirstQueue“）;
????????????consumer?=?session.createConsumer（destination）;
//????????????while?（true）?{
//????????????????//設置接收者接收消息的時間，為了便于測試，這里誰定為100s
//????????????????TextMessage?message?=?（TextMessage）?consumer.receive（100000）;
//????????????????if?（null?!=?message）?{
//????????????????????System.out.println（“收到消息“?+?message.getText（））;
//????????????????}?else?{
//????????????????????break;
//????????????????}
//????????????}
????????????/*
?????????????*?兩種方式均可
?????????????*?1，while循環和consumer.receive（）結合
?????????????*?2，consumer.setMessageListener（new?MessageListener（）?{}）;
?????????????*/
????????????consumer.setMessageListener（new?MessageListener（）?{
				@Override
				public?void?onMessage（Message?message）?{
					try?{
						message?=?（TextMessage）?consumer.receive（）;
						System.out.println（“收到消息：“+?（（TextMessage）?message）.getText（））;
					}?catch?（JMSException?e）?{
						e.printStackTrace（）;
					}
				}
			}）;
????????}?catch?（Exception?e）?{
????????????e.printStackTrace（）;
????????}?finally?{
????????????try?{
????????????????if?（null?!=?connection）
????????????????????connection.close（）;
????????????}?catch?（Throwable?ignore）?{
????????????}
????????}
????}
}

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2014-04-14?11:12??jms\
?????文件?????????384??2014-04-17?15:02??jms\.classpath
?????文件?????????379??2014-03-21?16:45??jms\.project
?????目錄???????????0??2014-04-14?11:12??jms\.settings\
?????文件?????????598??2014-03-21?16:45??jms\.settings\org.eclipse.jdt.core.prefs
?????目錄???????????0??2014-04-14?11:12??jms\activemq-data\
?????目錄???????????0??2014-04-14?11:12??jms\activemq-data\localhost\
?????目錄???????????0??2014-04-14?11:12??jms\activemq-data\localhost\KahaDB\
?????文件????33030144??2014-04-18?10:16??jms\activemq-data\localhost\KahaDB\db-1.log
?????文件???????32768??2014-04-18?10:16??jms\activemq-data\localhost\KahaDB\db.data
?????文件???????28720??2014-04-18?10:16??jms\activemq-data\localhost\KahaDB\db.redo
?????文件???????????0??2014-04-18?10:10??jms\activemq-data\localhost\KahaDB\lock
?????目錄???????????0??2014-04-14?11:12??jms\bin\
?????目錄???????????0??2014-04-14?11:12??jms\bin\com\
?????目錄???????????0??2014-04-14?11:12??jms\bin\com\rick\
?????目錄???????????0??2014-04-14?11:12??jms\bin\com\rick\queue\
?????文件????????1307??2014-04-14?11:11??jms\bin\com\rick\queue\Receiver$1.class
?????文件????????2287??2014-04-14?11:11??jms\bin\com\rick\queue\Receiver.class
?????文件????????2649??2014-04-14?11:11??jms\bin\com\rick\queue\Sender.class
?????文件????????1683??2014-04-14?11:11??jms\bin\com\rick\queue\Sender2.class
?????目錄???????????0??2014-04-14?11:12??jms\bin\com\rick\topic\
?????文件?????????572??2014-04-14?11:04??jms\bin\com\rick\topic\MessageObj.class
?????文件????????2578??2014-04-14?11:11??jms\bin\com\rick\topic\TopicReceiver.class
?????文件????????1219??2014-04-14?11:11??jms\bin\com\rick\topic\TopicReceiverDurable$1.class
?????文件????????2020??2014-04-14?11:11??jms\bin\com\rick\topic\TopicReceiverDurable.class
?????文件????????2856??2014-04-14?11:12??jms\bin\com\rick\topic\TopicSender.class
?????目錄???????????0??2014-04-14?11:12??jms\src\
?????目錄???????????0??2014-04-14?11:12??jms\src\com\
?????目錄???????????0??2014-04-14?11:12??jms\src\com\rick\
?????目錄???????????0??2014-04-14?11:12??jms\src\com\rick\queue\
?????文件????????2919??2014-04-14?11:11??jms\src\com\rick\queue\Receiver.java
............此處省略7個文件信息