關鍵介面和類:
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...