如何实现webservice的异步调用

Posted 2023-05-10

参考技术A

对异步调用的理解：
说白了异步调用其实就是调用者线程和执行被调用过程的线程并行执行。
实现WEB服务方法异步调用有不同方法都可以实现，下面给你举三个例子：
第一种方法是：使用回调
使用这种方式来进行WEB服务方法的异步调用关键是在启动异步调用时传入一个代理实例作为调用结束时的回调方法。这样用以回调的方法调用结束异步调用的方法获得异步调用的结果。若调用方要跟异步调用同步，则需要在启动异步调用时传入一个同步对象[作为最后一个参数]，然后在回调方法中通过IAsyncResult的AsyncState成员获得该对象。
举一个例子：
假如有下面一个WEB服务方法
[webmethod]
public string GetName(string name)
return name;
/*****************客户端调用**************************
class Client

localhost1.Serivice service=new localhost1.Service();
public void GetResults(IAsyncResult ar)

MannualResetEvent ent;
ent=(MannualResetEvent)ar.AsyncState;
string ret=service.EndGetName(ar);
Console.WriteLine("the result is:"+ret);
ent.Set();

public void CallWithBack()

string name="kim";
AsyncCallBack callBack;
callBack=new AsyncCallBack(GetResults);
MannualResetEvent ent=MannualResetEvent(false);
service.BeginGetName(name,callBack,ent);
//做其他的事情
ent.WaitOne();

static void Main(string[] ars)

CallWithBack();


第二种方法使用轮询
轮询就是不断检查异步调用启动后获得的IasyncResult变量的IsCompleted属性，以等待异步调用结束。而一般在判断异步调用还未结束时，调用Thread类的静态方法Sleep(0)迫使当前线程由运行状态转入就绪状态。
如：
WEB服务方法还是以上面的例子为例：
客户端实现：
Class Client

localhost1.Serivice service=new localhost1.Service();
public void CallWithQuery()

string name="kim";
IasyncResult ar;
ar=service.BeginGetName(name,null,null);
while(!ar.IsCompleted)

//做其他事情
Console.WritleLine("Watting....");
Tread.Sleep(0);

string ret;
ret=service.EndGetName(ar);
Console.WriteLine("the result is:"+ret);

static void Main(string[] ars)

CallWithQuery();

第三种方法是：开始调用，结束调用
这种方式在启动异步调用后用结束异步调用的方式获取结果，如果异步调用没有结束，当前线成被阻塞。
如：
WEB服务方法还是以上面的例子为例：
客户端实现：
Class Client

localhost1.Serivice service=new localhost1.Service();
public void CallWithEnd()

string name="kim";
IasyncResult ar=service.BeginGetName(name,null,null);
string ret=service.EndGetName(ar);
Console.WriteLine("the result is:"+ret);

static void Main(string[] ars)

CallWithEnd();

forest调用webservice

用java实现web services必须遵循两个规范，他们分别是:

 JSR 101:用于基于XML的RPC ，Remote Procedure Call、 的Java API 、Java

API for XML based RPC， JAX-RPC，

 JSR 109:实现企业Web服务。Implementing Enterprise Web services。两个规范提供了厂商的实现的一致性和互操作性需求。

JAX-RPC——Java到XML和XML到Java映射API

JAX-RPC为基于XML的远程过程调用。Remote Procedure Call、 RPC，和Java应用程序编程接口 、Java Application Programming Interface。 API， 、

 WSDL到Java和Java到WSDL映射，例如、将WSDL端口类型映射到Java服

务端点接口 ，Java Service Endpoint Interface、 SEI。 。

 XML数据类型到Java数据类型和Java数据类型到XML数据类型映射。包括简

单类型、复杂类型和数组。

除了XML映射之外， JAX-RPC还定义了服务器端编程模型和API。 AX-RPC 1. 1根据Web 服务互操作性组织、Web Services Interoperability organization、 WS-I。基本概要版本1.0 、Basic Profile version 1.0，添加了互操作性需求。

JSR 109——J2EE环境的API

JSR 109指定了Java 2 Enterprise Edition ，J2EE、环境的Web服务编程模型和体系结构。 JSR 109构建在SOAP 1. 1和WSDL 1. 1的基础上、它涵盖了J2EE环境中JAX-RPC 的使用， 图2， 。它还定义了J2EE应用程序服务器中的部署模型。 JSR 109的客户端编程模型符合JAX-RPC。

JAX-RPC 1. 1和JSR 109是J2EE 1.4的组成部分。

1/7页
在这里我不准备描述用java如何实现服务端，仅描述如何用java作为客户端如何调用web services。

获取客户端服务

Java客户端有两种获取方式、一种是基于容器管理的、一种不是基于容器管理的。基于容器管理的、可以是不同类型的J2EE容器管理的客户机，

 应用程序客户机容器客户机

 Web容器客户机。 JavaBean或Servlet

 EJB容器客户机、 EJB

他们通过jndi查找服务。一般是两个步骤:

1，实例化本地JND I上下文。

2、在此上下文中对Web服务进行JND I查找。

Context ic = new InitialContext() ;

Service service = (Service) ctx. lookup("java:comp/env/service/HelloService") ;然后可以使用获得的服务接口 。Service Interface，来获取静态存根、动态代理或DII Call对象,来实现我下面描述的三种调用方式。

不是基于容器管理的、就是在本地通过java程序直接调用服务的，服务查找是通过JAX-RPC ServiceFactory进行的、 JAX-RPC ServiceFactory是创建服务访问点的工厂，可以如下进行使用获取服务。javax.xml.rpc.Service service =

ServiceFactory.newInstance() .createService(. . . ) ;

我在下面描述的客户端获取方式都是基于不是容器管理的。java调用webservices

用java作为客户端调用webservices主要有三种方式，下面描述三种调用方式。

1.DLL 、Dynamic Invocation Interface，调用

复杂度最高。灵活性最强的调用方式

通过自己创建Call对象完成调用，此方法的步骤如下，

2/7页
1. 获取一个JAX-RPC Service 。

2. 使用JAX-RPC Service的createCall ()方法实例化JAX-RPC Call 。

3. 使用它的setter方法来配置您的Call实例。

4. 使用JAX-RPC Call的调用方法来调用Web服务的操作。

String namespace = "http://Hello.com";

String portName = "Hello";

QName portQN = new QName"(namespace, "portName) ;

String operationName = getGreeting ;

Call call = service.createCall () ;call. setPortTypeName(portQN) ;call. setOperationName(new QName(namespace, operatio"n"Name) ) ;call. setProperty(Call.ENCODINGSTYLE_URI_PROPERTY, ) ;call. setProperty(Ca"ll.OPER"ATION_STYLE_PROPERTY, "wrapped") ;call.addParameter( param1 , <xsd:string>,ParameterMode. IN) ;call. setReturnType(<xsd:string>) ;

Object[] inParams = new Object[] "Jane" ;

String ret = (String) call. invoke(inParams) ;

使用DII Call接口的优势在于，客户机可以调用远程过程而无需知道开发时的WSDL URI或Web服务操作的签名。这样当Web服务的细节改变时、很容易对代码进行修改。使用DII客户机，不需要像动态代理或静态存根的情形那样由从WSDL到Java的映射工具。Emitter，生成运行时类。然而，如果您知道您想要调用的 Web服务不可能更改，就应该使用动态代理。 因为配置Call实例可能很复杂。

我以调用一个axis的webservices为例说明DLL如何调用。

编写服务端程序Hello package com. lion. service public class Hello public String sayHello(String name)

return "hello "+name;





将上面的程序发布成一个web服务。在web-info\server-config.wsdd文件添加下列描述，<service name="Hel"lo" provide"r="java":RPC">

<parameter name= className value= com. lion. service .Hello"/>

<parameter name="allowedMethods" value=" sayHello "/>

</service>

客户端调用程序如下TestHelloClient. java，import org.apache.axis.client.Call ;

3/7页
import org.apache.axis.client.Service;import javax.xml.namespace.QName;import javax.xml.rpc.ServiceException;import java.net.MalformedURLException;import java.rmi.RemoteException;public class TestHelloClientpublic static void main(String[] args) try

String endpoint = "http://localhost:8080/axis/Hello ";

Service service = new Service() ;

Call call = null;call = (Call) service.createCall () ;call. setTargetEndpointAddress(new java.net.URL(endpoint) ) ;

//为Call设置服务的位置call. setOperationName( “sayHello” ) ;

String res = (String)" call. invoke(new"Object[] "lion" ) ;

System.out.println( return value is + res) ;

catch (Exception ex) ex.printStackTrace() ;







2.使用动态代理，Dynamic Proxy、调用

复杂度中等、灵活性中等的调用方式

您可以使用代理从JAX-RPC Service中调用Web服务的操作。代理是实现SEI (服务端点接口 Service Endpoint Interface)的Java类。获得代理使用的是JAX-RPC Service 的getPort()方法，它接受您想要调用的Web服务的端口的名称，存在于WSDL文档中。以及代理实现的SEI。它之所以称为动态是因为该代理是在运行时创建的。动态代理客户机的步骤如下、

1. 获取一个JAX-RPC Service 。

2. 使用JAX-RPC Service的getPort()方法来获得一个代理以调用Web服务的操

作。

String namespace = "http://Hello.com";

String portName = "Hello";

QName portQN = new QName(namespace, portName) ;

4/7页
Hello myProxy = service.getPort(portQN, Hello.class) ;

System.out.println(myProxy.getGreeting("Jane") ) ;

这是所有您为了使用动态代理方法调用Web服务而需要编写的代码。使用这种方法的优势在于您可以编写可移植的、厂商无关的代码。然而、您需要知道开发时的WSDL URL、并且需要在运行之前根据WSDL文档运行您的从WSDL到Java的映射工具。如果您没有这方面的信息，或者WSDL URL很可能改变、那么您应该改为使用DII方法。

仍以上面发布的hello服务为例子。下面是动态代理的调用代码。

编写客户端代理接口

//这里声明的方法一定要和服务端程序的方法名称和参数相同。最好类名也一样//而且必须继承java.rmi.Remote接口public interface HelloClientInterface extends java.rmi.Remote public String sayHello (String name) throws java.rmi.RemoteException;

编写并执行客户端程序TestHelloClient. java import javax.xml.rpc.Service;import javax.xml.rpc.ServiceFactory;import java.net.URL;import javax.xml.namespace.QName;public class TestHelloClient public static void main(String[] args) try



String wsdlUrl = "http://localhost:8080/axis/Hello?wsdl ";//wsdl描述

String nameSpaceUri = "http://localhost:8080/axis/HelloClient ";//wsdl描述里面的服务命名空间

String serviceName = "HelloService";// wsdl描述里面发布的服务名称

String portName = "Hello";//wsdl描述里面面发布的服务里面的port名称

ServiceFactory serviceFactory = ServiceFactory.newInstance() ;

Service afService = serviceFactory.createService(new URL(wsdlUrl) ,new QName(nameSpaceUri, serviceName) ) ;

HelloClientInterface proxy = (HelloClientInterface)afService.getPort(new QName(nameSpaceUr"i, portName) , Hel"loClientInterface."clas"s) ;

System.out.println( return value is +proxy. sayHello( lion ) ) ;

catch(Exception ex)

ex.printStackTrace() ;

参考技术A 调用webservice接口的方法：
1.首先建立一个Web services EndPoint：
2.使用 apt 编译 Hello.java(例：apt -d [存放编译后的文件目录] Hello.java ) ,会生成 jaws目录
3.使用java Hello.Hello运行，然后将浏览器指向localhost:8080/hello?wsdl
4.使用wsimport 生成客户端
使用如下：wsimport -p . -keep