【译】使用Java编写Oracle Tuxedo应用

时间 2019-11-10

标签使用 java 编写 oracle tuxedo 应用栏目 Java 繁體版

原文原文链接

来源：Programming an Oracle Tuxedo Application Using Javahtml

Oracle Tuxedo Java编程介绍

简介

Oracle Tuxedo服务可使用纯java来编写。使用java实现的服务的功能和其余Tuxedo服务实现是同样的。你可使用客户端或者Tuxedo服务器经过ATMI接口来调用Tuxedo Java Server（TMJSVASVR）对外提供的服务；你也在java实现的服务中经过TJATMI接口来调用Tuxedo server提供的服务。java

另外，你可使用任何类型的Tuxedo客户端调用java实现的服务，好比本地客户端，/WS客户端和Jolt客户端。web

可使用TJATMI接口、JATMI类型缓冲、POLO java对象等主流Java技术来实现Tuxedo服务。sql

编程方针

Java服务类，实现Java服务，须要继承TuxedoJavaServer类；Java服务类应该有一个默认的构造函数
Java服务类中的Java方法会被向外提供成Java服务，应该声明为public, 并将TPSVCINFO接口做为惟一的输入参数
Java服务类应该实现tpsvrinit()方法，在Tuxedo Java服务启动时会被调用
Java服务类应该实现tpsvrdone()方法，在Tuxedo Java服务关闭时会被调用
Java服务可使用Tuxedo Java ATMI接口（例如tpcall,tpbegin等）
Java服务可使用tpreturn向客户端返回结果，或者经过抛出异常退出

Tuxedo Java 服务器线程与Java类实例模型

Tuxedo Java服务使用传统的Tuxedo多线程模型，必须运行在多线程模式下
一旦启动，Tuxedo Java服务为每个定义在配置文件中的类建立一个全局对象（实例），处理Java服务时工做线程共享全局对象（实例）

Tudexo Java服务器 `tpsvrinit()/tpsvrdone()`处理

tpsvrinit()处理：
用户须要实现tpsvrinit()方法。因为该方法会在服务启动时调用，最好在该方法中完成类的初始化。若是一个类的tpsvrinit()方法失败，用户日志中会报告一条警告信息，Java服务会继续执行。数据库

tpsvrdone()处理：
用户须要实现tpsvrinit()方法。该方法在服务关闭时调用，推荐将类范围的清理工做放入这个方法中。编程

Tuxedo Java服务器`tpreturn()`处理

Java服务的tpreturn()并不会当即结束Java服务方法的执行，而是向Tuxedo Java服务器返回一个结果。数组

Java 服务的tpreturn()的行为与现有Tuxedo系统的tpreturn()行为不一样：服务器

当现有Tuxedo系统调用tpreturn()时，流控制自动转向Tuxedo
当Java服务调用tpreturn()时，tpreturn()以后的语句依旧会被执行。用户必须保证tpreturn()是Java服务中最后一条执行的语句。若是不是，建议在tpreturn()以后加上return；不然tpreturn()不会自动将流控制转向Tuxedo系统

注意：不建议在Java服务中前面没有tpreturn()时使用return。这种用法会使Java服务器返回rcode为0的TPFAIL到相关的客户端。多线程

Tuxedo Java服务器异常处理

Java服务执行期间能够抛出任何的异常而后退出Java服务。这种状况下Java服务器会返回TPFAIL到其客户端，其中rcode设置为0
全部的异常信息会记录在$APPDIR/stderr文件中。

编程环境

更新UBB配置文件

你须要配置一个路径，经过该路径Tuxdeo Java服务器能够找到CLOPT中Java实现的服务的配置文件。
因为ATMI Java服务器是一个多线程服务器，你还须要指名线程分配的限制。能够查看Defining the Server Dispatch Threads一章获取更多关于多线程服务配置的信息。oracle

清单2-1 显示了ATMI Java服务器的UBB配置文件示例：

清单2-1

conf*SERVERS
TMJAVASVR SRVGRP=TJSVRGRP SRVID=3
CLOPT="-- -c /home/oracle/app/javaserver/TJSconfig.xml"
MINDISPATCHTHREADS=2 MAXDISPATCHTHREADS=3

注意：UBBCONFIG中为Java服务器指明的MAXDISPATCHTHREADS最小值为2。

参见

Setting Up an Oracle Tuxedo Application
UBBCONFIG(5) in the File Formats, Data Descriptions, MIBs, and System Processes Reference

ATMI Java Server 用户接口

TuxedoJavaServer

TuxedoJavaServer是一个抽象类，全部用户定义的实现服务的类都应该继承它。

表3-1 TuxedoJavaServer接口

