這個東西沒接觸到的時候挺懵的，用過一次之後，哇哦
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)
}}
@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...