扫一扫
分享文章到微信
扫一扫
关注官方公众号
至顶头条
作者:佚名 来源:论坛整理 2007年11月17日
关键字:
要开始创建客户机,请确保 Axis2 lib 目录中的所有 *.jar 文件——指 Standard 分发版,而不是 War 分发版——都在您的 CLASSPATH 上,并创建名为 ClassifiedClient 的新类。创建有效负载,如清单 17 中所示。
17. 有效负载
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.client.ServiceClient;
import org.apache.axis2.om.OMElement;
import javax.xml.stream.XMLOutputFactory;
import javax.xml.stream.XMLStreamException;
import java.io.StringWriter;
import org.apache.axis2.om.OMAbstractFactory;
import org.apache.axis2.SOAP.SOAPFactory;
import org.apache.axis2.om.OMFactory;
import org.apache.axis2.om.OMNamespace;
public class ClassifiedClient {
public static OMElement getEchoOMElement() {
SOAPFactory fac = OMAbstractFactory.getSOAP12Factory();
OMNamespace omNs = fac.createOMNamespace(
"http://daily-moon.com/cms", "cms");
OMElement method = fac.createOMElement("echo", omNs);
OMElement value = fac.createOMElement("category", omNs);
value.addChild(fac.createText(value, "classifieds"));
method.addChild(value);
return method;
}
public static void main(String[] args) {
try {
OMElement payload = ClassifiedClient.getEchoOMElement();
} catch (Exception e) { //(XMLStreamException e) {
System.out.println(e.toString());
}
}
}
首先,创建工厂和命名空间,并使用其创建各个元素。在本例中,您将创建与前面示例完全相同的元素,因为将再次使用此客户机访问 echo 函数。(稍后将对其进行更改,以访问真正的服务。)
接下来,将创建请求。
创建请求
下一步将创建实际的请求。同样,这方面也体现出技术随时间的发展。这里不会直接将请求发送到 URL,而要设置“端点引用”,如清单 18 中所示。
清单 18. 请求中的端点引用
...
public class ClassifiedClient {
private static EndpointReference targetEPR = new
EndpointReference(
"http://localhost:8080/axis2/services/MyService");
public static OMElement getEchoOMElement() {
...
}
public static void main(String[] args) {
try {
OMElement payload = ClassifiedClient.getEchoOMElement();
Options options = new Options();
options.setTo(targetEPR);
options.setTransportInProtocol(Constants.TRANSPORT_HTTP);
} catch (Exception e) { //(XMLStreamException e) {
System.out.println(e.toString());
}
}
}
对 WS-Addressing 的全面讨论不在本教程的范畴之内,但完全可以说端点引用包含消息将定向到的 URL,还可以有选择地包含其他信息,如应答地址和其他资源属性等。
首先,为请求创建 Options,以便为请求设置 EPR 和其他信息(如打算使用的传输协议)。完成了这些后,就可以实际发送请求了。
发送请求
完成了设置后,就可以发送请求了。对于 Axis 的 0.94 版,首选的方式是通过 ServiceClient 类发送消息,如清单 19 中所示。
清单 19. 发送请求
...
public static void main(String[] args) {
try {
OMElement payload = ClassifiedClient.getEchoOMElement();
Options options = new Options();
options.setTo(targetEPR);
options.setTransportInProtocol(Constants.TRANSPORT_HTTP);
ServiceClient sender = new ServiceClient();
sender.setOptions(options);
OMElement result = sender.sendReceive(payload);
} catch (Exception e) { //(XMLStreamException e) {
System.out.println(e.toString());
}
}
}
将创建 ServiceClient 对象,并为其设置前面创建的 Options。然后就可以直接发送消息了。由于希望得到响应,因此将使用 sendReceive() 方法(该方法用于 in/out 类型的消息)。将在本教程的单向服务部分讨论单向消息的信息。sendReceive() 方法将在客户机接收到实际响应时将其返回。
输出结果
实际上,sendReceive() 并不会返回整个响应,而仅返回有效负载。如果将结果输出到命令行,应该清楚地看到清单 20 中的内容。
清单 20. sendReceive 输出
...
sender.setOptions(options);
OMElement result = sender.sendReceive(payload);
System.out.println(result.toString());
} catch (Exception e) { //(XMLStreamException e) {
System.out.println(e.toString());
}
}
}
运行此客户机将获得清单 21 中所示的响应。
清单 21. sendReceive 响应
<cms:echo xmlns:cms="http://daily-moon.com/cms"><cms:category>classifieds</cms:category></cms:echo>
当然,接收到此数据后,可以使用其进行任何工作。接下来,我们将构建实际的 getNumberofArticles() 服务。
如果您非常迫切的想了解IT领域最新产品与技术信息,那么订阅至顶网技术邮件将是您的最佳途径之一。
现场直击|2021世界人工智能大会
直击5G创新地带,就在2021MWC上海
5G已至 转型当时——服务提供商如何把握转型的绝佳时机
寻找自己的Flag
华为开发者大会2020(Cloud)- 科技行者