MQ ActiveMQ(二) 訊息處理機制

2021-08-10 21:13:47 字數 2829 閱讀 5711

對於訊息的傳遞有兩種型別:

jms定義了五種不同的訊息正文格式,以及呼叫的訊息型別,允許你傳送並接收以一些不同形式的資料,提供現有訊息格式的一些級別的相容性。

生產者:生產訊息,傳送端。

把jar包新增到工程中。使用5.11.2版本的jar包。

第一步:建立connectionfactory物件,需要指定服務端ip及埠號。

第二步:使用connectionfactory物件建立乙個connection物件。

第三步:開啟連線,呼叫connection物件的start方法。

第四步:使用connection物件建立乙個session物件。

第五步:使用session物件建立乙個destination物件(topic、queue),此處建立乙個queue物件。

第六步:使用session物件建立乙個producer物件。

第七步:建立乙個message物件,建立乙個textmessage物件。

第八步:使用producer物件傳送訊息。

第九步:關閉資源。

@test

public

void

testqueueproducer() throws exception

消費者:接收訊息。

第一步:建立乙個connectionfactory物件。

第二步:從connectionfactory物件中獲得乙個connection物件。

第三步:開啟連線。呼叫connection物件的start方法。

第四步:使用connection物件建立乙個session物件。

第五步:使用session物件建立乙個destination物件。和傳送端保持一致queue,並且佇列的名稱一致。

第六步:使用session物件建立乙個consumer物件。

第七步:接收訊息。

第八步:列印訊息。

第九步:關閉資源

@test

public

void

testqueueconsumer() throws exception catch (jm***ception e)

}});

//等待鍵盤輸入

system.in.read();

// 第九步:關閉資源

consumer.close();

session.close();

connection.close();

}

使用步驟:

第一步:建立connectionfactory物件,需要指定服務端ip及埠號。

第二步:使用connectionfactory物件建立乙個connection物件。

第三步:開啟連線,呼叫connection物件的start方法。

第四步:使用connection物件建立乙個session物件。

第五步:使用session物件建立乙個destination物件(topic、queue),此處建立乙個topic物件。

第六步:使用session物件建立乙個producer物件。

第七步:建立乙個message物件,建立乙個textmessage物件。

第八步:使用producer物件傳送訊息。

第九步:關閉資源。

@test

public

void

testtopicproducer() throws exception

消費者:接收訊息。

第一步:建立乙個connectionfactory物件。

第二步:從connectionfactory物件中獲得乙個connection物件。

第三步:開啟連線。呼叫connection物件的start方法。

第四步:使用connection物件建立乙個session物件。

第五步:使用session物件建立乙個destination物件。和傳送端保持一致topic,並且話題的名稱一致。

第六步:使用session物件建立乙個consumer物件。

第七步:接收訊息。

第八步:列印訊息。

第九步:關閉資源

@test

public

void

testtopicconsumer() throws exception catch (jm***ception e)

}});

system.out.println("topic的消費端03。。。。。");

// 等待鍵盤輸入

system.in.read();

// 第九步:關閉資源

consumer.close();

session.close();

connection.close();

}

通過分析和用不與spring結合的測試方法來更加深刻的了解mq在具體的使用過程中的步驟。

都是引入相關jar包後,建立連線工廠,工廠建立相關的連線物件,連線物件開啟,建立相關的會話,會話發起目的地並且建立生產者或者消費者,然後對訊息進行處理,最後關閉連線。

Android訊息處理機制 二

角色綜述 回顧 1 ui thread 通常就是main thread,而android啟動程式時會替它建立乙個messagequeue。2 當然需要乙個looper物件,來管理該messagequeue。3 我們可以構造handler物件來push新訊息到message queue裡 或者接收lo...

VC訊息處理之二 訊息對映的工作原理

任何使用了mfc應用程式框架的windows程式都含有乙個從 派生的應用程式類物件,成員函式run 將被隱含呼叫,其呼叫的cwinthread類成員函式run 將通過對 getmessage translatemessage 和dispatchmessage 等函式的呼叫完成同winmain 類似的...

MMORPG開發雜談(二) 訊息處理框架

這樣做的乙個好處是,可以有子模組向上申請自己關心哪些訊息,避免父模組越來越複雜。附code list 1 pragma once class msgdelegate virtual msgdelegate int m msgid class nontypedelegate public msgdel...