activeMq的點對點傳送

2021-07-15 10:06:04 字數 1723 閱讀 8378

connectionfactory factory = new activemqconnectionfactory("system","manager","tcp://localhost:61616"); 

引數1:使用者名稱,預設:activemqconnection.default_user=null;可以根據mq的配置檔案自己設定

引數2:密碼,預設:activemqconnection.default_password=null;可以根據mq的配置檔案自己設定

引數3:url,預設:activemqconnection.default_broker_url=failover://tcp://localhost:61616;

url有幾種:

mq預設使用的協議,開放性、高效性、可靠性是其主要特點,這個協議可滿足一般應用的大部分需求,因此在專案中還是比較常用的。

網路訊息的傳播效率非常的高。因此,當系統存在高使用者量、高併發或網路堵塞時,可考慮用此協議。
安全套接層協議

在mq目錄/conf/activemq.xml檔案中修改以下配置xml**:

connection conn = factory.createconnection();session session = conn.createsession(true, session.auto_acknowledge);

引數1:是否自動提交

引數2:session.auto_acknowledge, session.client_acknowledge, session.dups_ok_acknowledgedestination destination = session.createqueue("queue");messageproducer producer = session.createproducer(destination);objectmessage om = session.createobjectmessage(d);

producer.send(om);messageconsumer consumer = session2.createconsumer(destination2);consumer.setmessagelistener(new mylistener());

傳送者完整**:
public class mqsender 	

}catch(exception e)finally catch (jm***ception e1) }}

}public static void main(string args) catch (exception e)

} }

消費者完整**:

public class receiver catch(exception e)finally catch (jm***ception e1) }}

}public static void main(string args) catch (exception e)

} }class mylistener1 implements messagelistener catch (exception e)

} }

activeMq 傳送模式之 點對點

1.1.1 activemq 倆種傳送模式之一 點對點模式 訊息生產者 也就是傳送方 1.建立連線工廠 connectionfactory connectionfactory newactivemqconnectionfactory tcp 2.獲取連線 connection connection ...

ActiveMq點對點模式傳送 接收訊息

訊息傳送流程 1 客戶機傳送訊息到jms訊息中介軟體 2 服務端負責監聽jms訊息目的地。3 發現jms裡面有訊息產生,服務就可以接受訊息。點對點訊息傳送服務 1 訊息只能被乙個服務接受 2 多個服務同時監聽訊息伺服器,遵循先來後到原則。3 訊息一旦被接受,訊息自動消失。4 如果訊息一直沒有被接受,...

HttpClient服務點傳送請求

public void getparams catch clientprotocolexception e catch parseexception e catch urisyntaxexception e catch ioexception e finally catch ioexception ...