| 网站首页 | 业界新闻 | 小组 | 威客 | 人才 | 下载频道 | 博客 | 代码贴 | 在线编程 | 编程论坛
欢迎加入我们,一同切磋技术
用户名:   
 
密 码:  
共有 11650 人关注过本帖, 1 人收藏
标题:学习了FML后,自己练手写了一个tuxedo FML32服务器端和客户端程序,供大家参 ...
只看楼主 加入收藏
khaz
Rank: 3Rank: 3
等 级:论坛游侠
帖 子:130
专家分:188
注 册:2011-4-21
结帖率:77.78%
收藏(1)
 问题点数:0 回复次数:3 
学习了FML后,自己练手写了一个tuxedo FML32服务器端和客户端程序,供大家参考
本例是在Redflag DC server 5.0上,使用的是tuxedo9.1,从本地读取一个文件tlr.txt,然后把文件内容以FML32缓冲区方式发送到服务器,由服务器处理后,返回内容增加一个序号。文件内容为:
[hwt@localhost fml]$ cat tlr.txt
hwt 29 18677150924
lht 28 13398813422
csq 25 13234234564
服务器处理后,预期结果为:
[hwt@localhost fml]$ ./clientfml tlr.txt
hwt 29 18677150924 33
lht 28 13398813422 42
csq 25 13234234564 21
------------------------------------------------
步骤一:
设置环境变量:
[hwt@localhost fml]$ cat setenv.ksh
TUXDIR=/home/hwt/tux9.1/tuxedo9.1
PATH=$TUXDIR/bin:.:$PATH
export TUXDIR PATH
LD_LIBRARY_PATH=$TUXDIR/lib:$LD_LIBRARY_PATH; export LD_LIBRARY_PATH

APPDIR=/home/hwt/fml
TUXCONFIG=$APPDIR/tuxconfig
FIELDTBLS32=fmlfile
FLDTBLDIR32=$APPDIR
export APPDIR TUXCONFIG FLDTBLDIR32 FIELDTBLS32
[hwt@localhost fml]$ . ./setenv.ksh
步骤二:
[hwt@localhost fml]$ cat UBBconfigunix
*RESOURCES
IPCKEY          155442
MAXACCESSERS    50
MAXSERVERS      25
MASTER          SITE1
MODEL           SHM

*MACHINES
"localhost"
                LMID=SITE1
                APPDIR="/home/hwt/fml"
                TUXCONFIG="/home/hwt/fml/tuxconfig"
                TUXDIR="/home/hwt/tux9.1/tuxedo9.1"

*GROUPS
MATHGRP         LMID=SITE1
                GRPNO=1

*SERVERS
serverfml       SRVID=1
                SRVGRP=MATHGRP
                CLOPT="-A"

*SERVICES
编译UBB:
[hwt@localhost fml]$ tmloadcf -y UBBconfigunix
步骤三:
编写fmlfile文件,这里一定要注意了,字段必须大写,不然调试半天找不到错误原因的:
[hwt@localhost fml]$ cat fmlfile
*base 1000
NAME 1  string -        -
AGE  2  long -  -
PHONE 3 string -        -
NO  4 long - -
编写完毕后,编译文件,会生成fmlfile.h:
[hwt@localhost fml]$ mkfldhdr fmlfile
[hwt@localhost fml]$ cat fmlfile.h
/*      fname   fldid            */
/*      -----   -----            */
#define NAME    ((FLDID)41961)  /* number: 1001  type: string */
#define AGE     ((FLDID)9194)   /* number: 1002  type: long */
#define PHONE   ((FLDID)41963)  /* number: 1003  type: string */
#define NO      ((FLDID)9196)   /* number: 1004  type: long */
步骤四:
编写客户端程序clientfml.c
程序代码:
#include <stdio.h>
#include <string.h>
#include "atmi.h"
#include "fml32.h"
#include "userlog.h"
#include "fmlfile.h"

