ActiveMQ學習筆記

2022-04-30 23:42:19 字數 1199 閱讀 3837

關鍵介面和類:

connectionfactory connectionfactory;//

連線工廠

connection connection;//

連線session session;

destination destination;

//目的

messageproducer messageproducer;//

訊息生產者

message message;//

訊息messageconsumer messageconsumer;//

訊息消費者

1.傳送訊息

//

activemq使用者名稱、activemq密碼、activemq位址

connectionfactory = new activemqxaconnectionfactory("admin", "admin", "failover://tcp://localhost:61616");

//連線

connection =connectionfactory.createconnection();

//第乙個引數是否使用事務,第二個引數訊息的確認模式

session = connection.createsession(false, session.auto_acknowledge);//

指定訊息提供者在每次收到訊息時自動傳送確認。訊息只向目標傳送一次

//目的地,activemq中已存在佇列

destination = session.createqueue("secondqueue");

//訊息生產者[傳送者]

messageproducer =session.createproducer(destination);

//永續性設定

messageproducer.setdeliverymode(deliverymode.non_persistent);

//訊息

message = session.createtextmessage("發了一條訊息給secondqueue");

//傳送

messageproducer.send(message);

session.close();

connection.close();

2.傳送檔案

關鍵:blogmessage

Docker學習筆記 安裝ActiveMQ

一 實驗環境 1 宿主機os win10 64位 2 虛擬機器os ubuntu18.04,虛擬機器名稱 ubuntu18vm1,虛擬機器ip 192.168.8.25 3 操作賬號 docker 4 在虛擬機器上已安裝docker 二 安裝 簡要步驟 1.搜尋映象 sudo docker sear...

訊息佇列activeMQ的簡介 學習筆記之一

訊息佇列的應用 1 業務日誌 2 手機簡訊 3 郵箱郵件 4 站內信 5 訂單 訂單支付後呼叫訂單系統,倉庫,物流 mq 訊息提供者producer 訊息消費者consumer mvc 返回值produces 引數 comsumes dubbo 服務提供者provider 服務消費者consumer...

ActiveMQ學習筆記(二)高階特性之非同步投遞

activemq預設使用非同步投遞模式,兩種情況除外 1.手動開啟同步模式 2.在未開啟事務的情況下傳送持久化訊息 1.在url後面新增引數 2.使用activemqconnectionfactory物件設定屬性 3.使用activemqconnection物件設定屬性 test public vo...