前言

自3月份到一家快递公司之后，就极少有时间来写博客了，进去的第一个周末就加班，做公司的开放平台，协助一个小伙伴写WebService接口，用的就是CXF，正好这个东西以前使用过。现在快7月了，以前写的东西，还木有写完，今天继续，将以前未写完的东西，写完整。

准备工作

这次的样例，都是在以前的基础上写的，主要贴出主要的代码，服务端和客户端都与Spring集成，使用了拦截器、Map数据类型等

服务端

共计写了四个服务，第一个主要说明服务端有多种发布方式，第二和第三实现类是相同的，区别在于第三个有拦截器，第四个包括拦截器和Map的数据类型，这些配置文件的注释中也有。

配置文件内容如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	 xmlns:jaxws="http://cxf.apache.org/jaxws"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
	http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
           http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd">
           
	<import resource="classpath:META-INF/cxf/cxf.xml"/>
<!-- 	<import resource="classpath:META-INF/cxf/cxf-servlet.xml"/> -->
	
	<!-- 服务一，无客户端 -->
	<!--  多种发布方式都可以
	<bean id="noInterfaceServiceImpl"
		class="com.wds.cxf.spring.server.impl.NoInterfaceServiceImpl"/>
	<jaxws:endpoint address="/noInterfaceService" 
		implementor="#noInterfaceServiceImpl"
	></jaxws:endpoint>
	-->
	<jaxws:endpoint
		id="noInterfaceService" address="/noInterfaceService" 
		implementor="com.wds.cxf.spring.server.impl.NoInterfaceServiceImpl"
	></jaxws:endpoint>
	
	<!-- 服务2：有客户端，不带拦截器 -->
	<jaxws:server address="/userService2">
		<jaxws:serviceBean>
			<bean class="com.wds.cxf.spring.server.impl.UserServiceImpl"></bean>
		</jaxws:serviceBean>
	</jaxws:server>
	
	<!-- 服务3：有客户端，带拦截器 ，与服务2是相同的代码，区别之处就是这个服务有拦截器-->
	<jaxws:server address="/userService" serviceClass="com.wds.cxf.spring.server.IUserService">
		<jaxws:serviceBean>
			<bean class="com.wds.cxf.spring.server.impl.UserServiceImpl"></bean>
		</jaxws:serviceBean>
		<jaxws:inInterceptors>
			<bean class="org.apache.cxf.interceptor.LoggingInInterceptor"></bean>
			<bean class="com.wds.cxf.spring.server.interceptor.HeaderHandlerInterceptor"></bean>
		</jaxws:inInterceptors>
		
		<jaxws:outInterceptors>
			<bean class="org.apache.cxf.interceptor.LoggingOutInterceptor"></bean>
		</jaxws:outInterceptors>
	</jaxws:server>
	
	<!-- 服务4：有拦截器，Map类型的数据结构 -->
	<jaxws:server address="/SecurityService" serviceClass="com.wds.cxf.spring.server.ISecurityService">
		<jaxws:serviceBean>
			<bean class="com.wds.cxf.spring.server.impl.SecurityServiceImpl"></bean>
		</jaxws:serviceBean>
		<jaxws:inInterceptors>
			<bean class="org.apache.cxf.interceptor.LoggingInInterceptor"></bean>
			<bean class="com.wds.cxf.spring.server.interceptor.HeaderHandlerInterceptor"></bean>
		</jaxws:inInterceptors>
		<jaxws:outInterceptors>
			<bean class="org.apache.cxf.interceptor.LoggingOutInterceptor"></bean>
		</jaxws:outInterceptors>
	</jaxws:server>
</beans>

第一个服务的类：

package com.wds.cxf.spring.server.impl;

import javax.jws.WebService;

@WebService
public class NoInterfaceServiceImpl {
	
	public String test(){
		return "Hello, this is test method";
	}
}

第二个和第三个服务的接口及实现类

package com.wds.cxf.spring.server;

import java.util.List;

import javax.jws.WebService;

@WebService
public interface IUserService {
	public List<String> getUserName();
}

实现类
package com.wds.cxf.spring.server.impl;

