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