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...