MQ ACTIVEMQ概述及定義(三)

2021-09-26 11:55:56 字數 2534 閱讀 4810

自己了解下。記錄一下筆記。下次就會有spring整合activemq。如果也有正在學的,我們一起討論討論哈。

這個以前通過jdbc運算元據庫的通用步驟。

這個是操作activemq的 通用步驟:

一、佇列的生產者

// 1建立連線工廠,安裝給定的url,採用預設的賬號和密碼

activemqconnectionfactory activemqconnectionfactory = new activemqconnectionfactory(activemq_url);

// 2、通過連線工廠,獲得連線connection並訪問

connection connection = activemqconnectionfactory.createconnection();

connection.start();

// 3、建立會話session

// 兩個引數 第乙個引數叫事務/第二個引數叫簽收

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

// 4、建立目的地,(具體是佇列還是主題topic)

queue queue = session.createqueue(queue_name);

// 5、建立訊息的生產者

messageproducer messageproducer = session.createproducer(queue);

// 6、通過使用messageproducer生產3條訊息傳送到mq的佇列裡面

for (int i = 1; i <= 3; i++)

// 9、關閉資源

messageproducer.close();

session.close();

connection.close();

system.out.println("訊息傳送到mq完成");

二、佇列的消費者

// 1建立連線工廠,安裝給定的url,採用預設的賬號和密碼

activemqconnectionfactory activemqconnectionfactory = new activemqconnectionfactory(activemq_url);

// 2、通過連線工廠,獲得連線connection並訪問

connection connection = activemqconnectionfactory.createconnection();

connection.start();

// 3、建立會話session

// 兩個引數 第乙個引數叫事務/第二個引數叫簽收

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

// 4、建立目的地,(具體是佇列還是主題topic)

queue queue = session.createqueue(queue_name);

// 5、建立訊息的消費者

messageconsumer messageconsumer = session.createconsumer(queue);

// ---------------------第一種 receive接受的方法。

// 同步阻塞方式,訂閱者或者接受者呼叫messageconsumer的receive()方法來接受訊息,receive方法在能夠接受到訊息之前(或超時之前)將一直阻塞。

// while (true) else

// }

// messageconsumer.close();

// session.close();

// connection.close();

// ---------------------第二種 通過監聽的方法來消費訊息

// 非同步非阻塞方式(*** onmessage())

// 訂閱者或者接受者通過messageconsumer的setmessagelistener(messagelistener

// listener)註冊乙個訊息***,

// 當訊息到達後,系統自動呼叫***meaasgelistener的message(message message)方法

messageconsumer.setmessagelistener(new messagelistener() catch (jm***ception e) }}

});system.in.read();// 保持控制檯燈不滅。

messageconsumer.close();

session.close();

connection.close();

Keepalived 概述及部署

keepalived 軟體起初是專為lvs 負載均衡軟體設計的,用來管理並監控lvs 集群系統中各個服務節點的狀態,後來又加入了可以實現高可用的vrrp 功能。因此,keepalived除了能夠管理lvs軟體外,還可以作為其他服務 例如 nginx haproxy mysql等 的高可用解決方案軟體...

systemtap概述及例項

systemtap對使用者級和核心級 提供了靜態和動態跟蹤的功能。systemtap採用其他的核心框架做源 靜態探針用tracepoints 動態探針用kprobes 使用者級別的探針用uprobes。這些源也為perf lttng所用。由於 systemtap 執行需要核心的除錯資訊支撐,預設發行...

DOM概述及分類

一 結點 結點是把具有相同屬性的html元素組成.節點分類 父節點 parentnode 子節點 firstchild lastchild childnodes 兄弟節點 nextsibling previoussibling 包含型別 名稱 值。nodetype 分類,元素結點 1,屬性結點 2,...