int main(int argc, char *argv[])
{
 
  if(argc!=2){
    (void)fprintf(stderr,"usage:%s filename\n",argv[0]);
    (void)exit(1);
    }
  FBFR32 *pF32,*pF32rec;
  long len;
  FLDLEN32 len2;

typedef struct tlr
{
  char name[10];
  long age;
  char phone[12];
  long no;
}*pTLR;

  int counter,i,ret;
  FILE *fp;
  char *str1=(char *)malloc(100);

  fp=fopen(argv[1],"r");
  if(fp==NULL){
  (void)fprintf(stderr,"%s: file no found!\n",argv[1]);
  (void)exit(1);
  }

  if (tpinit((TPINIT *)NULL) == -1) {
    (void)fprintf(stderr, "Failed to join application  -- %s\n",
          tpstrerror(tperrno));
    (void)userlog("Clientfml failed to join application  -- %s\n",
          tpstrerror(tperrno));
    (void)fclose(fp);
    (void)exit(1);
  }

  if ((pF32 = (FBFR32 *)tpalloc("FML32", NULL, Fneeded32(1,30))) == NULL) {
    (void)fprintf(stderr, "Failure to allocate FML32 buffer -- %s\n",
          tpstrerror(tperrno));
    (void)userlog("Clientfml failed to allocate FML32 buffer -- %s\n",
          tpstrerror(tperrno));
    (void)tpterm();
    (void)fclose(fp);
    (void)exit(1);
  }

  if ((pF32rec = (FBFR32 *)tpalloc("FML32", NULL, Fneeded32(1,32))) == NULL) {
    (void)fprintf(stderr, "Failure to allocate FML32 buffer -- %s\n",
                  tpstrerror(tperrno));
    (void)userlog("Clientfml failed to allocate FML32 buffer -- %s\n",
                  tpstrerror(tperrno));
    (void)fclose(fp);
    (void)tpterm();
    (void)exit(1);
  }

 pTLR ptlr[3];
 pTLR ptlr2[3];

  for(i=0;i<3;i++){
   ptlr[i]=(pTLR)malloc(sizeof(struct tlr));
    if(ptlr[i]==NULL){
    (void)fprintf(stderr,"mem allocate error!\n");
        (void)fclose(fp);
    (void)exit(1);
    }
   ptlr2[i]=(pTLR)malloc(sizeof(struct tlr));
        if(ptlr2[i]==NULL){
        (void)fprintf(stderr,"mem allocate error!\n");
        (void)fclose(fp);
        (void)exit(1);
        }

  }

  i=0;
  while(fgets(str1,100,fp)!=NULL){
  if((ret=sscanf(str1, "%s %ld %s", ptlr[i]->name, &ptlr[i]->age, ptlr[i]->phone))<3){
  (void)fprintf(stderr,"error in calling sscanf():%d\n",ret);
  (void)fclose(fp);
  (void)exit(1);
  }
  i++;
  }


  for(i=0;i<3;i++){ 
    if (Fadd32(pF32,NAME, (char *)ptlr[i]->name, 0) == -1) {
      (void)fprintf(stderr, "Failure to change NAME field -- %s\n",
            Fstrerror32(Ferror32));
      (void)userlog("Clientfml failed to change NAME field -- %s\n",
          Fstrerror32(Ferror32));
      (void)tpfree((char *)pF32);
      (void)tpfree((char *)pF32rec);
      (void)free(str1);
      for(i=0;i<3;i++){
      (void)free(ptlr[i]);
      (void)free(ptlr2[i]);
      }
      (void)fclose(fp);
      (void)tpterm();
      (void)exit(1);
    }
 
     if (Fadd32(pF32,AGE, (char *)&ptlr[i]->age, 0) == -1) {
      (void)fprintf(stderr, "Failure to change AGE field -- %s\n",
                  Fstrerror32(Ferror32));
      (void)userlog("Clientfml failed to change AGE field -- %s\n",
                  Fstrerror32(Ferror32));
      (void)tpfree((char *)pF32);
      (void)tpfree((char *)pF32rec);
      (void)free(str1);
      for(i=0;i<3;i++){
      (void)free(ptlr[i]);
      (void)free(ptlr2[i]);
      }
      (void)fclose(fp);
      (void)tpterm();
      (void)exit(1);
    }
 
      if (Fadd32(pF32,PHONE, (char *)ptlr[i]->phone, 0) == -1) {
      (void)fprintf(stderr, "Failure to change PHONE field -- %s\n",
                  Fstrerror32(Ferror32));
      (void)userlog("Clientfml failed to change PHONE field -- %s\n",
                  Fstrerror32(Ferror32));
      (void)tpfree((char *)pF32);
      (void)tpfree((char *)pF32rec);
      (void)free(str1);
      for(i=0;i<3;i++){
      (void)free(ptlr[i]);
      (void)free(ptlr2[i]);
      }
      (void)fclose(fp);
      (void)tpterm();
      (void)exit(1);
    }




  }
  if (tpcall("FMLTEST", (char *)pF32, 0, (char **)&pF32rec, &len,0) == -1) {
      (void)fprintf(stderr, "Failure to call the FMLTEST service -- %s \n",
          tpstrerror(tperrno));
      (void)userlog("Clientfml failed to call the FMLTEST service -- %s \n",
          tpstrerror(tperrno));
      (void)tpfree((char *)pF32);
      (void)tpfree((char *)pF32rec);
      (void)free(str1);
      for(i=0;i<3;i++){
      (void)free(ptlr[i]);
      (void)free(ptlr2[i]);
      }
      (void)fclose(fp);
      (void)tpterm();
      (void)exit(1);
  }

  for(i=0;i<3;i++){
    len2=10;
  if (Fget32(pF32rec,NAME, i, (char *)ptlr2[i]->name, &len2) == -1) {
      (void)fprintf(stderr, "Failure to call get the NAME field -- %s \n",
          Fstrerror32(Ferror32));
      (void)userlog("Clientfml failed to get the NAME field -- %s \n",
          Fstrerror32(Ferror32));
      (void)tpfree((char *)pF32);
      (void)tpfree((char *)pF32rec);
      (void)free(str1);
      for(i=0;i<3;i++){
      (void)free(ptlr[i]);
      (void)free(ptlr2[i]);
      }
      (void)fclose(fp);
      (void)tpterm();
      (void)exit(1);
  }
  len2=sizeof(long);
  if (Fget32(pF32rec,AGE, i, (char *)&ptlr2[i]->age, &len2) == -1) {
      (void)fprintf(stderr, "Failure to call get the AGE field -- %s \n",
                  Fstrerror32(Ferror32));
      (void)userlog("Clientfml failed to get the AGE field -- %s \n",
                  Fstrerror32(Ferror32));
      (void)tpfree((char *)pF32);
      (void)tpfree((char *)pF32rec);
      (void)free(str1);
      for(i=0;i<3;i++){
      (void)free(ptlr[i]);
      (void)free(ptlr2[i]);
      }
      (void)fclose(fp);

      (void)tpterm();
      (void)exit(1);
  }
  len2=12;
  if (Fget32(pF32rec,PHONE, i, (char *)ptlr2[i]->phone, &len2) == -1) {
      (void)fprintf(stderr, "Failure to call get the PHONE field -- %s \n",
                  Fstrerror32(Ferror32));
      (void)userlog("Clientfml failed to get the PHONE field -- %s \n",
                  Fstrerror32(Ferror32));
      (void)tpfree((char *)pF32);
      (void)tpfree((char *)pF32rec);
      (void)free(str1);
      for(i=0;i<3;i++){
      (void)free(ptlr[i]);
      (void)free(ptlr2[i]);
      }
      (void)fclose(fp);
      (void)tpterm();
      (void)exit(1);
  }
  len2=sizeof(long);
  if (Fget32(pF32rec,NO, i, (char *)&ptlr2[i]->no, &len2) == -1) {
      (void)fprintf(stderr, "Failure to call get the NO field -- %s \n",
                  Fstrerror32(Ferror32));
      (void)userlog("Clientfml failed to get the NO field -- %s \n",
                  Fstrerror32(Ferror32));
      (void)tpfree((char *)pF32);
      (void)tpfree((char *)pF32rec);
      (void)free(str1);
      for(i=0;i<3;i++){
      (void)free(ptlr[i]);
      (void)free(ptlr2[i]);
      }
      (void)fclose(fp);
      (void)tpterm();
      (void)exit(1);
  }
    (void)fprintf(stdout,"%s %ld %s %ld\n",ptlr2[i]->name,ptlr2[i]->age,
        ptlr2[i]->phone,ptlr2[i]->no);

  }
  


  (void)tpfree((char *)pF32);
  (void)tpfree((char *)pF32rec);
  (void)free(str1);
  for(i=0;i<3;i++){
  (void)free(ptlr[i]);
  (void)free(ptlr2[i]);
  }
  (void)fclose(fp);


  (void)tpterm();
  return(0);
}
编译客户端程序:
$buildclient -o clientfml -f clientfml.c
步骤五:
编写服务器端程序:
程序代码:
#include <stdio.h>
#include "fml32.h"
#include "atmi.h"
#include "userlog.h"
#include "fmlfile.h"

