TongLINK/QV8.0系統(tǒng)開(kāi)發(fā)手冊(cè)_客戶端集群地址：市海淀區(qū)彩和坊路10號(hào)1+12、客戶服務(wù) ?1993-2011科 ?1993-2011科技。TongTech、TongLINK/Q、TongEASY、TongWeb、TongIntegrator、TongSEC、TongWorkflow、TongGTP、MBP是科技的商標(biāo)。其他所有的公司和產(chǎn)品名稱可能為第所有。布訂閱、集群、網(wǎng)絡(luò)傳輸、SSL安全傳輸、安全出口、事務(wù)、管理、應(yīng)用程序管理、系統(tǒng)管理、目的編輯約束、配置相關(guān)數(shù)據(jù)結(jié)構(gòu)、配置文件動(dòng)/靜態(tài)配置、配置文件相關(guān)編程和編譯、使用Jva進(jìn)行配置文件的編輯等。主要介紹系統(tǒng)監(jiān)視工具tlqstat、系統(tǒng)對(duì)象控制工具、錯(cuò)誤信息查看工具、資源占用計(jì)算工具UNIXWindows的安裝、系統(tǒng)結(jié)構(gòu)、參數(shù)配置、主要介紹TongLINK/QJMS應(yīng)用體系結(jié)構(gòu)、JAVA說(shuō)明、使用TLQJMS程序的步驟、TLQJMS程序配置說(shuō)明、TLQJMS環(huán)境設(shè)置、編寫(xiě)TLQJMS程序、編寫(xiě)發(fā)布訂閱應(yīng)用、JMS消息、JMS中的加密& 第1章客戶端集群簡(jiǎn) 客戶端集群概 多客戶端應(yīng)用場(chǎng) 少客戶端應(yīng)用場(chǎng) 第2章客戶端集群相關(guān)參數(shù)配 配置文件 配置信息小 [Factory]連接工廠的參數(shù)說(shuō) 應(yīng)用編寫(xiě)中用到的數(shù)據(jù)結(jié) 消息描述的數(shù)據(jù)結(jié)構(gòu) 結(jié)構(gòu)概 域詳細(xì)說(shuō) 消息操作選項(xiàng)的數(shù)據(jù)結(jié)構(gòu) 結(jié)構(gòu)描 域詳細(xì)說(shuō) 消息錯(cuò)誤信息的數(shù)據(jù)結(jié)構(gòu) 結(jié)構(gòu)描 域說(shuō) 客戶端集群連接工廠的數(shù)據(jù)結(jié)構(gòu) 結(jié)構(gòu)描 域說(shuō) 客戶端集送線程信息的數(shù)據(jù)結(jié)構(gòu) 結(jié)構(gòu)描 域說(shuō) 客戶端集群線程信息的數(shù)據(jù)結(jié)構(gòu) 結(jié)構(gòu)描 域說(shuō) 客戶端集群連接信息的數(shù)據(jù)結(jié)構(gòu) 結(jié)構(gòu)描 域說(shuō) 客戶端集群實(shí)例句柄的數(shù)據(jù)結(jié)構(gòu) 結(jié)構(gòu)描 域說(shuō) 函數(shù)定 函數(shù)應(yīng)用函 C客戶端集群的 消息發(fā) 發(fā)送消息流 發(fā)送消息應(yīng)用示 消息接 接收消息流 接收消息舉例說(shuō) 第4章JMS客戶端集群接口介 消息發(fā) 發(fā)送消息流 發(fā)送消息應(yīng)用示 消息接 接收消息流 接收消息應(yīng)用示 第1章1-1-1-1-產(chǎn)者clusterQueueProducer，然后通過(guò)集群隊(duì)列生產(chǎn)者向目標(biāo)隊(duì)列發(fā)送消息。消費(fèi)者clusterQueueConsumer，用于接收消息。()接收消息：通過(guò)clusterQueueConsumer的setMessageListener設(shè)置消息器，接收目標(biāo)隊(duì)列中的消息。當(dāng)接收隊(duì)列中有消息時(shí)，會(huì)調(diào)用消息器中的onMessage方法來(lái)通知應(yīng)用。第2章客戶端集群相關(guān)配置信息都存放在一個(gè)文件名為tlqjndi.conf配置文件中，tlqjndi.conf 連接工廠小 客戶端集群連接工 客戶端集群隊(duì) --# -- -- tmqiAddressList=tlqlocal://localhost/qcu1 --連接url --間隔，單位 --Consumer流控大小，消費(fèi)者一次可以發(fā)送tmqiConsumerFlowThreshold=50 tmqiAckTimeout= --響應(yīng)超時(shí)時(shí)間,單位毫秒tmqiProducerFlowBytesLimit Produce流控大小, -- --tmqiLocalFileConnection=false Jndi Jndi jndi TLQ# --Jndi --Jndi記錄小節(jié)ame= --jndiame= --TLQ的TlqPubQueueName=TLQ.SYS.BROKER.SYN1 TlqSubQueueName=TLQ.SYS.BROKER.SUB1 ClusterFactoryName Reference= --連接工廠# JndiClusterQueueName= ClusterQueueName= Reference= --連接工廠 2-cfqftfxcfxqfxtf1)本地方式：為需要連接的QCU名；默認(rèn)為2)方式：tlkq://ipaddress:port。Ipaddress為要連接的TLQIP地址，port為運(yùn)行的端。4字符秒Consumer流控大小，消費(fèi)者一次可條Consumer流控小于百分比多少時(shí)發(fā)送恢百分0Produce流控bytes大小。僅對(duì)方式0端，格式為：IP:PORT(如：1字符或字符2-2-若沒(méi)有配置，則為缺省的訂閱接收隊(duì)列若沒(méi)有配置，則為缺省的綜合隊(duì)列2-2-3-signedsigned00signed4signedsigned00unsigned0unsigned00char0char0000signed0signed00unsigned0]00unsigned0signedsigned0000版本號(hào)。一般用于。為消息。消息只能由產(chǎn)生，用戶應(yīng)用不能產(chǎn)生類型的消息消息的用戶數(shù)據(jù)的取值為64或取值如下：若消息類型MsgType為BUF_MSG類型時(shí)，則為消息內(nèi)容。若Expiry等于0，則表示發(fā)送時(shí)不運(yùn)行；則表示為非持久消息；若消息的持久性大于0，則表示是持久性消息。TLQ的消息屬性無(wú)法準(zhǔn)確描述用戶的消息時(shí)，可采用自定義屬性自義方式進(jìn)一步用戶需要把此值賦給自定義屬性串的長(zhǎng)度UserPropertyLen。 ode與MsgId一起使用，保證了單消息在網(wǎng)絡(luò)中的唯一性。 PPP3-signed。0signed00signed0條件查詢字符串的長(zhǎng)0訂閱的類00signedsignedsigned消息操作類型包括：發(fā)送、接收、發(fā)布、取消0版本號(hào)。一般用于。。消息標(biāo)識(shí)產(chǎn)生方式取值為0、1或分別取值如下：TLQMIF_AUTO TLQMATCH_NONE外，其他條件可以自由組合。根據(jù)需要條件匹配選項(xiàng)可以選一個(gè)條 ODE|取值為1、0或分別取值如下：ageBETWEEN15ANDprop_nameISJMSType='car'ANDcolor='blue'ANDweight>為開(kāi)始發(fā)送數(shù)據(jù)產(chǎn)生的為發(fā)送數(shù)據(jù)完成產(chǎn)生的為開(kāi)始接收數(shù)據(jù)產(chǎn)生的系統(tǒng)隊(duì)列TLQ.SYS.EVENT中。用戶確認(rèn)可取值1、0或分別取值如下：WaitInterval0時(shí)，表示有限等待時(shí)間，如果在等待時(shí)間內(nèi)出現(xiàn)符合條件的消息則返回，否則調(diào)用Tlq_PutMsg（）函數(shù)前消息操作類型取值為2、3、4、5、6或分別取值如下：3-tlqsys3-charchar客戶端IP地址客戶端IP地址3-3-3-3-信息集合最大數(shù)為100。方面進(jìn)行具體介紹。沒(méi)有做特別說(shuō)明的接口函數(shù)既適用于UNIX環(huán)境又適用于Windows環(huán)境。須包含頭文件tlq_api.h。＃include“tlq_api.h”#include〖原型〗 JNDIserver地址，格式為：ip:port[|ip:port]可使用主備地址，主地址無(wú)效時(shí)可采 〖原型〗intTlq_ClusterCreateInstance(TLQCLUSTER_HANDLE 用于接收消息的操作選項(xiàng)，發(fā)送實(shí)例忽略此參 〖原型〗 3-#include"tlq_api.h" main(intargc,char{ ret=0,count= char*msgcontent; inti=1,j=0;charcharCqName[49];int{ }{MsgSizeatoi(argv[3]);/*消息的大小，在程序中構(gòu)造Expiry=atoi(argv[4]);/*消息的生命周期，>0為時(shí)間，<0為無(wú)限長(zhǎng)，=0不放入隊(duì)列中*/Persistenceatoi(argv[5]);/*消息持久性標(biāo)志，1為持久性，0為非持久性，-1為消息與隊(duì)列的持久性一致LoopTimeatoi(argv[6]);/*消息的發(fā)送次數(shù)}{return-}{return-}/***初始化msginfo****/{printf("LoopTimeis:%d\n",i);uMsg.MsgType=BUF_MSG;uMsg.Persistence=Persistence;/*持久性*/uMsg.Expiry=Expiry;/*生命周期*/msgcontent=(char*)malloc(MsgSize);{ formsgcontent }uMsg.MsgSize=MsgSize;} return}#include"tlq_api.h" main(intargc,char{ inti=1,j=0;charcharCqName[49];char*lib;{ }{sleeptime=strcpy(lib,argv[4]);ConNum=}{return-}/***初始化msginfo****/{return-}/*讓子線程先執(zhí)行*/ return第4章JMS〖原型〗publicvoidclusterConnection(intsessionNum,intconnectionNumintsessionNum：session數(shù)量；〖原型〗publicvoidclusterConnection(intsessionNumint〖原型〗publicvoid〖原型〗publicvoid〖原型〗publicvoid〖原型〗publicClusterQueueProducer〖原型〗publicvoid〖原型〗publicvoid〖原型〗publicMessagesend(bytecontent,Properties〖原型〗publicMessagesend(byte〖原型〗publicvoid4-LookupClusterQueuepublicclass{publicstaticvoidmain(String[]argv){StringqueueName="cq1";try{ClusterQueuequeue=ClusterQueueSuppor