Java Web 服务，第 2 部分: 深度探索 Axis2：AXIOM

核心提示： AXIOM 通过 org.apache.AXIOM.om.OMText 接口以及该接口的实现来支持 XOP/MTOM，OMText 定义了相应的方法以支持代表二进制数据的文本项目（以 javax.activation.DataHandler 的形式表示，Java Web 服务，第 2 部分: 深

AXIOM 通过 org.apache.AXIOM.om.OMText 接口以及该接口的实现来支持 XOP/MTOM。OMText 定义了相应的方法以支持代表二进制数据的文本项目（以 javax.activation.DataHandler 的形式表示，这是 Java Web 服务框架中用于附件支持的广泛使用的 Java Activation API 的一部分），以及一个“优化”标志用来表示是否可以使用 XOP 对该项目进行处理。org.apache.AXIOM.om.impl.llom.OMTextImpl 实现添加了一个与 MTOM 兼容的内容 ID，在创建或自动生成类的实例时，如果尚未设置，可以对其进行相应的设置。

清单 6 通过一个示例介绍了如何在 AXIOM 中使用 XOP/MTOM 来构建消息。这段代码取自一个性能测试示例，该示例使用 Java 序列化将结果数据结构转换为一个字节数组，然后返回这个数组作为附件。

清单 6. 创建 XOP/MTOM 消息
　　public　OMElement　matchQuakes(OMElement　req)　{　
　　　　Query　query　=　new　Query();　
　　　　Iterator　iter　=　req.getChildElements();　
　　　　try　{　
　　　　　　...　
　　　　　　//　retrieve　the　matching　quakes　
　　　　　　Response　response　=　QuakeBase.getInstance().handleQuery(query);　
　　　　　　　
　　　　　　//　serialize　response　to　byte　array　
　　　　　　ByteArrayOutputStream　bos　=　new　ByteArrayOutputStream();　
　　　　　　ObjectOutputStream　oos　=　new　ObjectOutputStream(bos);　
　　　　　　oos.writeObject(response);　
　　　　　　byte[]byts　=　bos.toByteArray();　
　　　　　　　
　　　　　　//　generate　response　structure　with　reference　to　data　
　　　　　　ByteArrayDataSource　ds　=　new　ByteArrayDataSource(byts);　
　　　　　　OMFactory　fac　=　OMAbstractFactory.getOMFactory();　
　　　　　　OMNamespace　ns　=　
　　　　　　　　fac.createOMNamespace("http://seismic.sosnoski.com/types",　"qk");　
　　　　　　OMElement　resp　=　fac.createOMElement("response",　ns);　
　　　　　　OMText　data　=　fac.createOMText(new　DataHandler(ds),　true);　
　　　　　　resp.addChild(data);　
　　　　　　return　resp;　
　　　　　　　
　　　　}　catch　(ParseException　e)　{　
　　　　　　e.printStackTrace();　
　　　　}　catch　(IOException　e)　{　
　　　　　　e.printStackTrace();　
　　　　}　
　　　　return　null;　
　　}