ActiveMQ使用方法

2021-10-04 04:49:34 字數 3292 閱讀 7571

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 使用離型劑時,首先要...

使用方法 卡丁車輪胎使用方法

輪胎的使用方法很重要 卡丁車輪胎是卡丁車場日常執行中的主要易損件,但是輪胎的使用方法很重要。哪些情況下會縮短輪胎的使用壽命呢?一 跑道地面粗糙 有的跑道在鋪瀝青時,或者選錯了瀝青中石子的規格,或者碾壓得不夠平整,導致路面粗糙。有的跑道使用現成的水泥地,但表面粗糙或不平整。有的室內跑道,為了提高輪胎的...