关于远程调用（XFire/HttpInvoker/Hessian etc.）及远程服务管理的一些随想（下）

iBatis框架batch处理问题分析及优化 | 关于远程调用（XFire/HttpInvoker/Hessian ...

2007-03-18

关键字: Spring xfire webservice soa httpinvoker hessian pool

服务代理生成器（ ServiceProxyGenerator ）也是一个值得一提的地方，我们先看一下它的接口：

/**
* 服务代理生成器。
*
* @author Tony
*/
public interface ServiceProxyGenerator {
/**
* 取得服务代理对象。
*
* @param serviceClass
* 服务接口
* @param serviceUrl
* 服务地址
* @param props
* 附加属性
* @return 代理对象
* @throws Exception
*/
Object getService(Class serviceClass, String serviceUrl, Properties props) throws Exception;
}
/*它只有一个 getService() 方法，那么为什么设计这个接口？在什么地方使用呢？回答这个问题之前先来看看下面这段代码： */
public void registService(ServiceModel serviceModel) throws ServiceException {
······
String key = serviceModel.getServiceId() + KEY_SPAR
+ serviceModel.getServiceClass().getName();
if ( serviceNames .contains(key)) {
throw new ServiceRegistException( "service is exist!" );
}
Object proxy = null ;
try {
ServiceProxyGenerator proxyGenerator = (ServiceProxyGenerator) beanFactory
.getBean(serviceModel.getServiceType() + PROXY_GENERATOR_END );
proxy = proxyGenerator.getService(serviceModel.getServiceClass(), serviceModel
.getServiceUrl(), serviceModel.getProps());
} catch (Exception e) {
throw new ServiceRegistException( "can't regist service !" , e);
}
if (proxy != null ) {
serviceNames .add(key);
serviceContainer .put(key, proxy);
} else {
throw new ServiceRegistException( "fail to regist service !" );
}
}

上面做特殊标记的代码就是应用服务代理生成器的地方，这里我们用到了 Spring 的 bean 工厂，根据注册服务的类型（ xfire,httpinvoker,hessian 等）到 Spring 容器里查找相应的生成器，并生成指定类型的服务。看下面配置的几个服务代理生成器：

xml 代码

< bean id = "xfire_generator" class = "com.tonysoft.common.service.repository.generator.XFireServiceProxyGenerator" lazy-init = "true" >
< property name = "serviceFactory" >
< ref bean = "xfire.serviceFactory" />
property >
bean >
< bean id = "hessian_generator" class = "com.tonysoft.common.service.repository.generator.HessianServiceProxyGenerator" lazy-init = "true" >
bean >
< bean id = "httpinvoker_generator" class = "com.tonysoft.common.service.repository.generator.HttpInvokeServiceProxyGenerator" lazy-init = "true" >
bean >
< bean id = "custom_generator" class = "com.tonysoft.common.service.repository.generator.CustomServiceProxyGenerator" lazy-init = "true" >
bean >
< bean id = "serviceRepository" class = "com.tonysoft.common.service.repository.DefaultServiceRepository" >
bean >
< bean id = "serviceIdProvider" class = "com.tonysoft.common.service.repository.provider.DefaultServiceIdProvider" >
bean >
< bean id = "abstractServiceProxyFactory" class = "com.tonysoft.common.service.repository.ServiceProxyFactory" abstract = "true" >
bean >

简单看一下 HttpInvoker 类型服务代理生成器的代码：

java 代码

public class HttpInvokeServiceProxyGenerator implements ServiceProxyGenerator {
/** HttpInvoker 服务代理工厂 */
private HttpInvokerProxyFactoryBean httpInvokerFactory = new HttpInvokerProxyFactoryBean();
/*
* @see com.alipay.xfiredemo.common.ServiceProxyGenerator#getService(java.lang.Class, java.lang.String,
* java.util.Properties)
*/
public Object getService(Class serviceClass, String serviceUrl, Properties props) {
// Todo initial httpInvokerFactory with props
httpInvokerFactory .setServiceInterface(serviceClass);
httpInvokerFactory .setServiceUrl(serviceUrl);
// must invoke this method
httpInvokerFactory .afterPropertiesSet();
return httpInvokerFactory .getObject();
}
}

是的，正如你所看到的一样，我们这里把真正生成服务代理的任务交给了 Spring 的 HttpInvokerProxyFactoryBean 来完成。

提供在初始化时注册的静态服务功能，配制如下：

< bean id = "bootupServiceRegister" class = "com.tonysoft.common.service.repository.register.BootupServiceRegister" lazy-init = "false" >
< property name = "services" >
< list >
< bean class = "com.tonysoft.common.service.repository.ServiceModel" >
< property name = "serviceClass" >< value > com.tonysoft.common.service.repository.example.HelloHttpInvoker value > property >
< property name = "serviceId" >< value > default value > property >
< property name = "serviceType" >< value > httpinvoker value > property >
< property name = "serviceUrl" >< value > http://localhost:8080/serviceRepositoryApplication/service/httpInvoker/helloHttpInvoker.service value > property >
< property name = "props" >
< props > props >
property >
bean >
< bean class = "com.tonysoft.common.service.repository.ServiceModel" >
< property name = "serviceClass" >< value > com.tonysoft.common.service.repository.example.HelloXFire value > property >
< property name = "serviceId" >< value > default value > property >
< property name = "serviceType" >< value > xfire value > property >
< property name = "serviceUrl" >< value > http://localhost:8080/serviceRepositoryApplication/service/xfire/helloXFire.service?WSDL value > property >
< property name = "props" >
< props > props >
property >
bean >
list >
property >
bean >

具体内容可以参看附件中的资源：

一、 ServiceRepository 的源代码（ Eclipse 工程）

二、一个示例应用

三、打包部署的 ANT 脚本

把项目导入 Eclipse 中，直接运行 Ant 脚本，在 target 目录下会生成服务中心的 jar 包，同时生成示例应用的 war 包，把 war 包放到任意服务器（ Server ）上并启动服务器并确保应用正常启动。运行 ServiceRepositoryTest .java 执行完整的单元测试，观测结果。其他的自己看源码吧。