引數1:使用者名稱,預設:activemqconnection.default_user=null;可以根據mq的配置檔案自己設定
引數2:密碼,預設:activemqconnection.default_password=null;可以根據mq的配置檔案自己設定
引數3:url,預設:activemqconnection.default_broker_url=failover://tcp://localhost:61616;
url有幾種:
mq預設使用的協議,開放性、高效性、可靠性是其主要特點,這個協議可滿足一般應用的大部分需求,因此在專案中還是比較常用的。
網路訊息的傳播效率非常的高。因此,當系統存在高使用者量、高併發或網路堵塞時,可考慮用此協議。
安全套接層協議connection conn = factory.createconnection();session session = conn.createsession(true, session.auto_acknowledge);在mq目錄/conf/activemq.xml檔案中修改以下配置xml**:
引數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 ...