org.apache.activemq<
/groupid>
activemq-all<
/artifactid>
5.15
.3<
/version>
<
/dependency>
步驟如下:具體**如下:
public
static
void
main
(string[
] args)
throws jm***ception
檢視佇列資訊
消費者:接收訊息。
步驟如下
實現**
public
static logger logger = logger.
getlogger
(myconsumer.
class);
public
static
void
main
(string[
] args)
throws jm***ception, ioexception
catch
(jm***ception e)}}
);system.in.
read()
;// 第九步:關閉資源
consumer.
close()
; session.
close()
; connection.
close()
;}
可同時執行兩個consumer
每生產乙個訊息,只能被乙個消費者消費一次。
步驟如下:
**實現
// 第一步:建立connectionfactory物件,需要指定服務端ip及埠號。
connectionfactory factory =
newactivemqconnectionfactory
("tcp://localhost:61616");
// 第二步:使用connectionfactory物件建立乙個connection物件。
connection connection = factory.
createconnection()
;// 第三步:開啟連線,呼叫connection物件的start方法。
connection.
start()
;// 第四步:使用connection物件建立乙個session物件。
session session = connection.
createsession
(false
,session.auto_acknowledge)
;// 第五步:使用session物件建立乙個destination物件(topic、queue),此處建立乙個topic物件。
topic topic = session.
createtopic
("test-topic");
// 第六步:使用session物件建立乙個producer物件。
messageproducer producer = session.
createproducer
(topic)
;// 第七步:建立乙個message物件,建立乙個textmessage物件。
textmessage message = session.
createtextmessage
("topic hello world ...");
// 第八步:使用producer物件傳送訊息。
producer.
send
(message)
;// 第九步:關閉資源。
producer.
close()
; session.
close()
; connection.
close()
;}
檢視topic消費者:接收訊息步驟如下:
**
public
static logger logger = logger.
getlogger
(topicconsumer.
class);
public
static
void
main
(string[
] args)
throws jm***ception, ioexception
catch
(exception e)}}
);system.out.
println
("消費者 3 ");
system.in.
read()
;// 第九步:關閉資源
consumer.
close()
; session.
close()
; connection.
close()
;}
檢視topic可開啟多個消費者進行測試!!!!queue形式
topic形式
pythonpip使用方法 pip使用方法整理
匯出專案已安裝的pip包 pip list 檢視專案中安裝的包 pip freeze requirements.txt 將專案中所用到的第三方庫輸出到requirements.txt中 pip install 版本號 pip install i 本次使用清華源進行安裝 離線安裝第三方庫 一鍵安裝整個...
使用方法 離型劑使用方法
1 使用離型劑前必須確保模具乾淨,無粉塵 蠟垢 樹脂垢 油汙等殘留物質。可以使用專用的模具潔模劑進行清洗,不可用其他液體清洗,以免清洗不乾淨或損壞模具。另外,如果您的模具是新的,在清洗乾淨後,務必要對模具進行初步處理,用離型劑在模具表面噴 刷塗5 6次,之後方可正常投入生產。2 使用離型劑時,首先要...
使用方法 卡丁車輪胎使用方法
輪胎的使用方法很重要 卡丁車輪胎是卡丁車場日常執行中的主要易損件,但是輪胎的使用方法很重要。哪些情況下會縮短輪胎的使用壽命呢?一 跑道地面粗糙 有的跑道在鋪瀝青時,或者選錯了瀝青中石子的規格,或者碾壓得不夠平整,導致路面粗糙。有的跑道使用現成的水泥地,但表面粗糙或不平整。有的室內跑道,為了提高輪胎的...