void FMLTEST(TPSVCINFO *msg)
{
struct emp {
char name[10];
long no;
};

  struct emp aa[3]={
  {"hwt",33},
  {"csq",21},
  {"lht",42}
  };
  struct emp bb[3];
  FBFR32 *fP32;
  FLDLEN32 len2;
  float inputnum, result;
  int counter, numofocc,i,j;

  fP32 = (FBFR32 *)msg->data;


  if ((numofocc = Foccur32(fP32,NAME)) == -1) {
    (void)userlog("FMLserver failed to the number of NAME occurrences -- %s\n", Fstrerror32(Ferror32));
    tpreturn(TPFAIL, 0, (char *)fP32, 0L, 0);
  }

  if (numofocc == 0) {
    (void)userlog("FMLserver received 0 NAME occurrences -- %s\n",
        Fstrerror32(Ferror32));
    tpreturn(TPFAIL, 0, (char *)fP32, 0L, 0);
  }

  for (counter = 0; counter < numofocc; counter++) {
     len2 = sizeof(float);
     if (Fget32(fP32,NAME, counter, (char *)bb[counter].name, &len2) == -1) {
        (void)userlog("FMLserver failed to get NAME occ %d field -- %s\n",
          counter, Fstrerror32(Ferror32));
        tpreturn(TPFAIL, 0, (char *)fP32, 0L, 0);
     }
 
   }
  for(i=0;i<3;i++)
    for(j=0;j<3;j++)
    {
    if(strcmp(bb[i].name,aa[j].name)==0){
          if (Fchg32(fP32,NO,i, (char *)&aa[j].no, (FLDLEN32)0) == -1) {
             (void)userlog("FMLserver failed to add NO field -- %s\n",
          Fstrerror32(Ferror32));
             tpreturn(TPFAIL, 0, (char *)fP32, 0L, 0);
            }
      }
    }

  tpreturn(TPSUCCESS, 0, (char *)fP32, 0L, 0);

}

