Posted on 2008-12-11 15:48
Prayer 閱讀(1391)
評(píng)論(0) 編輯 收藏 引用 所屬分類:
TUXEDO
索引：
1.TPSVCINFO
2.buffer管理
3.server的client角色
4.tpadvertise
5.tpunadvertise
6.tpreturn
7.tpforward
8.tpsvrinit/tpsvrdone
--------------------------------------------------------------------------------在server端tuxedo本身提供了一個(gè)標(biāo)準(zhǔn)的main()函數(shù)，它負(fù)責(zé)完成一些必要的工作。server端編程只需要編寫service處理函數(shù)，進(jìn)行service的請(qǐng)求處理和回應(yīng)處理。所以，在server端不需要調(diào)用tpinit()和tpterm()。1.TPSVCINFO
每個(gè)service函數(shù)都有統(tǒng)一的形式：
void tpservice (TPSVCINFO *svcinfo);只有一個(gè)參數(shù)，該參數(shù)是指向TPSVCINFO結(jié)構(gòu)的指針（atmi.h）。該結(jié)構(gòu)定義如下：
struct tpsvcinfo {
char name[32]; /*service名（最大15個(gè)字符）*/
long flags; /* client調(diào)用時(shí)指定的flags */
char *data; /* 接收的數(shù)據(jù)地址 */
long len; /* 數(shù)據(jù)長度 */
int cd; /* 會(huì)話方式下的連接描述符 */
long appkey; /* 應(yīng)用認(rèn)證的key */
CLIENTID cltid; /* client ID */
};--------------------------------------------------------------------------------2.buffer管理
在service函數(shù)里，一樣可以調(diào)用tpalloc()、tpfree()、tprealloc()處理自定義的buffer。通過TPSVCINFO參數(shù)傳遞的buffer是使用tpalloc()分配的，所以可以對(duì)它使用tprealloc()。要注意的是在service函數(shù)里自己調(diào)用tpalloc()分配的空間在退出要釋放，除非該空間作為tpreturn()或tpforward()的參數(shù)。如果分配的空間不釋放，最終會(huì)耗盡該server的內(nèi)存資源。對(duì)于TPSVCINFO傳遞的buffer不用手動(dòng)釋放。使用舉例：
void
BAL (TPSVCINFO* input)
{
char* f, f1, f2;
f=input->data;
f1=tpalloc (“STRING”, NULL, 80);
f2=tpalloc (“STRING”, NULL, 120);
. . .
tpfree ((char *) f2);
tpreturn (TPSUCCESS, 0, f1, 0, 0);
}
可以使用tptypes()查看buffer的類型。如：
void ABAL(TPSVCINFO *transb)
{
char type[20], subtype[20];
long len;
len = tptypes(transb->data, type, subtype);
if (len == 0) {
/*error*/
userlog(“NULL message sent...\n”);
...
}
if (strcmp(type, “FML”) == 0) {
/* convert FML to aud VIEW; */
} else if (strcmp(type, “VIEW”) == 0) {
if (strcmp(subtype, “aud”) != 0) {
/*error*/
userlog(“Wrong VIEW subtype...”);
...
}
} else {
/*error*/
userlog(“Invalid buffer type ...”);
...
}
}--------------------------------------------------------------------------------3.server的client角色
tuxedo的機(jī)制允許一個(gè)server程序作為client，調(diào)用tpcall()去請(qǐng)求別的service服務(wù)。這樣做可以避免代碼的冗余，但效率上會(huì)有犧牲。這樣做時(shí)有一些情況要注意：如果一個(gè)server要把負(fù)責(zé)返回接收到的buffer，則不要使用這個(gè)buffer作為參數(shù)來請(qǐng)求別的service服務(wù)。可以分配輔助性的buffer來處理，這樣做可以避免在tpcall()過程中改變了輸入buffer的內(nèi)容和類型。
一個(gè)server不能請(qǐng)求一個(gè)只被它本身發(fā)布的service。這樣做會(huì)導(dǎo)致死鎖。例外是請(qǐng)求時(shí)指定TPNOREPLY標(biāo)志。 --------------------------------------------------------------------------------4.tpadvertise
service可以在啟動(dòng)時(shí)發(fā)布，也可使用tmadmin或使用tpadvertise動(dòng)態(tài)發(fā)布。int tpadvertise (char *svcname, void (*func)(TPSVCINFO *));參數(shù)說明：
svcname：要發(fā)布的service名；
func：該service對(duì)應(yīng)的處理函數(shù)指針；如果該service用func已經(jīng)發(fā)布，則函數(shù)立即成功返回。如果調(diào)用server是MSSQ集的一員，則該MQSQ中的所有server都發(fā)布這個(gè)service。失敗時(shí)返回-1。出錯(cuò)原因：該service已經(jīng)用別的函數(shù)發(fā)布了；
超過了最大允許發(fā)布的service數(shù)量（MAXSERVICES）；
參數(shù)錯(cuò)誤（有為NULL的）；
協(xié)議錯(cuò)；
操作系統(tǒng)錯(cuò)等。 --------------------------------------------------------------------------------5.tpunadvertise
一個(gè)server取消發(fā)布一個(gè)它已經(jīng)發(fā)布的service。int tpunadvertise (char *svcname);參數(shù)說明：
svcname：操作的service名；如果調(diào)用server是MSSQ集的一員，則該MQSQ中的所有server都取消發(fā)布這個(gè)service。失敗時(shí)返回-1。失敗原因：service沒有發(fā)布；
參數(shù)錯(cuò)誤；
協(xié)議錯(cuò)等。 --------------------------------------------------------------------------------6.tpreturn
普通的C函數(shù)返回時(shí)使用return語句。但在tuxedo程序里，不能使用return，必須使用tpreturn()終止當(dāng)前處理并發(fā)送回應(yīng)給請(qǐng)求端；或者使用tpforward()把請(qǐng)求傳遞給別的service處理。void tpreturn(int rval, int rcode, char *data,long len, long flags);參數(shù)說明：
rval：返回值，決定該service請(qǐng)求是否成功。如三個(gè)可選值：TPSUCCESS：成功。tpcall和tpgetrply將返回一個(gè)非負(fù)值；如果是會(huì)話service，則產(chǎn)生TPEV_SVCSUCC事件；
TPFAIL：失敗。tpcall和tpgetrply將返回-1；tperrno設(shè)置為TPESVCFAIL，如果是會(huì)話service，則產(chǎn)生TPEV_SVCFAIL事件；
TPEXIT：除了TPFAIL的功能外，該server隨后將終止，如果配置了重啟動(dòng)，則該server將重新啟動(dòng)。
rcode：應(yīng)用定義的返回碼。service將向client返回該數(shù)字，tuxedo本身不對(duì)其做任何解釋，接收端通過全局變量tpurcode得到該值，在成功或失敗時(shí)該值都會(huì)返回；
data：返回給client端的數(shù)據(jù)buffer；
len：返回?cái)?shù)據(jù)的長度（只CARRAY類型有用）；
flags：標(biāo)志，當(dāng)前沒用。--------------------------------------------------------------------------------7.tpforward
調(diào)用tpforward的server不向client返回?cái)?shù)據(jù)，而是把更新過的buffer傳遞給另一個(gè)service做更多的處理，由它處理返回client數(shù)據(jù)等后續(xù)的工作。本身則返回到標(biāo)準(zhǔn)的main流程中。void tpforward(char *service, char *data, long len, long flags);參數(shù)說明：
service：后續(xù)的service的名稱；
data：指向傳遞的buffer的指針；
len：buffer的長度（只CARRAY有用）；
flags：當(dāng)前沒有使用；該函數(shù)不能用在會(huì)話service中。--------------------------------------------------------------------------------8.tpsvrinit/tpsvrdone
在一個(gè)server的實(shí)例啟動(dòng)時(shí)會(huì)調(diào)用tpsvrinit()，在結(jié)束時(shí)會(huì)調(diào)用tpsvrdown()。如果應(yīng)用沒有定義這兩個(gè)函數(shù)，則使用tuxedo提供的缺省函數(shù)。int tpsvrinit(int argc, char **argv);參數(shù)說明：形式類似與main函數(shù)的參數(shù)，函數(shù)里可以使用getopt和全局變量optind進(jìn)行處理，配置文件中的CLOPT命令行選項(xiàng)也傳遞到該函數(shù)。函數(shù)成功返回0，失敗返回-1。void tpsvrdone();