這個東西沒接觸到的時候挺懵的,用過一次之後,哇哦
首先建立乙個生產者,這東西其實就是乙個工具類public class producter catch (jm***ception e)
}public void sendmessage(string disname, listlist) else
thread.sleep(1000);
int num = count.getandincrement();
for (lgttimeplanentity entity : list)
} catch (jm***ception e) catch (interruptedexception e)
}}
然後在方法執行中呼叫sendmessage方法,這不就是乙個工具類麼,這時候已經把資料放進佇列中了,接下來就是從佇列中傳送出去資料@service(value = "lgtwaybillinfoservice")
public class lgtwaybillinfoserviceimpl implements lgtwaybillinfoservice catch (interruptedexception e)
producter.sendmessage("activemq",list);
}}
首先建立乙個消費者,說白了這玩意也是乙個工具類public class comsumer catch (jm***ception e)
}public void getmessage(string disname)else
while(true)else
}} catch (jm***ception e) catch (interruptedexception e)
}}
public static void main(string args)
private class consumermq implements runnable
@override
public void run() catch (interruptedexception e) }}
}} 然後,重頭戲來了,我把工程中的啟動類改了 ,這樣啟動工程的時候消費者就可以從生產者產生的資料裡直接取,而且要注意,訊息佇列是需要賬號密碼和ip埠才能連線的,所以在乙個完整的專案中,mq可能只有乙個,但是生產者和消費者不一定有多少個
activeMQ訊息佇列
session.auto acknowledge。當客戶成功的從receive 方法返回的時候,或者從messagelistener.onmessage方法成功返回的時候,會話自動確認客戶收到的訊息。session.client acknowledge。客戶通過訊息的 acknowledge 方法確...
ActiveMQ實現訊息佇列
實現訊息佇列 123 4567 891011 1213 1415 1617 1819 2021 2223 2425 2627 2829 3031 32 service public class providerservice 123 4567 891011 1213 1415 1617 1819 2...
activemq佇列訊息小結
jms開發基本步驟 1.建立連線工廠connectionfactory new connectionfactory 2.建立連線connection connectionfactory.createconnection 3.開啟連線connection.start 4.建立會話session con...