编译服务器端程序:
$buildserver -o serverfml -f serverfml.c -s FMLTEST
步骤六:
启动服务:
[hwt@localhost fml]$ tmboot -y
Booting all admin and server processes in /home/hwt/fml/tuxconfig
INFO: BEA Tuxedo, Version 9.1, 32-bit, Patch Level (none)
INFO: Serial #: 454493271161-2664953090480, Expiration NONE, Maxusers 1000000
INFO: Licensed to: Customer

Booting admin processes ...

exec BBL -A :
        process id=9898 ... Started.

Booting server processes ...

exec serverfml -A :
        process id=9899 ... Started.
2 processes started.
检查一下:
[hwt@localhost fml]$ tmadmin
tmadmin - Copyright (c) 1996-1999 BEA Systems, Inc.
Portions * Copyright 1986-1997 RSA Data Security, Inc.
All Rights Reserved.
Distributed under license by BEA Systems, Inc.
Tuxedo is a registered trademark.

> psc
Service Name Routine Name Prog Name  Grp Name  ID    Machine  # Done Status
------------ ------------ ---------  --------  --    -------  ------ ------
FMLTEST      FMLTEST      serverfml  MATHG+     1      SITE1       0 AVAIL

> psr
Prog Name      Queue Name  Grp Name      ID RqDone Load Done Current Service
---------      ----------  --------      -- ------ --------- ---------------
BBL            155442      SITE1          0      0         0 (  IDLE )
serverfml      00001.00001 MATHGRP        1      0         0 (  IDLE )

步骤七:
执行客户端程序:
[hwt@localhost fml]$ ./clientfml tlr.txt
hwt 29 18677150924 33
lht 28 13398813422 42
csq 25 13234234564 21

小结:
本人本来C语言就不是很好,写这程序花了快2天,总结以下问题:
1.指针使用前要提前分配空间(malloc)
2.FML格式文件字段要大写
3.如果读取的是"|"分隔的文件,sscanf中应该用"%[^|]|%ld|%s"这样的格式

程序已经调试通过了,主要是练习FML的用法,希望能对大家学习有帮助。

[ 本帖最后由 khaz 于 2011-4-24 15:47 编辑 ]
搜索更多相关主题的帖子: 服务器 缓冲区 客户端 
2011-04-24 15:36
zhu224039
Rank: 8Rank: 8
等 级:贵宾
威 望:17
帖 子:862
专家分:792
注 册:2012-7-29
收藏
得分:0 
木有看懂

我要成为嘿嘿的黑客,替天行道
2012-10-11 21:54
tsyalvin
Rank: 1
等 级:新手上路
帖 子:9
专家分:0
注 册:2013-9-13
收藏
得分:0 
这是天书吗
2013-09-13 16:43
格瓦拉lxl
Rank: 1
等 级:新手上路
帖 子:1
专家分:0
注 册:2014-3-28
收藏
得分:0 
好!帮了我的大忙了,非常感谢!
2014-03-28 11:21
快速回复:学习了FML后,自己练手写了一个tuxedo FML32服务器端和客户端程序,供 ...
数据加载中...
 
   



关于我们 | 广告合作 | 编程中国 | 清除Cookies | TOP | 手机版

编程中国 版权所有,并保留所有权利。
Powered by Discuz, Processed in 0.019653 second(s), 9 queries.
Copyright©2004-2024, BCCN.NET, All Rights Reserved