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