函数	描述
tpsvrinit	抽象方法，子类实现时作一些初始化的工做
tpsvrdone	抽象方法，子类实现时作一些清理工做
getTuxAppContext	用来取回当前链接的Tuxedo应用Java上下文

Oracle Tuxedo Java上下文

为了获取Oracle Tuxedo Java Server提供的TJATMI原始功能，你须要获取一个TuxAppContext对象，该对象实现了全部的TJATMI功能
由于服务类继承自TuxedoJavaServer，你能够在服务中调用getTuxAppContext()方法获取上下文对象。然而，你不能在tpsvrinit()中或其TuxAppContext，由于此时TuxAppContext没有准备好。若是你在tpsvrinit()中尝试获取TuxAppContext，tpsvrinit()会出错并抛出异常。

Tuxedo Java 应用中的TJATMI功能

TJATMI是原生功能的集合，提供客户端和服务器端的通讯功能，好比调用服务，开始和结束事务，获取到数据源的链接，日志等等。更多信息参考Java Server Javadoc.

表3-2 TJATMI功能

名字	操做
tpcall	用于在请求/应答通讯中同步调用Oracle Tuxedo服务
tpreturn	用于在Tuxedo Java Server中设置返回值
tpbegin	开始事务
tpcommit	提交当前事务
tpabort	终止当前事务
tpgetlev	检查事务是否正在执行
getConnection	获取到已配置的数据源的链接
userlog	在Tuxedo用户日志文件中打印日志

注意：在tpreturn结束执行后服务依旧在运行。推荐把tpreturn做为服务中最后执行的语句。

Tuxedo Java应用的类型缓冲

ATMI Java server 重用了Oracle WebLogic Tuxedo Connector TypedBuffers 做为相应的Oracle Tuxedo类型缓冲。消息经过类型缓冲传入 server 。ATMI Java server提供的类型缓冲见表3-3:

表3-3 类型缓冲

缓冲类型	描述
TypedString	数据是以null字符做为结束的字符数组时使用。Oracle Tuxedo 等价类型：STRING
TypedCArray	数据是未定义字符数组（字节数组），任一字节都有多是null。Oracle Tuxedo等价类型：CARRAY
TypedFML	数据自定义时使用。每一个数据域携带本身的标识，事件数，有可能有长度指示器。Oracle Tuxedo等价类型：FML
TypedFML32	相似于TypedFML可是容许更大的字符范围和域，更大的缓冲。Oracle Tuxedo等价类型：FML32
TypedXML	数据是基于XML的消息。Oracle Tuxedo等价类型：XML
TypedView	应用使用Java结构，使用视图描述文件来定义缓冲结构。Oracle Tuxedo等价类型：VIEW
TypedView32	相似于View，容许更大的字符范围、域、缓冲。Oracle Tuxedo等价类型：VIEW32

更多关于类型缓冲的信息，参见"weblogic.wtc.jatmi"

类型缓冲支持的限制

TypedFML32中Fldid()/Fname()嵌套在另外一个TypedFML32中时没法工做。为了应对这种状况，你可使用fieldtable类传输name/id。
目前weblogic.wtc.gwt.XmlViewCnv/XmlFmlCnv类没法使用。

获取/设置服务信息

使用TPSVCINFO类经过客户端获取/设置服务信息

表3-4 Getter函数

函数	描述
getServiceData	用来返回Oracle Tuxedo客户端发送过来的服务数据
getServiceFlags	用来返回客户端发送过来的服务标识
getServiceName	用来返回调用的服务名
getAppKey	获取程序认证客户端密钥
getClientID	获取客户端标识符

使用TuxATMIReply从服务请求中获取回应数据和元数据

表3-5 用于回应的Getter函数

函数	描述
getReplyBuffer	返回从服务返回的类型缓冲（多是null）
gettpurcode	返回从服务返回的`tpurcode`

异常

你须要捕获服务中JATMI原语抛出的异常，好比tpcall()。JATMI可能抛出两种类型的异常：

TuxATMITPException：该异常抛出代表TJATMI出错
TuxATMITPReplyException：若是服务出错（TPESVCFAIL或者TPSVCERROR）该异常抛出，用户数据关联到异常中。

跟踪

你还须要导出TMTRACE=atmi:ulog，正如你使用传统ATMI那样。TJATMI API跟踪信息被写入ULOG。

在Oracle Tuxedo Java Server 中实现服务

典型过程

定义一个继承自 TuxedoJavaServer的类
提供一个默认的构造函数
实现tpsvrinit()和tpsvrdone()方法
实现服务方法，该方法应该使用TPSVCINFO做为惟一的参数
- 使用getTuxAppContext()获取TuxAppContext对象
- 使用TPSVCINFO.getServiceData()从TPSVCINFO对象中获取客户端请求数据
- 若是配置了数据源，使用TuxAppContext.getConnection()方法获取到数据源的链接
- 完成商业逻辑，好比使用TuxAppContext.tpcall()调用其余服务，操纵数据库等
- 分配新的类型缓冲，把应答数据放入类型缓冲中
- 调用TuxAppContext.tpreturn()将应答数据返回客户端

