activeMq 傳送模式之 點對點

2021-10-01 14:14:59 字數 1991 閱讀 1997

1.1.1 activemq 倆種傳送模式之一——點對點模式

** 訊息生產者——也就是傳送方**

//1.建立連線工廠

connectionfactory connectionfactory =

newactivemqconnectionfactory

("tcp:");

//2.獲取連線

connection connection = connectionfactory.

createconnection()

;//3.啟動連線

connection.

start()

;//4.獲取session (引數1:是否啟動事務,引數二:訊息確認模式)

session session = connection.

createsession

(false

, session.auto_acknowledge)

;//5.確認佇列模式

queue queue = session.

createqueue

("test-queue");

//6.建立訊息生產者

messageproducer producer = session.

createproducer

(queue)

;//7.建立訊息

textmessage textmessage = session.

createtextmessage

("hello 你好世界");

//8.傳送訊息

producer.

send

(textmessage)

; producer.

close()

; session.

close()

; connection.

close()

;

訊息消費者——接收方

//1.建立連線工廠

connectionfactory connectionfactory=

newactivemqconnectionfactory

("tcp:");

//2.獲取連線

connection connection = connectionfactory.

createconnection()

;//3.啟動連線

connection.

start()

;//4.獲取session (引數1:是否啟動事務,引數2:訊息確認模式)

session session = connection.

createsession

(false

, session.auto_acknowledge)

;//5.建立佇列物件

queue queue = session.

createqueue

("test-queue");

//6.建立訊息消費

messageconsumer consumer = session.

createconsumer

(queue)

;//7.監聽訊息

consumer.

setmessagelistener

(new

messagelistener()

catch

(jm***ception e)}}

);//8.等待鍵盤輸入

system.in.

read()

;//9.關閉資源

consumer.

close()

; session.

close()

; connection.

close()

;}

ActiveMq點對點模式傳送 接收訊息

訊息傳送流程 1 客戶機傳送訊息到jms訊息中介軟體 2 服務端負責監聽jms訊息目的地。3 發現jms裡面有訊息產生,服務就可以接受訊息。點對點訊息傳送服務 1 訊息只能被乙個服務接受 2 多個服務同時監聽訊息伺服器,遵循先來後到原則。3 訊息一旦被接受,訊息自動消失。4 如果訊息一直沒有被接受,...

個人對單例模式的一點理解

如有誤解請指出,感激不盡 單例模式是一種常用的軟體設計模式。在它的核心結構中只包含乙個被稱為單例的特殊類。通過單例模式可以保證系統中,應用該模式的乙個類只有乙個例項。即乙個類只有乙個物件例項。在某些場景下,我們可能只需要建立乙個例項,並且確保其他所有的物件訪問時都是這乙個例項,然後利用這個例項來控制...

使用設計模式之觀察者模式來實現簡單的傳送彈幕元件

按下的必須是回車鍵,並且輸入框中的內容不能全為空格或者沒有內容。lang en charset utf 8 name viewport content width device width,initial scale 1.0 彈幕title input div0 style head class d...