大战熟女丰满人妻av-荡女精品导航-岛国aaaa级午夜福利片-岛国av动作片在线观看-岛国av无码免费无禁网站-岛国大片激情做爰视频

JMS&ActiveMQ教程
基于JMS的消息傳送
ActiveMQ與Spring集成
ActiveMQ與SpringBoot集成
ActiveMQ安全機(jī)制
ActiveMQ主從集群

ActiveMQ中Queue與Topic的區(qū)別

隊(duì)列(Queue)和主題(Topic)是JMS支持的兩種消息傳遞模型:

1、點(diǎn)對(duì)點(diǎn)(point-to-point,簡稱PTP)Queue消息傳遞模型:

通過該消息傳遞模型,一個(gè)應(yīng)用程序(即消息生產(chǎn)者)可以向另外一個(gè)應(yīng)用程序(即消息消費(fèi)者)發(fā)送消息。在此傳遞模型中,消息目的地類型是隊(duì)列(即Destination接口實(shí)現(xiàn)類實(shí)例由Session接口實(shí)現(xiàn)類實(shí)例通過調(diào)用其createQueue方法并傳入隊(duì)列名稱而創(chuàng)建)。消息首先被傳送至消息服務(wù)器端特定的隊(duì)列中,然后從此對(duì)列中將消息傳送至對(duì)此隊(duì)列進(jìn)行監(jiān)聽的某個(gè)消費(fèi)者。同一個(gè)隊(duì)列可以關(guān)聯(lián)多個(gè)消息生產(chǎn)者和消息消費(fèi)者,但一條消息僅能傳遞給一個(gè)消息消費(fèi)者。如果多個(gè)消息消費(fèi)者正在監(jiān)聽隊(duì)列上的消息,,JMS消息服務(wù)器將根據(jù)“先來者優(yōu)先”的原則確定由哪個(gè)消息消費(fèi)者接收下一條消息。如果沒有消息消費(fèi)者在監(jiān)聽隊(duì)列,消息將保留在隊(duì)列中,直至消息消費(fèi)者連接到隊(duì)列為止。這種消息傳遞模型是傳統(tǒng)意義上的懶模型或輪詢模型。在此模型中,消息不是自動(dòng)推動(dòng)給消息消費(fèi)者的,而是要由消息消費(fèi)者從隊(duì)列中請(qǐng)求獲得。

2、發(fā)布/訂閱(publish/subscribe,簡稱pub/sub)Topic消息傳遞模型:

通過該消息傳遞模型,應(yīng)用程序能夠?qū)⒁粭l消息發(fā)送給多個(gè)消息消費(fèi)者。在此傳送模型中,消息目的地類型是主題(即Destination接口實(shí)現(xiàn)類實(shí)例由Session接口實(shí)現(xiàn)類實(shí)例通過調(diào)用其createTopic方法并傳入主題名稱而創(chuàng)建)。消息首先由消息生產(chǎn)者發(fā)布至消息服務(wù)器中特定的主題中,然后由消息服務(wù)器將消息傳送至所有已訂閱此主題的消費(fèi)者。主題目標(biāo)也支持長期訂閱。長期訂閱表示消費(fèi)者已注冊(cè)了主題目標(biāo),但在消息到達(dá)目標(biāo)時(shí)該消費(fèi)者可以處于非活動(dòng)狀態(tài)。當(dāng)消費(fèi)者再次處于活動(dòng)狀態(tài)時(shí),將會(huì)接收該消息。如果消費(fèi)者均沒有注冊(cè)某個(gè)主題目標(biāo),該主題只保留注冊(cè)了長期訂閱的非活動(dòng)消費(fèi)者的消息。與PTP消息傳遞模型不同,pub/sub消息傳遞模型允許多個(gè)主題訂閱者接收同一條消息。JMS一直保留消息,直至所有主題訂閱者都接收到消息為止。pub/sub消息傳遞模型基本上是一個(gè)推模型。在該模型中,消息會(huì)自動(dòng)廣播,消息消費(fèi)者無須通過主動(dòng)請(qǐng)求或輪詢主題的方法來獲得新的消息。

具體區(qū)別對(duì)比如下:

類型

Topic

Queue

概要

Publish Subscribe messaging 發(fā)布訂閱消息

Point-to-Point 點(diǎn)對(duì)點(diǎn)

有無狀態(tài)

topic數(shù)據(jù)默認(rèn)不落地,是無狀態(tài)的。

Queue數(shù)據(jù)默認(rèn)會(huì)在mq服務(wù)器上以文件形式保存,比如Active MQ一般保存在$AMQ_HOME\data\kr-store\data下面。也可以配置成DB存儲(chǔ)。

完整性保障

并不保證publisher發(fā)布的每條數(shù)據(jù),Subscriber都能接受到。

Queue保證每條數(shù)據(jù)都能被receiver接收。

消息是否會(huì)丟失

一般來說publisher發(fā)布消息到某一個(gè)topic時(shí),只有正在監(jiān)聽該topic地址的sub能夠接收到消息;如果沒有sub在監(jiān)聽,該topic就丟失了。

Sender發(fā)送消息到目標(biāo)Queue,receiver可以異步接收這個(gè)Queue上的消息。Queue上的消息如果暫時(shí)沒有receiver來取,也不會(huì)丟失。

消息發(fā)布接收策略

一對(duì)多的消息發(fā)布接收策略,監(jiān)聽同一個(gè)topic地址的多個(gè)sub都能收到publisher發(fā)送的消息。Sub接收完通知mq服務(wù)器

一對(duì)一的消息發(fā)布接收策略,一個(gè)sender發(fā)送的消息,只能有一個(gè)receiver接收。receiver接收完后,通知mq服務(wù)器已接收,mq服務(wù)器對(duì)queue里的消息采取刪除或其他操作。

全部教程
主站蜘蛛池模板: 91尤物国产尤物福利 | 青青青青久在线观看视频 | 欧美视频在线视频 | 亚洲成a人在线播放www | 国产在线精品香蕉麻豆 | 欧美一级毛片欧美毛片视频 | 久久一 | 欧美韩国日本一区 | 综合色在线观看 | 日本制服丝袜在线 | 青青热久免费精品视频精品 | 91香蕉在线观看 | 热久久网站 | 一级毛片日韩a欧美视频 | 色多网站免费视频 | 精品国产乱码一区二区三区麻豆 | 国产精品美女久久久久网站 | 毛片免费全部免费观看 | 99久久精品免费 | 奇米视频888 | 国产乱码精品一区二区三区卡 | 成人毛片免费网站 | 99热久久这里只有精品2010 | 国产精品久久久影院 | 欧美成人一级毛片 | 国产精品入口麻豆高清在线 | 日韩毛片免费看 | 在线免费观看一区二区三区 | 日本爽快片100色毛片 | 性欧美高清久久久久久久 | 天天干夜干 | 狠狠色丁婷婷综合久久 | 日本 毛片基地-亚洲 | 国产毛片一级国语版 | 久久九九热re6这里有精品 | 国产精品玖玖玖影院 | 久久影院在线 | 久久久精品一区二区三区 | a在线观看免费 | 国产成人精品久久免费动漫 | 本地毛片 |