TongLINK/Q8.0培訓(xùn)

---系統(tǒng)概述演講人：演講時(shí)間：背景介紹基本概念介紹主要功能其他相關(guān)內(nèi)容簡介目錄背景介紹消息中間件是一種獨(dú)立的系統(tǒng)軟件或服務(wù)程序介于操作系統(tǒng)和應(yīng)用系統(tǒng)之間獨(dú)立于網(wǎng)絡(luò)和操作系統(tǒng)屏蔽了環(huán)境的差異型用于分布式應(yīng)用系統(tǒng)中：借助這種軟件在不同的系統(tǒng)之間共享資源，管理計(jì)算資源和網(wǎng)絡(luò)通訊。實(shí)現(xiàn)應(yīng)用的互連和互操作，保證應(yīng)用系統(tǒng)安全、可靠、高效地運(yùn)行。為應(yīng)用提供了公用的通信手段。為開發(fā)者提供了公用于所有環(huán)境的應(yīng)用程序接口。消息中間件概述當(dāng)前計(jì)算環(huán)境硬件環(huán)境當(dāng)前的計(jì)算環(huán)境朝著高配置：多CPU、高帶寬（如光纖）、高容量（如磁盤陣列）等方面發(fā)展。軟件必須能夠充分利用高配置硬件提供的性能，以提高軟件性能軟件環(huán)境支持多種語言和使用方式支持多種操作系統(tǒng)符合國際標(biāo)準(zhǔn)，如JMS支持多種通訊協(xié)議TLQ8.0支持的操作系統(tǒng)類型Server：支持主流的Unix和Linux操作系統(tǒng)，如HP11、AIX、Sorlaris等常見操作系統(tǒng)類型；不支持如SCO等無法提供多線程功能的Unix操作系統(tǒng)。支持主流的Windows操作系統(tǒng)，如WinNT、WinXP、Win2000、Win2003不支持諸如Win98、Win95及以下版本。Client：支持幾乎所有常見操作系統(tǒng)類型，甚至Win98、Win95、SCO等不支持Win32及更低版本的Windows系統(tǒng)基本概念介紹節(jié)點(diǎn)節(jié)點(diǎn):

是一套完整的TLQ運(yùn)行環(huán)境（實(shí)例）的集合，其中包括運(yùn)行的系統(tǒng)核心進(jìn)程、系統(tǒng)內(nèi)存資源、日志系統(tǒng)、數(shù)據(jù)存儲(chǔ)和應(yīng)用進(jìn)程。系統(tǒng)的監(jiān)控和管理是以節(jié)點(diǎn)為單位的。靜態(tài)： 一組環(huán)境變量和環(huán)境變量對應(yīng)的目錄和文件、一組執(zhí)行碼。 環(huán)境變量包括：

TLQHOMEDIR（系統(tǒng)安裝路徑）

TLQCONFDIR（配置文件存放路徑）

TLQMSGDIR（隊(duì)列文件存放路徑）

TLQSNDFILESDIR（發(fā)送文件存放路徑）

TLQRCVFILESDIR（接收文件存放路徑）

TLQLOGDIR（日志文件存放路徑） 動(dòng)態(tài)：一組運(yùn)行進(jìn)程、IPC資源和一組目錄文件

9消息

消息，是在應(yīng)用進(jìn)程之間或兩臺(tái)計(jì)算機(jī)間傳送的數(shù)據(jù)，為TongLINK/Q的最小處理單元。消息的結(jié)構(gòu)： 消息在結(jié)構(gòu)上分為消息描述和消息體。數(shù)據(jù)類型： 消息分為BUFFER消息和FILE消息

BUFFER消息的消息體為內(nèi)存中的一段數(shù)據(jù)。

FILE消息的消息體為文件名。消息組成： 消息分為單消息和組消息。隊(duì)列控制單元隊(duì)列控制單元，英文為QueueControlUnit，簡稱QCU，是對隊(duì)列及消息進(jìn)行監(jiān)控和管理運(yùn)行單位；

運(yùn)行中的QCU由BQS（BufferQueueSystem

