訊息中介軟體之activeMQ

2021-10-05 23:04:22 字數 1925 閱讀 8414

使用activemq主要有以下幾點,在這裡做一下記錄。

1、docker search activemq    

2、docker pull webcenter/activemq

3、docker images

4、docker run -d --name activemq -p 61617:61616 -p 8162:8161 webcenter/activemq

2、執行成功後,瀏覽器訪問如下則配置成功

3、在springboot專案中,新增以下依賴

org.apache.activemq

activemq-core

5.7.0

4、點對點模型(p2p)

點對點模型,採用的是佇列(queue)作為訊息載體。在該模式中,一條訊息只能被乙個消費者消費,沒有被消費的,只能留在佇列中,等待被消費,或者超時。舉個例子,如果佇列中有10條訊息,有兩個消費者,就是乙個消費者消費5條資訊,你一條我一條。以下以**演示。

訊息發布者:

/**

* created by [email protected] on 2020/5/10 17:22

*/public class activemqsender

if(connection!=null)}}

訊息消費者(弄兩個試試):

/**

* created by [email protected] on 2020/5/10 17:41

*/public class activemqreceiver

system.out.println(message.gettext());

}if(connection!=null)}}

先啟動兩個消費者,在啟動訊息發布者

效果如下

5、發布/訂閱(pub/sub)模型

發布者發布資訊:

/**

* created by [email protected] on 2020/5/10 17:51

*/public class activemqsendpub catch (jm***ception e)

}});

system.out.println("topic消費者啟動。。。。");

// 等待接收訊息

system.in.read();

// 關閉資源

consumer.close();

session.close();

connection.close();}}

訂閱者訂閱資訊:

/**

* created by [email protected] on 2020/5/10 17:52

*/public class activemqsub1

// 9、關閉資源

producer.close();

session.close();

connection.close();}}

訂閱者要提前訂閱,所以先執行訂閱者。

activemq訊息中介軟體

生產者 factory new connectionfactory tcp localhost 61616 通過工廠建立連線 using iconnection connection factory.createconnection 消費者 建立連線工廠 iconnectionfactory fac...

訊息中介軟體ActiveMQ

此處用的是version 5.14.0 windows上安裝非常簡單直雙擊接執行apache activemq 5.14.0 bin win64 activemq.bat檔案 img 出現如圖所示說明執行啟動成功 linux上安裝此處略 然後瀏覽器輸入http localhost 8161 admi...

訊息中介軟體學習1 ActiveMQ

點對點 point to point 專門用於使用佇列queue傳送訊息 基於佇列queue的點對點訊息只能被乙個消費者消費,如多個消費者都註冊到同乙個訊息佇列上,當生產者傳送一條訊息後,而只有其中乙個消費者會接收到該訊息,而不是所有消費者都能接收到該訊息。發布 訂閱 publish subscri...