產(chǎn)品培訓(xùn)系統(tǒng)概述(文件)
【正文】 隊(duì)列一一對(duì)應(yīng) QCU sndQ sndQ sndQ sndQ sndQ SndProc sndConn sndConn sndConn sndConn sndConn SndProc 端口監(jiān)聽與接收進(jìn)程 ? 發(fā)送方可以通過一個(gè)或多個(gè)端口向某個(gè)接收節(jié)點(diǎn)發(fā)送消息 ? 一個(gè)接收進(jìn)程只能負(fù)責(zé)某個(gè)特定端口的監(jiān)聽，且一個(gè)端口不能由多個(gè)進(jìn)程監(jiān)聽 ? 通過某個(gè)端口收到的消息只能放到某個(gè)特定 QCU的隊(duì)列中，但可以為任意隊(duì)列 node QCU1 QCU2 Port RcvProc RcvProc RcvProc 接收線程 接收線程 接收線程 接收線程 接收線程 接收線程 接收線程 客戶端代理 ? 客戶端代理作為客戶端應(yīng)用跟 Server交互的中間媒介。 如果 AckType=TLQACK_COMMIT 提交確認(rèn)后，成功接收的消息從隊(duì)列中清除； 如果 AckType=TLQACK_ROLLBACK 回滾確認(rèn)后，成功接收的消息被重新放回到隊(duì)列中 2023/2/25 31 發(fā)布訂閱 發(fā)布訂閱 2023/2/25 32 發(fā)布訂閱 發(fā)布訂閱是一種一對(duì)多的消息傳輸模式。 發(fā)布者： 提供信息者 訂閱者： 信息消費(fèi)者 訂閱者標(biāo)識(shí)： 本地訂閱者： MsgId 異地訂閱者：相鄰的代理名 2023/2/25 34 發(fā)布訂閱 圖示 Publisher Subscriber Subscriber Subscriber Subscriber 主 題 舉例：古董拍賣，主題為某個(gè)古董的競價(jià) 發(fā)布者：發(fā)布古董的最新價(jià)格信息 訂閱者：訂閱古董的最新價(jià)格信息 2023/2/25 35 發(fā)布訂閱 發(fā)布類型 Event事件型： 每一次發(fā)布操作都是獨(dú)立的。 發(fā)布范圍 Local本地發(fā)布 :發(fā)布的消息只會(huì)被本地的訂閱者收到； Global異地發(fā)布：只會(huì)被非本地的訂閱者收到； Local|Global全局發(fā)布：整個(gè)網(wǎng)絡(luò)中的訂閱者均會(huì)收到。 Global異地訂閱：訂閱者不會(huì)收到本地發(fā)布的信息，只會(huì)收到異地發(fā)布的信息。 提交 提交之后，事務(wù)中的所有動(dòng)作才開始執(zhí)行 。 2023/2/25 41 事件管理 事件消息概述 （ 1）定義事件是為了跟蹤所有消息的狀態(tài)以及被處理的狀況，對(duì)所有消息有效 （ 2）為持久性消息； （ 3）生命周期無限長； （ 4）比普通消息多兩個(gè)屬性：事件類型和事件發(fā)生的時(shí)間； （ 5） TLQ啟動(dòng)時(shí)，會(huì)自動(dòng)創(chuàng)建事件隊(duì)列 ； （ 6）事件隊(duì)列滿后，新產(chǎn)生的事件消息將被丟棄； 2023/2/25 42 事件管理 BeginSend 開始發(fā)送消息 SendOver 發(fā)送消息完畢 BeginRecv 開始接收消息 RecvOver 消息接收完畢 Expiry 生命周期超時(shí) FileFail 因?qū)?
規(guī)章制度相關(guān)推薦
鄂ICP備17016276號(hào)-1