国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 開發設計 > 正文

第3.3案例2:工作隊列jobqueue

2019-11-14 15:36:33
字體:
來源:轉載
供稿:網友

  第2個案例就是工作隊列,典型的點對點的消息,一個PRoducer發送一個工作消息到隊列去,具有Listener類的Consumer能夠從工作隊列中獲得一個工作情況的消息,這個消息被這個消費者消費掉之后,就不存在了,隸屬于一點對一點模式,這不同于3.2案例中的股票期貨那樣可以把一個價格發布到多個訂閱了的消費者身上。

  還有一點不同:Producer使用消息生產者發送了100個消息進入隊列后,就馬上關閉連接了,這一點同3.2一樣。此后,這10個消息仍舊存在于JMS服務器消息域中,隨后的消費者什么時候運行就什么時候來消費掉這些消息,不用一直在線等,該隊列中的消息也不會逝去。這也是不同于3.2案例的地方。

  啟動步驟:

      1、        啟動ActiveMQ。

      2、        首先要運行的是Producer類。

      3、        在運行Consumer類。

  需要說明的一點是:

            1、這次誰先啟動都無所謂,因為在消息會在隊列里暫時存儲一段時間,誰先啟動都無關緊要,這一點我已經證實多次了,而且,消費者所獲得的消費消息也會完整無缺,一個也不缺。

    2、關于“點對點”模式的說明,具體來講應該是“消息點對點”。如果理解為一個生產者和一個消費者,那這樣是理解錯誤的,應該是一個生產者發出消息只能有被一個消費者所消費后,其他的消費者是得不到的,因為該條消息是一次性的,進入隊列后在從隊列中,在隊列中什么也沒有發生變化,而且隊列形象的象個直通子的容器,只是讓這條消息在里面呆了一陣子而已,無它。

   這是我理解下的消息點對點模式圖:

 

 

附件:程序的運行結果:

 

 

 

 


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 芒康县| 大理市| 祁连县| 嘉定区| 长乐市| 甘泉县| 陈巴尔虎旗| 河曲县| 河池市| 兰坪| 台州市| 汝城县| 西安市| 兰西县| 法库县| 区。| 岢岚县| 遂宁市| 台州市| 怀集县| 海门市| 大埔区| 平舆县| 山东| 龙游县| 岑巩县| 平定县| 永州市| 偃师市| 河西区| 莫力| 娄烦县| 紫云| 横山县| 林周县| 会东县| 桦南县| 新和县| 湘潭市| 突泉县| 田林县|