import java.util.ArrayList;
import java.util.List;

import javax.jws.WebService;
import javax.xml.ws.BindingType;
import javax.xml.ws.soap.SOAPBinding;

import com.wds.cxf.spring.server.IUserService;

@WebService(endpointInterface="com.wds.cxf.spring.server.IUserService",serviceName="UserService")
@BindingType(value=http://www.mamicode.com/SOAPBinding.SOAP12HTTP_BINDING)>第四个服务

package com.wds.cxf.spring.server;

import java.util.List;
import java.util.Map;

import javax.jws.WebService;
import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;

import com.wds.cxf.spring.server.adapter.MappingUser;

@WebService
public interface ISecurityService {
	@XmlJavaTypeAdapter(value=http://www.mamicode.com/MappingUser.class)>类型转换的适配类两个

package com.wds.cxf.spring.server.adapter;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

import javax.xml.bind.annotation.adapters.XmlAdapter;

import com.wds.cxf.spring.server.User;

public class MappingUser extends XmlAdapter<MappingUserValue, Map<String, List<User>>>{

	@Override
	public Map<String, List<User>> unmarshal(MappingUserValue src)
			throws Exception {
		Map<String, List<User>> target = new HashMap<String, List<User>>();
		for (MappingUserValue.Entry entry : src.getEntries()) {
			target.put(entry.getKey(), entry.getValue());
		}
		return target;
	}

	@Override
	public MappingUserValue marshal(Map<String, List<User>> src) throws Exception {
		MappingUserValue result = new MappingUserValue();
		MappingUserValue.Entry e = null;
		for (Entry<String, List<User>> entry : src.entrySet()) {
			e = new MappingUserValue.Entry();
			e.setKey(entry.getKey());
			e.setValue(entry.getValue());
			result.getEntries().add(e);
		}
		return result;
	}

}

package com.wds.cxf.spring.server.adapter;

import java.util.ArrayList;
import java.util.List;

import com.wds.cxf.spring.server.User;

public class MappingUserValue {
	private List<Entry> entries = new ArrayList<MappingUserValue.Entry>();

	public List<Entry> getEntries() {
		return entries;
	}

	public void setEntries(List<Entry> entries) {
		this.entries = entries;
	}
	
	public static class Entry {
		private String key;
		private List<User> value;

		public List<User> getValue() {
			return value;
		}

		public void setValue(List<User> value) {
			this.value = http://www.mamicode.com/value;>拦截器

package com.wds.cxf.spring.server.interceptor;

import java.util.List;

import javax.xml.namespace.QName;

import org.apache.cxf.binding.soap.SoapMessage;
import org.apache.cxf.headers.Header;
import org.apache.cxf.interceptor.Fault;
import org.apache.cxf.message.Message;
import org.apache.cxf.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
import org.w3c.dom.Element;
import org.w3c.dom.NodeList;

public class HeaderHandlerInterceptor extends AbstractPhaseInterceptor<Message> {

	public HeaderHandlerInterceptor(String phase) {
		super(Phase.PRE_INVOKE);
	}
	
	public HeaderHandlerInterceptor() {
		this(null);
	}

	@Override
	public void handleMessage(Message message) throws Fault {
		SoapMessage msg = (SoapMessage)message;
		List<Header> headers = msg.getHeaders();
		
		if(headers == null || headers.size() < 1){
			throw new Fault(new IllegalArgumentException("There have no header node!"));
		}
		
		Header firstHeader = headers.get(0);
		
		for (Header header : headers) {
			QName qName = header.getName();
			System.out.println(qName);
		}
		
		Element element = (Element)firstHeader.getObject();
		
		NodeList usernameNode = element.getElementsByTagName("username");
		NodeList passwordNode = element.getElementsByTagName("password");
		
		if(usernameNode == null || usernameNode.getLength() != 1){
			throw new Fault(new IllegalArgumentException("not valid username"));
		}
		
		if(passwordNode == null || passwordNode.getLength() != 1){
			throw new Fault(new IllegalArgumentException("not valid password"));
		}
		
		String userName = usernameNode.item(0).getTextContent();
		String userPass = passwordNode.item(0).getTextContent();
		
		if(!("admin".equals(userPass) && "admin".equals(userName))){
			throw new Fault(new IllegalArgumentException("username or password is not valid"));
		}
	}

}

至此，服务端的代码，全部齐了

客户端

客户端的代码是需要CXF的命令生成

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	 xmlns:jaxws="http://cxf.apache.org/jaxws"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
	http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
           http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd">
           
	<import resource="classpath:META-INF/cxf/cxf.xml"/>
	<!-- 第四个服务的客户端 -->
	<jaxws:client 
		id="securityService" 
		address="http://localhost:8080/web/services/SecurityService"
		serviceClass="com.wds.java.cxf.client.role.code.ISecurityService" >
		<jaxws:outInterceptors>
			<bean class="com.wds.java.cxf.interceptor.ClientHeaderInterceptor">
				<constructor-arg index="0" value=http://www.mamicode.com/"admin" />>使用CXF的命令，生成客户端代码，加上面的配置，此外还需要一个拦截器，代码如下：

package com.wds.java.cxf.interceptor;

import java.util.List;

import javax.xml.namespace.QName;

import org.apache.cxf.binding.soap.SoapMessage;
import org.apache.cxf.headers.Header;
import org.apache.cxf.helpers.DOMUtils;
import org.apache.cxf.interceptor.Fault;
import org.apache.cxf.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
import org.w3c.dom.Document;
import org.w3c.dom.Element;

public class ClientHeaderInterceptor extends AbstractPhaseInterceptor<SoapMessage>{

	private String username;
	private String password;
	
	public ClientHeaderInterceptor(String phase) {
		super(Phase.PREPARE_SEND);//在准备发送SOAP消息时，调用此拦截器
	}
	
	public ClientHeaderInterceptor(String username, String password) {
		this("");
		this.username = username;
		this.password = password;
	}

	@Override
	public void handleMessage(SoapMessage msg) throws Fault {
		List<Header> headers = msg.getHeaders();
		Document doc = DOMUtils.createDocument();
		Element authEle = doc.createElement("header");
		Element usernameEle = doc.createElement("username");
		Element passwordEle = doc.createElement("password");
		
		usernameEle.setTextContent(username);
		passwordEle.setTextContent(password);
		
		authEle.appendChild(usernameEle);
		
		authEle.appendChild(passwordEle);
		
		Header header = new Header(new QName("authHeaer"), authEle);
		
		headers.add(header);
		
		authEle = doc.createElement("headerTwo");
		usernameEle = doc.createElement("username");
		passwordEle = doc.createElement("password");
		
		usernameEle.setTextContent(username);
		passwordEle.setTextContent(password);
		
		authEle.appendChild(usernameEle);
		
		authEle.appendChild(passwordEle);
		
		header = new Header(new QName("2authHeaer"), authEle);
		
		headers.add(header);
	}

}

测试类

package com.wds.java.cxf.client.user;

import java.util.List;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.wds.java.cxf.client.role.code.Entry;
import com.wds.java.cxf.client.role.code.ISecurityService;
import com.wds.java.cxf.client.role.code.MappingUserValue;
import com.wds.java.cxf.client.user.code.IUserService;

public class Main {

	@SuppressWarnings("resource")
	public static void main(String[] args) {
		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:/conf/cxf/spring-cxf-client.xml");
		
		IUserService service = (IUserService) context.getBean("userServiceTwo");
		List<String> userNames = service.getUserName();
		
		service = (IUserService) context.getBean("userServiceOne");
		List<String> userNamesOne = service.getUserName();
		
		for (String string : userNames) {
			System.out.println(string);
		}
		
		for (String string : userNamesOne) {
			System.out.println(string);
		}
		
		ISecurityService  securityService = (ISecurityService) context.getBean("securityService");
		MappingUserValue userValue = http://www.mamicode.com/securityService.getAuthority();>运行即可

声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉：投诉/举报工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。

联系
我们

首页 > 代码库 > WebService-06-CXF与Spring集成

WebService-06-CXF与Spring集成

前言

准备工作

服务端

客户端

测试类

看完仍有疑问？有类似问题直接问程序猿