自己了解下。記錄一下筆記。下次就會有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,...