）、數(shù)據(jù)交換區(qū)（發(fā)送/接收緩沖區(qū)）、隊(duì)列、監(jiān)控進(jìn)程和管理進(jìn)程組成；可以根據(jù)隊(duì)列和消息的特點(diǎn)，將隊(duì)列組織成多個(gè)QCU，分別進(jìn)行管理。 節(jié)點(diǎn)和QCU一個(gè)節(jié)點(diǎn)的的隊(duì)列可以以包含成多多個(gè)QCU，分別進(jìn)行行管理。NodeQCU2QCU4QCU1QCU3隊(duì)列隊(duì)列是存儲(chǔ)儲(chǔ)消息的數(shù)數(shù)據(jù)結(jié)構(gòu)，，可存在于于主存儲(chǔ)器器、磁盤或或相似的輔輔助存儲(chǔ)器器。隊(duì)列只屬于于某一個(gè)隊(duì)隊(duì)列控制單單元，由隊(duì)隊(duì)列控制單單元負(fù)責(zé)維維護(hù)和管理理。隊(duì)列分為物物理隊(duì)列和和邏輯隊(duì)列列兩種：－物理隊(duì)隊(duì)列占有物物理存儲(chǔ)空空間；－邏輯隊(duì)隊(duì)列只是隊(duì)隊(duì)列定義，，不占有物物理空間。。根據(jù)隊(duì)列的的生命周期期分為：－永久隊(duì)隊(duì)列－臨時(shí)隊(duì)列（（存在于一一次注冊和和注銷之間間）物理隊(duì)列本地隊(duì)列：：用于存放：：1異地通過網(wǎng)網(wǎng)絡(luò)傳輸過過來的消息息、2本地應(yīng)用發(fā)發(fā)送的消息息、3系統(tǒng)產(chǎn)生的的事件消息息、4系統(tǒng)內(nèi)部管管理信息等等。發(fā)送隊(duì)列：：發(fā)送隊(duì)列是是消息發(fā)送送到異地節(jié)節(jié)點(diǎn)的媒介介隊(duì)列。如果要將消消息傳輸?shù)降疆惖?，消消息必須首首先發(fā)送到到發(fā)送隊(duì)列列。通過一一個(gè)發(fā)送隊(duì)隊(duì)列可以將將消息發(fā)往往異地某個(gè)個(gè)節(jié)點(diǎn)上的的多個(gè)隊(duì)列列。邏輯隊(duì)列遠(yuǎn)程隊(duì)列：：為遠(yuǎn)方節(jié)點(diǎn)點(diǎn)的一個(gè)本本地隊(duì)列或或遠(yuǎn)程隊(duì)列列在本地節(jié)節(jié)點(diǎn)的一個(gè)個(gè)邏輯映射射。當(dāng)遠(yuǎn)程隊(duì)列列對應(yīng)的目目的隊(duì)列為為一個(gè)遠(yuǎn)程程隊(duì)列時(shí)，，表示消息息的傳輸過過程還要繼繼續(xù)下去（（路由,落地路由）。多個(gè)遠(yuǎn)程隊(duì)隊(duì)列可以對對應(yīng)一個(gè)發(fā)發(fā)送隊(duì)列，，即通過多多個(gè)遠(yuǎn)程隊(duì)隊(duì)列發(fā)送消消息其實(shí)都都是通過一一個(gè)物理的的發(fā)送隊(duì)列列發(fā)出。集群隊(duì)列：：由多個(gè)隊(duì)列列組成的隊(duì)隊(duì)列集合。。當(dāng)消息放放入到集群群隊(duì)列時(shí)，，按照一定定比例被放放入到集合合中的多個(gè)個(gè)隊(duì)列中。。功能：集群主要有有線路備份份和負(fù)載均均衡兩種功功能隊(duì)列間的關(guān)關(guān)系qcu2qcu1SQ1RQ1RQ2RQ3LQ1RQ1LQ2RQ4SQ2BQS（BufferQueueSystem）存放應(yīng)用跟跟系統(tǒng)之間間進(jìn)行交換換的控制信信息。*分為三個(gè)部部分：QOUT：存放應(yīng)用用發(fā)向核心心的請求信信息QIN：存放核心心返回給應(yīng)應(yīng)用的應(yīng)答答（除發(fā)送送消息的應(yīng)應(yīng)答外）QAUX：存放發(fā)送送消息后核核心返回的的應(yīng)答。BQS（發(fā)送程序序與BQS的調(diào)度關(guān)系系）S_APPQCU核心進(jìn)程QOUTQAUXSendBuffSQRQ124357867BQS（接收程序序與BQS的調(diào)度關(guān)系系）R_APPQCU核心進(jìn)程QOUTQINRecvBuffLQ12385467傳輸進(jìn)程傳輸進(jìn)程：：傳輸進(jìn)程分分為發(fā)送進(jìn)進(jìn)程和接收收進(jìn)程兩種種；傳輸進(jìn)程通通過創(chuàng)建工工作線程來來完成消息息的網(wǎng)絡(luò)傳傳輸:－發(fā)送線線程負(fù)責(zé)連連接的建立立和消息數(shù)數(shù)據(jù)的網(wǎng)絡(luò)絡(luò)發(fā)送。－接收線線程負(fù)責(zé)消消息數(shù)據(jù)的的網(wǎng)絡(luò)接收收。發(fā)送進(jìn)程：：監(jiān)視隊(duì)列列，創(chuàng)建和和監(jiān)控發(fā)送送線程。接收進(jìn)程：：監(jiān)聽端口口，創(chuàng)建和和監(jiān)控接收收線程。發(fā)送連接：：連接為兩個(gè)個(gè)節(jié)點(diǎn)QCU間進(jìn)行數(shù)據(jù)據(jù)傳輸?shù)耐ㄍǖ溃═CP下為socket連接）；由數(shù)據(jù)發(fā)起起方建立，，連接雙方方進(jìn)行維護(hù)護(hù)；一個(gè)發(fā)送進(jìn)進(jìn)程可以對對應(yīng)一個(gè)或或多個(gè)發(fā)送送連接。節(jié)點(diǎn)和傳輸輸進(jìn)程一個(gè)節(jié)點(diǎn)可可以有一個(gè)個(gè)或多個(gè)傳傳輸進(jìn)程，，各個(gè)傳輸輸進(jìn)程的傳傳輸工作互互不影響NodeSendProcSendProcRecvProcRecvProcCliBrokerCliBroker發(fā)送隊(duì)列和和發(fā)送連接接一個(gè)發(fā)送進(jìn)進(jìn)程只能負(fù)負(fù)責(zé)某個(gè)特特定的QCU中消息的發(fā)發(fā)送一個(gè)QCU可以使用一一個(gè)或多個(gè)個(gè)發(fā)送進(jìn)程程進(jìn)行消息息發(fā)送一個(gè)發(fā)送進(jìn)進(jìn)程可以負(fù)負(fù)責(zé)一個(gè)或或多個(gè)發(fā)送送連接的管管理發(fā)送連接跟跟發(fā)送隊(duì)列列一一對應(yīng)應(yīng)QCUsndQsndQsndQsndQsndQSndProcsndConnsndConnsndConnsndConnsndConnSndProc端口監(jiān)聽與與接收進(jìn)程程發(fā)送方可以以通過一個(gè)個(gè)或多個(gè)端端口向某個(gè)個(gè)接收節(jié)點(diǎn)點(diǎn)發(fā)送消息息一個(gè)接收進(jìn)進(jìn)程只能負(fù)負(fù)責(zé)某個(gè)特特定端口的的監(jiān)聽，且且一個(gè)端口口不能由多多個(gè)進(jìn)程監(jiān)監(jiān)聽通過某個(gè)端端口收到的的消息只能能放到某個(gè)個(gè)特定QCU的隊(duì)列中，，但可以為為任意隊(duì)列列nodeQCU1QCU2PortRcvProcRcvProcRcvProc接收線程接收線程接收線程接收線程接收線程接收線程接收線程客戶端代理理客戶端代理理作為客戶戶端應(yīng)用跟跟Server交互的中間間媒介。客戶端代理理接收來自自客戶端的的連接，創(chuàng)創(chuàng)建工作線線程。工作線程負(fù)負(fù)責(zé)：接收客戶端端發(fā)來的消消息數(shù)據(jù)，，放入到隊(duì)隊(duì)列中；從隊(duì)列中取取消息數(shù)據(jù)據(jù)，并發(fā)送送給客戶端端；維護(hù)連接。。端口監(jiān)聽與與客戶端代代理nodeQCU1QCU2PortCliBroker工作線程工作線程工作線程工作線程工作線程CliBroker工作線程工作線程工作線程CliBrokerClientAPP25瘦客戶TLQ的客戶端是是跟TLQ服務(wù)器相對對的概念，，客戶端應(yīng)應(yīng)用運(yùn)行時(shí)時(shí)不需要核核心進(jìn)程和和各種IPC資源的輔助助；26主要功能介介紹27點(diǎn)對點(diǎn)傳輸輸圖形示意：：發(fā)送消息瀏覽消息接收消息刪除消息遠(yuǎn)程隊(duì)隊(duì)列本地隊(duì)隊(duì)列qcugetqcusend28點(diǎn)對點(diǎn)點(diǎn)傳輸輸發(fā)送消消息:普通消消息分分類：：Buffer消息：：內(nèi)存存中的的一段段數(shù)據(jù)據(jù)File消息：：文文件件消息息，一一個(gè)消消息只只能對對應(yīng)一一個(gè)文文件消息可可發(fā)送送到的的隊(duì)列列：發(fā)送隊(duì)隊(duì)列本地隊(duì)隊(duì)列遠(yuǎn)程隊(duì)隊(duì)列29點(diǎn)對點(diǎn)點(diǎn)傳輸輸接收消消息:只能接接收ready狀態(tài)的的消息息只能從從本地地隊(duì)列列中接接收消消息采用等待模模式接接收（（等待待時(shí)間間大于于0或-1）和非非等待待模式式（等等待時(shí)時(shí)間為為0）接收收30點(diǎn)對點(diǎn)點(diǎn)傳輸輸消息接接收確確認(rèn)模模式MsgOpt.AckMode：自動(dòng)接收模式TLQACK_AUTO接收后，自動(dòng)刪除隊(duì)列中的消息用戶確認(rèn)模式TLQACK_USER接收后，須手工確認(rèn)才從隊(duì)列中刪除消息。如果AckType=TLQACK_COMMIT提交確認(rèn)后，成功接收的消息從隊(duì)列中清除；如果AckType=TLQACK_ROLLBACK回滾確認(rèn)后，成功接收的消息被重新放回到隊(duì)列中31發(fā)布訂訂閱發(fā)布訂訂閱32發(fā)布訂訂閱發(fā)布訂訂閱是是一種種一對對多的的消息息傳輸輸模式式。消消息發(fā)發(fā)布者者和訂訂閱者者通過過主題題建立立聯(lián)系系，雙雙方無無需知知道對對方的的存在在。發(fā)布（（者））：提提供消消息（（者））訂閱（（者））：消消費(fèi)消消息（（者））主題：：訂閱閱者和和發(fā)布布者之之間發(fā)發(fā)生聯(lián)聯(lián)系的的媒介介33發(fā)布訂訂閱概念發(fā)布訂訂閱機(jī)機(jī)制：：區(qū)別與與P2P消息傳傳輸模模式，，P2P模式式下，，消息息的生生產(chǎn)者者必須須知道道消息息的消消費(fèi)者者在哪哪里。。Pub/Sub下下，消消息的的生產(chǎn)產(chǎn)者無無需知知道消消息的的消費(fèi)費(fèi)者在在哪里里，而而且生生產(chǎn)者者生產(chǎn)產(chǎn)的一一個(gè)消消息可可以為為多個(gè)個(gè)消費(fèi)費(fèi)者使使用，，生產(chǎn)產(chǎn)者和和消費(fèi)費(fèi)者之之間通通過Topic進(jìn)行行關(guān)聯(lián)聯(lián)。發(fā)布者者：提供信信息者者訂閱者者：信息消消費(fèi)者者訂閱者者標(biāo)識(shí)識(shí)：本地訂訂閱者者：MsgId異地訂訂閱者者：相相鄰的的代理理名34發(fā)布訂訂閱圖示PublisherSubscriberSubscriberSubscriberSubscriber主題舉例：：古董董拍賣賣，主主題為為某個(gè)個(gè)古董董的競競價(jià)發(fā)布者者：發(fā)發(fā)布古古董的的最新新價(jià)格格信息息訂閱者：：訂閱古古董的最最新價(jià)格格信息35發(fā)布訂閱閱發(fā)布類型型Event--事件型：：每一次發(fā)發(fā)布操作作都是獨(dú)獨(dú)立的。。這種消消息一般般為重要要的信息息，如果果訂閱者者沒有收收到可能能造成損損失。注：允許許有多個(gè)個(gè)發(fā)布者者，只允允許先訂訂閱后發(fā)發(fā)布State--狀態(tài)型：：一般為周周期性發(fā)發(fā)布更新新的消息息，后面面發(fā)布的的消息會(huì)會(huì)覆蓋前前一次發(fā)發(fā)布的消消息。注：一般般只允許許有一個(gè)個(gè)發(fā)布者者，由用用戶保證證。發(fā)布范圍圍Local--本地發(fā)布布:發(fā)布的消消息只會(huì)會(huì)被本地地的訂閱閱者收到到；Global--異地發(fā)布布：只會(huì)會(huì)被非本本地的訂訂閱者收收到；Local|Global--全局發(fā)布布：整個(gè)個(gè)網(wǎng)絡(luò)中中的訂閱閱者均會(huì)會(huì)收到。。36發(fā)布訂閱閱訂閱類型型持久訂閱閱：代理理重啟后后，訂閱閱請求信信息依然然存在。。非持久訂訂閱：應(yīng)應(yīng)用離線線或代理理重啟后后，該訂訂閱請求求信息不不復(fù)存在在。訂閱范圍圍Local--本地訂閱閱：訂閱閱者只能能收到本本地發(fā)布布者發(fā)布布的信息息。Global--異地訂閱閱：訂閱閱者不會(huì)會(huì)收到本本地發(fā)布布的信息息，只會(huì)會(huì)收到異異地發(fā)布布的信息息。Local|Global--全局訂閱閱：訂閱閱者能夠夠收到本本地發(fā)布布者和異異地發(fā)布布者發(fā)布布的消息息。37事務(wù)事務(wù)38事務(wù)概念為一組邏邏輯上相相關(guān)的操操作組成成的工作作單元，，在操作作時(shí)，這這些操作作要么一一起提交交，要么么一起回回滾。組成和操操作特點(diǎn)點(diǎn)（1）單純的發(fā)發(fā)送和接收操作作，發(fā)送送和接收收操作的的結(jié)合；（2）事務(wù)的的不同分分支可以以操作一一個(gè)或多多個(gè)不同同的隊(duì)列列，但不不能跨QCU；（3）多個(gè)組組消息或或單消息息的接收收與發(fā)送送；（4）刪除和和瀏覽操操作不能能放在事事務(wù)中。。提交提交之后后，事務(wù)務(wù)中的所所有動(dòng)作作才開始始執(zhí)行。回滾當(dāng)事務(wù)回回滾信號(hào)號(hào)發(fā)出后后，等于于所有的的操作被被放棄，，即發(fā)往往隊(duì)列中中的消息息被清除除，從本本地隊(duì)列列中接收收的消息息被重新新放回。。39事件管理理事件管理理事件管理理為系統(tǒng)運(yùn)運(yùn)行過程程中發(fā)生生的特定定情況，，這些特特定情況況可以被被系統(tǒng)捕捕獲或識(shí)識(shí)別，以以便用于于分析。。事件發(fā)生生時(shí)，如如果要求求被捕獲獲，則會(huì)會(huì)產(chǎn)生一一條消息息（EventMessage）放入到到一個(gè)特特定隊(duì)列列(TLQ.SYS.EVENT)中編寫應(yīng)用用分析事事件隊(duì)列列中的事事件消息息，跟蹤蹤系統(tǒng)的的運(yùn)行。。41事件管理理事件消息息概述（1）定義事事件是為為了跟蹤蹤所有消消息的狀狀態(tài)以及及被處理理的狀況況，對所所有消息息有效（2）為持久久性消息息；（3）生命周周期無限限長；（4）比普通通消息多多兩個(gè)屬屬性：事事件類型型和事件件發(fā)生的的時(shí)間；；（5）TLQ啟動(dòng)時(shí)，，會(huì)自動(dòng)動(dòng)創(chuàng)建事事件隊(duì)列列TLQ.SYS.EVENT；（6）事件隊(duì)隊(duì)列滿后后，新產(chǎn)產(chǎn)生的事事件消息息將被丟丟棄；42事件管理理BeginSend開始發(fā)送消息SendOver發(fā)送消息完畢BeginRecv開始接收消息RecvOver消息接收完畢Expiry生命周期超時(shí)FileFail因?qū)Ψ娇臻g（硬盤空間和隊(duì)列空間）不足，嘗試6次后從發(fā)送隊(duì)列中刪除RollbackCount本地隊(duì)列中消息被rollback6次FileDel文件消息續(xù)傳或開始發(fā)送時(shí)，對應(yīng)的文件被刪除或不存在時(shí)事件類型型43集群概念集群是兩兩個(gè)或更更多隊(duì)列列控制單單元組成成的組，，它們在在邏輯上上是相關(guān)關(guān)的，物物理上是是可以不不相關(guān)的的。應(yīng)用用可以發(fā)發(fā)送消息息至同一一群集中中的其它它隊(duì)列控控制單元元，而不不需要設(shè)設(shè)置特殊殊發(fā)送連連接、遠(yuǎn)遠(yuǎn)程隊(duì)列列和發(fā)送送隊(duì)列。。集群隊(duì)列列為一種種特殊的的隊(duì)列，，為一個(gè)個(gè)包含多多個(gè)真正正隊(duì)列的的隊(duì)列列列表。當(dāng)當(dāng)消息發(fā)發(fā)送到集集群隊(duì)列列時(shí)，消消息實(shí)際