CXF2.0.7和2.1.1在AegisDatabinding方面的问题

0 0

CXF2.0.7和2.1.1在AegisDatabinding方面的问题5

我注意到CXF有两个不同的Release （v2.0.7 & v2.1.1）。这两个版本在AegisDatabinding方面有一些区别。

对于V2.0.7版本，仍然保留了org.apache.cxf.aegis.type.TypeMappingRegistry
和org.apache.cxf.aegis.type.DefaultTypeMappingRegistry。这类似于XFire中对于Aegis的binding支持。Developer可以通过：

TypeMapping typeMapping = registry.getDefaultTypeMapping();

if (typeMapping.isRegistered(MyType.class)) {
typeMapping.removeType(typeMapping.getType(myType.getTypeClass()));
}

typeMapping.register(new Mytype());

public class MyType extends Type {

@Override
public .... readObject() {....}

@Override
public .... writeObject() {.....}

}

加入自定义类或没有无参构造器类的Aegis Databinding. 如对于java.util.UUID类(经常使用它作为实体的主键)。

对于V2.1.1版本，取消了上述的org.apache.cxf.aegis.type.TypeMappingRegistry
和org.apache.cxf.aegis.type.DefaultTypeMappingRegistry。但是加入了AegisContext，它包含TypeMapping。并且，AegisContext被包含在AegisDataBinding类中，并且多出了一个DefaultTypeMapping的TypeMapping实现类。

我觉得大致的Aegis Databinding过程如下：

产生一个AegisDatabinding 对其进行TypeMapping的处理，如下：

public static AegisDatabinding createAegisDatabinding() {
AegisDatabinding aegisDatabinding = new AegisDatabinding();

AegisContext aegisContext = aegisDatabinding.getAegisContext();

TypeMapping mapping = new DefaultTypeMapping();
if (mapping.isRegistered(UUIDType.class)) {
mapping.removeType(new UUIDType());
}
mapping.register(new UUIDType());

aegisContext.setTypeMapping(mapping);

aegisContext.initialize();

aegisDatabinding.setAegisContext(aegisContext);

return aegisDatabinding;
}

之后，配置jaxws:endpoint，如下（serserBeans.xml）：

<import resource="classpath:META-INF/cxf/cxf.xml"/>
<import resource="classpath:META-INF/cxf/cxf-extension-soap.xml"/>
<import resource="classpath:META-INF/cxf/cxf-extension-http.xml" />
<import resource="classpath:META-INF/cxf/cxf-extension-local.xml" />
<import resource="classpath:META-INF/cxf/cxf-extension-jms.xml" />
<import resource="classpath:META-INF/cxf/cxf-servlet.xml"/>

<bean id="userService" class="demo.service.UserService"/>

<bean id="aegisDatabinding"
class="org.springframework.beans.factory.config.MethodInvokingFactoryBean"
scope="singleton">
<property name="staticMethod"
value="demo.service.type.AegisTypeMappingHelper.createAegisDatabinding"/>
</bean>

<bean id="serviceFactory" class="org.apache.cxf.jaxws.support.JaxWsServiceFactoryBean" scope="prototype">
<property name="dataBinding" ref="aegisDatabinding" />
<property name="serviceConfigurations">
<list>
<bean class="org.apache.cxf.jaxws.support.JaxWsServiceConfiguration" />
<bean class="org.apache.cxf.aegis.databinding.AegisServiceConfiguration" />
<bean class="org.apache.cxf.service.factory.DefaultServiceConfiguration" />
</list>
</property>
</bean>

<bean id="logInbound"
class="org.apache.cxf.interceptor.LoggingInInterceptor" />
<bean id="logOutbound"
class="org.apache.cxf.interceptor.LoggingOutInterceptor" />

<jaxws:endpoint id="userServiceEndpoint" implementor="#userService" address="http://localhost:9002/UserService">
<jaxws:inInterceptors>
<ref bean="logInbound" />
<ref bean="logOutbound" />
</jaxws:inInterceptors>
<jaxws:serviceFactory>
<ref bean="serviceFactory" />
</jaxws:serviceFactory>
</jaxws:endpoint>

对应的客户端配置文件:(clientBeans.xml)
<import resource="classpath:demo/service/serverBeans.xml" />

<bean id="userServiceTestClient" class="demo.service.UserService" />

<bean id="userServiceClient"
class="demo.service.IUserService" factory-bean="clientFactory"
factory-method="create" />

<bean id="clientFactory"
class="org.apache.cxf.jaxws.JaxWsProxyFactoryBean">
<property name="serviceClass"
value="demo.service.IUserService" />
<property name="address"
value="http://localhost:9002/UserServiceService" />
<property name="serviceFactory" ref="serviceFactory" />
</bean>

测试代码：

import java.util.UUID;

import javax.annotation.Resource;

import junit.framework.Assert;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.TestExecutionListeners;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.test.context.support.DependencyInjectionTestExecutionListener;

import demo.domain.IUser;
import demo.domain.User;
import demo.service.IUserService;

@RunWith(SpringJUnit4ClassRunner.class)
@TestExecutionListeners({DependencyInjectionTestExecutionListener.class})
@ContextConfiguration(locations={"classpath:demo/service/clientBeans.xml","classpath:demo/service/serverBeans.xml"})
public class UserServiceTestCase extends Assert implements ApplicationContextAware {

ApplicationContext applicationContext;
IUserService userService;

@Override
public void setApplicationContext(ApplicationContext applicationContext)
throws BeansException {
this.applicationContext = applicationContext;
}

public ApplicationContext getApplicationContext() {
return applicationContext;
}

@Resource(name="userServiceTestClient")
public void setUserService(IUserService userService) {
this.userService = userService;
}

@Test
public void testCreateUser() throws Exception {
IUser user = new User();
user.setId(UUID.randomUUID());
user.setName("Johnny");
userService.createUser(user);
}

@Test
public void testFindUserById() throws Exception {
userService.findUserById(UUID.randomUUID());
}

@Test
public void testFindUserByName() throws Exception {
userService.findUserByName("Johnny");
}

@Test
public void testGetUserMap() throws Exception {
userService.getUserMap();
}

@Test
public void testFindUserListByName() throws Exception {
userService.findUserListByName("Johnny");
}

}

但是，server无法正常启动。我怀疑是UUID没有被正确的mapping。报错是schema重复冲突，如果不设置UUIDType的schema则会报NullPointerException。

Project在附件中。

请大家不吝赐教在V2.1.1环境下正确配置此种AegisDatabinding的方法。

SOA