WebServiceInaurora
Web Service是一种面向服务的架构的技术，通过标准的Web协议提供服务，目的是保证不同平台的应用服务可以互操作。在aurora框架中可以方便的提供Web Service服务及调用由他人发布的Web Service。
在aurora中发布Web Service
Web Service是一种面向服务的架构的技术，通过标准的Web协议提供服务，目的是保证不同平台的应用服务可以互操作。在aurora框架中可以方便的提供Web Service服务及调用由他人发布的Web Service。
1. 从
Aurora-framework上下载最新的aurora.jar
2. 添加web service监听器。打开
WEB-HOME\WEB-INF\aurora.feature\service-listener.config,在 <participant-list category="service"> 节点下，添加 <participant class="aurora.service.ws.soAPServiceInterpreter"/> 子节点。
3. 取消此svc的登录校验。在系统注册svc文件时，设置不需要登录的权限。对于webservice作为一个独立部署的工程，可以取消service-procedure.config配置文件，这样所有的文件都不需要登录校验。
4. 撰写svc文件，提供给他人调用即可。
我们提供一个svc，此svc把请求的数据插入到一个数据库表中。
1. create table account_test(ACCOUNT_ID number,ACCOUNT_OTHER_CODE varchar2(100)); 新建一个对应的结果表
2. 建立一个此表的bm：
<?xml version="1.0" encoding="UTF-8"?> <!-- $Author: linjinxiao $Date: 2011-11-9 上午10:42:34 $Revision: 1.0 $Purpose: --> <bm:model xmlns:bm="http://www.aurora-framework.org/schema/bm" alias="t1" baseTable="ACCOUNT_TEST"> <bm:fields> <bm:field name="ACCOUNT_ID" databaseType="NUMBER" datatype="java.lang.Long" physicalName=prompt="ACOUNT_TEST.ACCOUNT_ID"/> "ACCOUNT_OTHER_CODE" "VARCHAR2" "java.lang.String" "ACOUNT_TEST.ACCOUNT_OTHER_CODE"/> </bm:fields> </bm:model>
<?xml version="1.0" encoding="UTF-8"?> <a:service xmlns:a="http://www.aurora-framework.org/application"> <a:init-procedure> <a:model-insert model="fnd.account_test"</a:init-procedure> <a:service-output output="/parameter"/> </a:service>
public class LowLevelClient { static void main(String[] args) throws AxisFault { ServiceClient client = new ServiceClient(); Options options = new Options(); options.setTo(new EndpointReference( "http://127.0.0.1:8080/newhec/modules/sys/ws_test.svc"));//修正为实际工程的URL client.setoptions(options); OMElement request = makeRequest(); OMElement response = client.sendReceive(request); System.out.println("ok:"+response.toString()); } private static OMElement makeRequest() { OMFactory factory = OMAbstractFactory.getoMFactory(); OMElement request = factory.createOMElement(new QName( "","parameter")); request.addAttribute("ACCOUNT_ID","123",null); request.addAttribute("ACCOUNT_OTHER_CODE","test",null); return request; }
5. 查看插入数据库记录是否成功和控制台的结果是否正确。
这个例子处理有头行结构的例子。譬如，调用方发送过来的请求是如下格式
<requestHead seqNo="1"<requestBody> <records> <record ACCOUNT_ID="22" ACCOUNT_OTHER_CODE="test"/> "33" "test2"</records> </requestBody>
返回的结构要求是如下格式
<responseHead xmlns="http://aurora.org" /> <requestBody responsedate="3008900"<records> "test" REQUEST_RESULT="successful" /> "test2" /> </records> </requestBody>
1. 我们创建一个pkg：
create or replace package ACCOUNT_TEST_PKG is procedure insert_account_test(p_account_id number,p_account_other_code varchar2,p_request_result out varchar2); end ACCOUNT_TEST_PKG; replace package body "ACCOUNT_TEST_PKG" out varchar2) begin insert into account_test (account_id,account_other_code) values (p_account_id,p_account_other_code); p_request_result := 'successful'; end; end ACCOUNT_TEST_PKG; /
2. 在bm中调用此pkg：
<bm:operations> <bm:operation "insert"> <bm:update-sql><![CDATA[ begin ACCOUNT_TEST_PKG.insert_account_test ( p_account_id => ${@ACCOUNT_ID},p_account_other_code => ${@ACCOUNT_OTHER_CODE},p_request_result => ${@REQUEST_RESULT} ); end; </bm:update-sql> <bm:parameters> <bm:parameter name="ACCOUNT_ID"/> <bm:parameter name="ACCOUNT_OTHER_CODE"/> <bm:parameter name="REQUEST_RESULT" output="true" outputPath="@REQUEST_RESULT"/> </bm:parameters> </bm:operation> </bm:operations>
3. 撰写svc如下：
"http://www.aurora-framework.org/application" xmlns:p="uncertain.proc"<p:echo/> <!-- 对数据进行循环操作--> <batch-apply sourcepath="/parameter/requestBody/records"> /> </batch-apply> <!--更改节点的名称和namespace--> <p:set-element target="/parameter/requestHead" "responseHead" namespace="http://aurora.org" /> <!-- 获得当前的时间--> <a:model-query fetchAll="true" fethOneRecord="ccic.systest" rootPath="/parameter/requestBody"/> "/parameter/"</a:service>
static OMElement makeRequest2() {
OMFactory factory = OMAbstractFactory.getoMFactory();
OMElement request = factory.createOMElement(new QName("soap:Body"));
OMElement requestHead = factory.createOMElement(new QName("requestHead"));
requestHead.addAttribute("seqNo","1",null);
OMElement requestBody = factory.createOMElement(new QName("requestBody "));
OMElement records = factory.createOMElement(new QName("records "));
OMElement record = factory.createOMElement(new QName("record "));
record.addAttribute("ACCOUNT_ID","11",null);
record.addAttribute("ACCOUNT_OTHER_CODE",null);
records.addChild(record);
requestBody.addChild(records);
request.addChild(requestHead);
request.addChild(requestBody);
return request;
}
假设服务端要求提交的格式如下：
<axis2ns1:cancat xmlns:axis2ns1="http://www.aurora.org/simple/"<s1>abc</s1> <s2>def</s2> </axis2ns1:cancat>
返回的格式如下：
<ns1:syncAccResponse xmlns:ns1=\http://service.test.com\> <ns1:out> <ns2:Account xmlns:ns2=//dto.test.com\> <ACCOUNT_ID //dto.test.com\>1681</ACCOUNT_ID> <ACCOUNT_OTHER_CODE //dto.test.com\></ACCOUNT_OTHER_CODE> </ns2:Account> //dto.test.com\>1682</ns2:Account> </ns1:out> </ns1:syncAccResponse>
1. 模拟第三方发布服务，以axis2为例
1. 下载
axis2
2. 把
simpleWebService部署到
AXIS2_HOME/repository/services下，然后启动服务
2. 编写客户端代码
1. 编写systest.bm文件
"http://www.aurora-framework.org/schema/bm""query"<bm:query-sql><![CDATA[select '3008900' exp_report_number,'222222222' employee_code,'测试' name,'MAS' unit_code,'[email protected]' email,'0' type from dual </bm:query-sql> </bm:operation> </bm:operations> </bm:model>
2. 编写svc文件
"http://www.aurora-framework.org/application" "uncertain.proc" xmlns:rs="aurora.database.rsconsumer" > <a:init-procedure> <!-- 构建符合的请求的格式--> prefix="ns1" nameSpace="http://www.aurora.org/simple" localName="cancat" "sys.systest" "/model/result1"/> "s1" attribAsCdata=attribAsCdataList="unit_code""/model/result1/cancat""s2" "employee_code" /> <!-- 请求WebService--> <a:ws-invoker raiseExceptionOnError="false" url="http://localhost:8080/axis2/services/simple" inputPath="/model/result1/cancat" returnPath="/model/syncAccResponse"<!--把子节点中cdata的内容整合成父节点中的一个属性 --> <p:method-invoke className="uncertain.composite.CompositeUtil" methodName="collapse"<p:arguments> <p:argument path="/model/syncAccResponse/out" type="uncertain.composite.CompositeMap"/> </p:arguments> </p:method-invoke> <as:SetParameterParsed /> <!--循环处理子节点 --> "/model/syncAccResponse/out"> /> </batch-apply> </a:init-procedure> />
最基本的四个功能:model-query,model-insert,model-update,model-delete
把单条记录查询结果返回的属性直接更新到指定的节点上: fetchOneRecord="true" 。例子：
fetchOneRecord=/>
如果不加此属性，返回的结果是
<model> <result1> <concat> employee_cod=</concat> </result1> </model>
加了此属性后，返回结果就是：
<concat /> </model>
注意：此属性仅对返回单条记录有效。
批量循环处理：batch-apply 。例子：
> /> </batch-apply>
表示对/model/syncAccResponse/out下面的所有子节点执行model-insert操作。
更改查询返回的数据格式。例子：
"s2" "true" "ns1" </a:model-query>
如果不加localName="s2"...nameSpace="http://www.aurora.org/simple" 那段，那么原本的返回结果可能是
</model>
经过处理后，就变成
<ns1:s2 "http://www.aurora.org/simple">test</ns1:s2> </model>
>
<p:arguments>
/>
</p:arguments>
</p:method-invoke>
原先的数据格式可能是这样的：
<syncAccResponse>
<out>
<s1>yes</s1>
<s2>test</s2>
</out>
</syncAccResponse1>
</model>
处理后的格式就是这样的
<out s1="yes" s2=</model>
复制元素属性，例子
"copyAttributes" > <p:arguments> "/model/result4" "java.util.Map""/parameter" </p:method-invoke>
原先的格式可能是这样的
<result4 </model> <parameter s3="aurora" />
执行后就变成这个效果
/>
更改元素名称、namespace和前缀：set-element。
例子
"ok" "right" childLevel="0"/>
原先的格式可能是这样的：
</model>
执行后变成：
<right:ok xmlns:right=</right:ok> </model>
其中childLevel表示子节点的层次，如果是0，代表本节点，如果是1，表示下一级子节点。假设把上面的childLevel改成1，然后结果会变成：
>yes</right:o> </right:o> </model>
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
