91av视频/亚洲h视频/操亚洲美女/外国一级黄色毛片 - 国产三级三级三级三级

  • 大小: 55KB
    文件類型: .zip
    金幣: 2
    下載: 0 次
    發布日期: 2021-05-22
  • 語言: 其他
  • 標簽: jms??demo??

資源簡介

自己寫的一個JMS的demo,包含點對點,發布/訂閱的例子,以及DeliverMode的測試,還有持久的訂閱者,解決topic模式下消息接收者離線后接收不到離線時錯過的消息的問題。

資源截圖

代碼片段和文件信息

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個文件信息

評論

共有 條評論