新书推介:《语义网技术体系》
作者:瞿裕忠,胡伟,程龚
   XML论坛     W3CHINA.ORG讨论区     计算机科学论坛     SOAChina论坛     Blog     开放翻译计划     新浪微博  
 
  • 首页
  • 登录
  • 注册
  • 软件下载
  • 资料下载
  • 核心成员
  • 帮助
  •   Add to Google

    >> 本版讨论DOM, SAX, XPath等。
    [返回] 中文XML论坛 - 专业的XML技术讨论区XML.ORG.CN讨论区 - XML技术『 DOM/SAX/XPath 』 → Tuxedo 8.1 XML C++ Parser的使用[转帖] 查看新帖用户列表

      发表一个新主题  发表一个新投票  回复主题  (订阅本版) 您是本帖的第 3568 个阅读者浏览上一篇主题  刷新本主题   树形显示贴子 浏览下一篇主题
     * 贴子主题: Tuxedo 8.1 XML C++ Parser的使用[转帖] 举报  打印  推荐  IE收藏夹 
       本主题类别:     
     zhu_ruixian 帅哥哟,离线,有人找我吗?射手座1983-12-2
      
      
      威望:2
      等级:大二期末(Java考了96分!)
      文章:406
      积分:3471
      门派:W3CHINA.ORG
      注册:2006/3/30

    姓名:(无权查看)
    城市:(无权查看)
    院校:(无权查看)
    给zhu_ruixian发送一个短消息 把zhu_ruixian加入好友 查看zhu_ruixian的个人资料 搜索zhu_ruixian在『 DOM/SAX/XPath 』的所有贴子 引用回复这个贴子 回复这个贴子 查看zhu_ruixian的博客楼主
    发贴心情 Tuxedo 8.1 XML C++ Parser的使用[转帖]

    在TUXEDO 8.0中,客户机和服务器之间可以使用XML缓冲区进行数据交换,但由于8.0版本没有集成XML Parser,所以对XML的支持是有限的。从8.1版本开始,TUXEDO集成了Apache Xerces C++ Parser 1.7,这样服务器端就可以直接分析XML文档了,而不用再去调用其它XML Parser。
    TUXEDO 8.1的samples中给了一个xmlstockapp例子,由于它太复杂(至少我这么认为),因此,本文将通过一个简单实用的例子来介绍XML缓冲区使用。

    一.XML缓冲区的分配和传输
    XML缓冲区支持的最大长度是4GB,分配方法与CARRAY缓冲区一样,需要指定长度。客户端需要打开一个XML文档,以字符方式读取文档内容,保存到缓冲区中,然后由tpcall()调用提交给服务进程。清单1-1是通信录应用程序的XML客户机代码段。

    清单1-1 XML缓冲区客户机代码段,文件名:XML_cli.c
    #define XMLDOCSIZE 1048576
    ... ...
    FILE *xml_fd;
    char *xml_buffer = NULL;
    if ((xml_fd = fopen("friends.xml", "r")) != NULL) {
    xml_buffer = (char *)malloc(sizeof(char) * XMLDOCSIZE);
    nsize = fread(xml_buffer, sizeof(char), XMLDOCSIZE, xml_fd);
    }
    sendlen = nsize + 1; /* 实际读取的长度 */
    if((sendbuf = (char *) tpalloc((char *)"XML", NULL, sendlen)) == NULL) {
    fprintf(stderr,"Error allocating send buffer, tperrno=%ld\n",tperrno);
    tpterm();
    return(1);
    }
    strncpy(sendbuf, xml_buffer, nsize);
    ret = tpcall((char *)"ADD_FRIEND", (char *)sendbuf, sendlen, (char **)&rcvbuf, &rcvlen, TPNOTIME);
    ... ...

    复制到缓冲区的XML文件必须遵循1.0标准,可以包含任何自定义的标记。本例中用到了friends.xml,这个文件包含了两条要添加到数据库好友信息,内容如清单1-2所示。

    清单1-2 XML文件示例,文件名:friends.xml
    <?xml version='1.0' encoding='UTF-8'?>
    <friends>
    <friend>
    <friend_id>1</friend_id>
    <fname>JQ</fname>
    <fmobile>13910793488</fmobile>
    </friend>
    <friend>
    <friend_id>2</friend_id>
    <fname>Snna</fname>
    <fmobile>13663129935</fmobile>
    </friend>
    </friends>

    二.基于XML标记的DDR
    XML缓冲区支持基于标记值的DDR,对于通信录应用程序来说,如果我们要把friend_id取值在1-10范围内的记录保存在table1中,把取值在11-20范围内的记录保存在table2中,把其它取值范围的记录保存在table3中,则可以在ubb配置文件中定义下面的路由标准来实现:

    *ROUTING
    symbol FIELD="friends/friend/ friend_id"
    BUFTYPE="XML"
    FIELDTYPE=LONG
    RANGES="1-10:GROUP1,11-20:GROUP2,*:GROUP3"

    XML缓冲区的路由字段还可以是STRING类型的,这时RANGES的取值必须用单引号引起来,请看如下代码段:

    *ROUTING
    symbol FIELD="stockquotes/stock_quote/symbol"
    BUFTYPE="XML"
    FIELDTYPE=STRING
    RANGES="'BEAS'-'BEAS':GROUP1, 'MSFT'-'MSFT':GROUP2"

    三.XML缓冲区的分析
    服务器端收到XML缓冲区后,需要对它进行分析,从中取出标记值。Tuxedo 8.1集成了Apache Xerces C++ Parser 1.7,并提供了两种类型的分析器:SAX Parser和DOM Parser,服务器端通常使用DOM Parser,客户端通常使用SAX Parser。使用Xerces C++ Parser的步骤一般是:
    · 初始化XMLC42系统;
     XMLPlatformUtils::Initialize();
    · 根据XML缓冲区创建MemBufferInputSource;
     MemBufInputSource* memBufIS =
     new MemBufInputSource( (const XMLByte*)xmlbuf, strlen(xmlbuf), bufId, false);
    · 创建SAX Parser或DOM Parser;
     DOMParser *parser = new DOMParser;
     SAXPArser *parser = new SAXParser;
    · 对于SAX Parser,需要为文档和错误处理设置回调函数;
     SAXPrintHandlers handler;
     parser->setDocumentHandler(&handler);
     parser->setErrorHandler(&handler);
    · 调用Xerces C++ Parser分析XML缓冲区;
     parse->parse(*memBufIS);
    · 删除Parser和MemBufferInputSource;
     delete parser;
     delete memBufIS;
    · 退出XMLC42系统;
     XMLPlatformUtils::Terminate();
    对于通信录应用程序来说,客户机给服务器传递了friends.xml文件,服务器端创建了一个DOM Parser对它进行分析,并把结果存入数据库,代码如清单1-3所示。

    清单1-3 XML缓冲区的服务器代码,文件名:XML_serv.pc
    #include <xercesc/parsers/DOMParser.hpp>
    #include <xercesc/util/PlatformUtils.hpp>
    #include <xercesc/framework/MemBufInputSource.hpp>
    #include <atmi.h>
    #include <userlog.h>
    #include <stdlib.h>
    #include <string.h>

    char *localbuf=NULL;
    static const char* bufId = "mybuf";

    EXEC SQL begin declare section;
    static long friend_id;
    static char fname[10];
    static char fmobile[14];
    EXEC SQL end declare section;

    EXEC SQL INCLUDE sqlca;

    void TopTree( DOM_Node node);
    void SubTree( DOM_Node node);
    void parseXMLBuffer(char** xmlbuf);


    #ifdef __cplusplus
    extern "C"
    #endif
    void
    #if defined(__STDC__) || defined(__cplusplus)
    ADD_FRIEND(TPSVCINFO *rqst)
    #else
    ADD_FRIEND(rqst)
    TPSVCINFO *rqst;
    #endif
    {
    parseXMLBuffer(&rqstàdata);
    tpreturn(TPSUCCESS, 0, xmlbuf, rqstàlen, 0);
    }
    void parseXMLBuffer(char** xmlbuf)
    {
    int errorCount ;
    localbuf = (char *)malloc(sizeof(char *) * 2048);
    XMLPlatformUtils::Initialize();

    MemBufInputSource* memBufIS =
    new MemBufInputSource( (const XMLByte*)*xmlbuf, strlen(*xmlbuf)-1, bufId, true);

    DOMParser *parser = new DOMParser;
    parseràparse(*memBufIS);
    if ((errorCount = parseràgetErrorCount()) == 0)
    {
    DOM_Document document = parseràgetDocument();
    DOM_Element topLevel = document.getDocumentElement();
    TopTree(topLevel);
    }
    delete parser;
    delete memBufIS;
    XMLPlatformUtils::Terminate();
    }
    void TopTree( DOM_Node node){
    if (node.getNodeType() == DOM_Node::ELEMENT_NODE)
    {
    if (node.getNodeName().equals ("friend")) SubTree(node);
    else
    {
    DOM_NodeList children = node.getChildNodes();
    for (int i=0; i<children.getLength(); i++) TopTree(children.item(i));
    }
    }
    }
    void SubTree( DOM_Node node){
    DOM_NodeList children = node.getChildNodes();
    for (int i=0; i<children.getLength(); i++)
    {
    DOM_Node nod = children.item(i);
    if(nod.getNodeType()==DOM_Node::ELEMENT_NODE)
    {
    if(nod.getNodeName().equals("friend_id"))
    friend_id = atol(nod.getFirstChild().getNodeValue().transcode());
    else if(nod.getNodeName().equals("fname"))
    strcpy(fname, nod.getFirstChild().getNodeValue().transcode());
    else if(nod.getNodeName().equals("fmobile"))
    strcpy(fmobile, nod.getFirstChild().getNodeValue().transcode());
    }
    }
    EXEC SQL insert into FRIEND (FRIEND_ID,NAME,MOBILE)
    values (:friend_id, :fname, :fmobile);

    if (SQLCODE != SQL_OK) userlog("Cannot insert into FRIEND");
    }

    注意:服务器文件名为XML_serv.pc,先要使用esqlc命令对它作预编译,生成C源程序,然后把扩展名改为cpp,才能用buildserver来编译,原因是Xerces C++ Parser只提供了C++的编程接口。读者可以参考如下命令来编译:
    proc iname=XML_serv.pc oname=XML_serv.cpp
    buildserver -v -s ADD_FRIEND -f XML_serv.cpp -o XML_serv -f %TUXDIR%\lib\libtxml.lib

    四.UBBConfigNT配置文件的编写
    这个例子使用了Oracle8i数据库来测试,Tuxedo的配置文件如清单1-4所示。

    清单1-4 Tuxedo的配置文件,文件名:UBBConfigNT
    *RESOURCES
    IPCKEY 123456
    DOMAINID simpapp
    MASTER SITE1
    MAXACCESSERS 10
    MAXSERVERS 5
    MAXSERVICES 10
    MODEL SHM
    LDBAL N

    *MACHINES
    DEFAULT:
    APPDIR="C:\TuxDAP\solutions\xml"
    TUXCONFIG="C:\TuxDAP\solutions\xml\tuxconfig"
    TUXDIR="G:\bea\tuxedo"
    TLOGNAME=TLOG
    TLOGDEVICE="C:\TuxDAP\solutions\xml\TLOG"

    JQ LMID=SITE1

    *GROUPS
    DEFAULT: LMID=SITE1

    GROUP1 LMID=simple GRPNO=1
    OPENINFO="Oracle_XA:Oracle_XA+Acc=P/scott/tiger+SqlNet=oradb+SesTm=120+
    MaxCur=5+LogDir=."
    TMSNAME="TMS_ORA8i" TMSCOUNT=2

    *SERVERS
    DEFAULT: RESTART=Y MAXGEN=5 REPLYQ=Y CLOPT="-A"
    XML_serv SRVGRP=GROUP1 SRVID=10

    *SERVICES
    ADD_FRIEND

    *ROUTING

    五.运行测试
    执行XML_Cli.exe进行测试,friends.xml文件已经通过XML缓冲区成功地发送到服务器端;
    打开SQL*PLUS,查看一下FRIEND表的内容,发现里面已经插入了两条记录,这两条记录的数据就是通过friends.xml文件来传输的!
    按此在新窗口浏览图片

    原文出处:http://dev2dev.bea.com.cn/techdoc/200312106.html


       收藏   分享  
    顶(0)
      




    ----------------------------------------------
    为什么总是索取的人多,奉献的人少...

    点击查看用户来源及管理<br>发贴IP:*.*.*.* 2006/12/15 13:14:00
     
     GoogleAdSense射手座1983-12-2
      
      
      等级:大一新生
      文章:1
      积分:50
      门派:无门无派
      院校:未填写
      注册:2007-01-01
    给Google AdSense发送一个短消息 把Google AdSense加入好友 查看Google AdSense的个人资料 搜索Google AdSense在『 DOM/SAX/XPath 』的所有贴子 访问Google AdSense的主页 引用回复这个贴子 回复这个贴子 查看Google AdSense的博客广告
    2024/5/15 18:37:22

    本主题贴数1,分页: [1]

    管理选项修改tag | 锁定 | 解锁 | 提升 | 删除 | 移动 | 固顶 | 总固顶 | 奖励 | 惩罚 | 发布公告
    W3C Contributing Supporter! W 3 C h i n a ( since 2003 ) 旗 下 站 点
    苏ICP备05006046号《全国人大常委会关于维护互联网安全的决定》《计算机信息网络国际联网安全保护管理办法》
    54.688ms