实例：没有事务的Java服务实现

以下实例是实现TOUPPER服务的简单示例。

定义Java类

清单4-1

javaimport weblogic.wtc.jatmi.TypedBuffer;
import weblogic.wtc.jatmi.TypedString;
import com.oracle.tuxedo.tjatmi.*;
public class MyTuxedoJavaServer extends TuxedoJavaServer {
    public MyTuxedoJavaServer()
    {
        return;
    }

    public int tpsvrinit() throws TuxException
    {
        System.out.println("MyTuxedoJavaServer.tpsvrinit()");
        return 0;
    }

    public void tpsvrdone()
    {
        System.out.println("MyTuxedoJavaServer.tpsvrdone()");
        return;
    }

    public void JAVATOUPPER(TPSVCINFO rqst) throws TuxException {
        TypedBuffer svcData;
        TuxAppContext myAppCtxt = null;
        TuxATMIReply myTuxReply = null;
        TypedBuffer replyTb = null;

        /* Get TuxAppContext first */
        myAppCtxt = getTuxAppContext();

        svcData = rqst.getServiceData();
        TypedString TbString = (TypedString)svcData;
        myAppCtxt.userlog("Handling in JAVATOUPPER()");
        myAppCtxt.userlog("Received string is:" + TbString.toString());
        String newStr = TbString.toString();
        newStr = newStr.toUpperCase();
        TypedString replyTbString = new TypedString(newStr);
        /* Return new string to client */
        myAppCtxt.tpreturn(TPSUCCESS, 0, replyTbString, 0);
    }

    public void JAVATOUPPERFORWARD(TPSVCINFO rqst) throws TuxException {
        TypedBuffer svcData;
        TuxAppContext myAppCtxt = null;
        TuxATMIReply myTuxReply = null;
        TypedBuffer replyTb = null;
        long flags = TPSIGRSTRT;
        /* Get TuxAppContext first */
        myAppCtxt = getTuxAppContext();
        svcData = rqst.getServiceData();
        TypedString TbString = (TypedString)svcData;

        myAppCtxt.userlog("Handling in JAVATOUPPERFORWARD()");
        myAppCtxt.userlog("Received string is:" + TbString.toString());
        /* Call another service "TOUPPER" which may be implemented by another Tuxedo Server */
        try {
            myTuxReply = myAppCtxt.tpcall("TOUPPER", svcData, flags);
            /* If success, get reply buffer */
            replyTb = myTuxReply.getReplyBuffer();
            TypedString replyTbStr = (TypedString)replyTb;
            myAppCtxt.userlog("Replied string from TOUPPER:" + replyTbStr.toString());
            /* Return the replied buffer to client */
            myAppCtxt.tpreturn(TPSUCCESS, 0, replyTb, 0);
        } catch (TuxATMITPReplyException tre) {
            myAppCtxt.userlog("TuxATMITPReplyException:" + tre);
            myAppCtxt.tpreturn(TPFAIL, 0, null, 0);
        } catch (TuxATMITPException te) {
            myAppCtxt.userlog("TuxATMITPException:" + te);
            myAppCtxt.tpreturn(TPFAIL, 0, null, 0);
        }
    }
}

建立Java Server配置文件

清单4-2显示了配置示例，将MyTuxedoJavaServer.JAVATOUPPER()方法导出成Tuxedo 服务JAVATOUPPER，将MyTuxedoJavaServer.JAVATOUPPERFORWARD()方法导出成Tuxedo 服务JAVATOUPPERFORWARD。

清单4-2

xml<?xml version="1.0" encoding="UTF-8"?>
<TJSconfig>
    <TuxedoServerClasses>
        <TuxedoServerClass name="MyTuxedoJavaServer"> </TuxedoServerClass>
    </TuxedoServerClasses>
</TJSconfig>

更新UBB配置文件

清单4-3 UBB配置文件

config*GROUPS
TJSVRGRP LMID=simple GRPNO=2
*SERVERS
TMJAVASVR SRVGRP= TJSVRGRP SRVID=4 CLOPT="-- -c TJSconfig.xml"
MINDISPATCHTHREADS=2 MAXDISPATCHTHREADS=2

实例：带有事务的Java Service实现

清单4-4给出了一个示例，实现WRITEDB_SVCTRN_COMMIT服务，该服务将用户请求字符串插入表TUXJ_TRAN_TEST中。