• WebService之CXF入门开发

    1. Server端项目结构
      f870ff0e5a4348aaa9f88df1c91c2fb5.png
    2. Server端pom.xml 
      1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      2.   <modelVersion>4.0.0</modelVersion>
      3.   <groupId>com.java1234.webservice</groupId>
      4.   <artifactId>WS_Server</artifactId>
      5.   <version>0.0.1-SNAPSHOT</version>
      6.  
      7.   <dependencies>
      8.  
      9.   	<dependency>
      10. 		<groupId>org.apache.cxf</groupId>
      11. 		<artifactId>cxf-core</artifactId>
      12. 		<version>3.1.5</version>
      13. 	</dependency>
      14.  
      15.   	<dependency>
      16. 		<groupId>org.apache.cxf</groupId>
      17. 		<artifactId>cxf-rt-frontend-jaxws</artifactId>
      18. 		<version>3.1.5</version>
      19. 	</dependency>
      20.  
      21. 	<dependency>
      22. 		<groupId>org.apache.cxf</groupId>
      23. 		<artifactId>cxf-rt-transports-http-jetty</artifactId>
      24. 		<version>3.1.5</version>
      25. 	</dependency>
      26.  
      27. 	<!--JDK11需要添加此依赖-->
      28. 	<dependency>
      29. 		<groupId>com.sun.xml.ws</groupId>
      30. 		<artifactId>jaxws-ri</artifactId>
      31. 		<version>2.3.1</version>
      32. 	</dependency>
      33.  
      34.   </dependencies>
      35. </project>
    3. Server端实体类 
      1. package com.cxf.entity;
      2.  
      3. public class User {
      4.  
      5. 	private Integer id; // 编号
      6. 	private String userName; // 用户名
      7. 	private String password; // 密码
      8. 	
      9. 	public Integer getId() {
      10. 		return id;
      11. 	}
      12. 	public void setId(Integer id) {
      13. 		this.id = id;
      14. 	}
      15. 	public String getUserName() {
      16. 		return userName;
      17. 	}
      18. 	public void setUserName(String userName) {
      19. 		this.userName = userName;
      20. 	}
      21. 	public String getPassword() {
      22. 		return password;
      23. 	}
      24. 	public void setPassword(String password) {
      25. 		this.password = password;
      26. 	}
      27. 	
      28. 	
      29. }
      1. package com.cxf.entity;
      2.  
      3. public class Role {
      4.  
      5. 	private Integer id; // 编号
      6. 	private String roleName; // 角色名称
      7. 	
      8. 	
      9. 	
      10. 	public Role() {
      11. 		super();
      12. 		// TODO Auto-generated constructor stub
      13. 	}
      14. 	
      15. 	
      16. 	public Role(Integer id, String roleName) {
      17. 		super();
      18. 		this.id = id;
      19. 		this.roleName = roleName;
      20. 	}
      21.  
      22.  
      23. 	public Integer getId() {
      24. 		return id;
      25. 	}
      26. 	public void setId(Integer id) {
      27. 		this.id = id;
      28. 	}
      29. 	public String getRoleName() {
      30. 		return roleName;
      31. 	}
      32. 	public void setRoleName(String roleName) {
      33. 		this.roleName = roleName;
      34. 	}
      35. 	
      36. 	
      37. }
      1. package com.cxf.entity;
      2.  
      3. import java.util.List;
      4.  
      5. /**
      6.  * 接口的返回值类型为Map时需要该中间实体来互转
      7.  * @author Administrator
      8.  *
      9.  */
      10. public class MyRole {
      11.  
      12. 	private String key;
      13. 	private List<Role> value;
      14. 	
      15. 	public String getKey() {
      16. 		return key;
      17. 	}
      18. 	public void setKey(String key) {
      19. 		this.key = key;
      20. 	}
      21. 	public List<Role> getValue() {
      22. 		return value;
      23. 	}
      24. 	public void setValue(List value) {
      25. 		this.value = value;
      26. 	}
      27. 	
      28. }
    4.  Server端接口 
      1. package com.cxf.webservice;
      2.  
      3. import java.util.List;
      4. import java.util.Map;
      5.  
      6. import javax.jws.WebService;
      7. import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
      8. 		
      9. 		import com.cxf.adapter.MapAdapter;
      10. 		import com.cxf.entity.Role;
      11. 		import com.cxf.entity.User;
      12.  
      13. @WebService
      14. public interface HelloWorld {
      15. 	
      16. 	// 返回值为String
      17. 	public String say(String str);
      18. 	
      19. 	// 返回值为List
      20. 	public List getRoleByUser(User user);
      21. 	
      22. 	// 返回值为Map-->需要自定义适配器：MapAdapter-->@XmlJavaTypeAdapter(MapAdapter.class)
      23. 	@XmlJavaTypeAdapter(MapAdapter.class)
      24. 	public Map> getRoles();
      25. 	
      26. }
    5. Server端接口实现 
      1. package com.cxf.webservice.impl;
      2.  
      3. import java.util.ArrayList;
      4. import java.util.HashMap;
      5. import java.util.List;
      6. import java.util.Map;
      7.  
      8. import javax.jws.WebService;
      9.  
      10. import com.cxf.entity.Role;
      11. import com.cxf.entity.User;
      12. import com.cxf.webservice.HelloWorld;
      13.  
      14. @WebService
      15. public class HelloWorldImpl implements HelloWorld{
      16.  
      17. 	public String say(String str) {
      18. 		return "Hello:"+str;
      19. 	}
      20.  
      21. 	public List<Role> getRoleByUser(User user) {
      22. 		List<Role> roleList=new ArrayList<Role>();
      23. 		roleList.add(new Role(1,"AAAA"));
      24. 		roleList.add(new Role(2,"BBBB"));
      25. 		return roleList;
      26. 	}
      27.  
      28. 	public Map<String, List<Role>> getRoles() {
      29. 		Map<String,List<Role>> map=new HashMap>();
      30. 		
      31. 		List<Role> roleList1=new ArrayList<Role>();
      32. 		roleList1.add(new Role(1,"CCCC"));
      33. 		map.put("cccc", roleList1);
      34. 		
      35. 		List<Role> roleList2=new ArrayList<Role>();
      36. 		roleList2.add(new Role(2,"DDDD"));
      37. 		map.put("dddd", roleList2);
      38. 		
      39. 		return map;
      40. 	}
      41.  
      42. }
    6.  Map类型返回值适配器 
      1. package com.cxf.adapter;
      2.  
      3. import java.util.HashMap;
      4. import java.util.List;
      5. import java.util.Map;
      6. import java.util.Set;
      7.  
      8. import javax.xml.bind.annotation.adapters.XmlAdapter;
      9.  
      10. import com.cxf.entity.MyRole;
      11. import com.cxf.entity.Role;
      12.  
      13. public class MapAdapter extends XmlAdapter<MyRole[], Map<String,List<Role>>>{
      15. 	/**
      16. 	 * 适配转换 MyRole[] -> Map<String, List<Role>>
      17. 	 */
      18. 	@Override
      19. 	public Map<String, List<Role>> unmarshal(MyRole[] myRoles) throws Exception {
      20. 		Map<String, List<Role>> map=new HashMap>();
      21. 		for(int i=0;i<myRoles.length;i++){
      22. 			MyRole myRole=myRoles[i];
      23. 			map.put(myRole.getKey(), myRole.getValue());
      24. 		}
      25. 		return map;
      26. 	}
      27.  
      28. 	/**
      29. 	 * 适配转换 Map<String, List<Role>> -> MyRole[]
      30. 	 */
      31. 	@Override
      32. 	public MyRole[] marshal(Map<String, List<Role>> map) throws Exception {
      33. 		MyRole[] roles=new MyRole[map.size()];
      34. 		
      35. 		Set<Map.Entry<String, List<Role>>> entries = map.entrySet();
      36. 		Integer index = 0;
      37. 		for (Map.Entry<String, List<Role>> entry : entries) {
      38. 			roles[index]=new MyRole();
      39. 			roles[index].setKey(entry.getKey());
      40. 			roles[index].setValue(entry.getValue());
      41. 			index++;
      42. 		}
      43. 		
      44. 		return roles;
      45. 	}
      46.  
      47. }
    7.  Server端自定义拦截器（调用接口方法前执行） 
      1. package com.cxf.interceptor;
      2.  
      3. import java.util.List;
      4.  
      5. import org.apache.cxf.binding.soap.SoapMessage;
      6. import org.apache.cxf.headers.Header;
      7. import org.apache.cxf.interceptor.Fault;
      8. import org.apache.cxf.phase.AbstractPhaseInterceptor;
      9. import org.apache.cxf.phase.Phase;
      10. import org.w3c.dom.Element;
      11. import org.w3c.dom.NodeList;
      12.  
      13. public class MyInterceptor extends AbstractPhaseInterceptor<SoapMessage> {
      14.  
      15. 	public MyInterceptor() {
      16. 		super(Phase.PRE_INVOKE);  // 调用接口方法前执行自定拦截器
      17. 		
      18. 	}
      19.  
      20. 	@SuppressWarnings("null")
      21. 	public void handleMessage(SoapMessage message) throws Fault {
      22. 		List<Header> headers=message.getHeaders();
      23. 		if(headers==null && headers.size()==0){
      24. 			throw new Fault(new IllegalArgumentException("没有Header，拦截器实施拦截"));
      25. 		}
      26. 		Header firstHeader=headers.get(0);
      27. 		Element ele=(Element) firstHeader.getObject();
      28. 		NodeList uList=ele.getElementsByTagName("userName");
      29. 		NodeList pList=ele.getElementsByTagName("password");
      30. 		if(uList.getLength()!=1){
      31. 			throw new Fault(new IllegalArgumentException("用户名格式不对"));
      32. 		}
      33. 		if(pList.getLength()!=1){
      34. 			throw new Fault(new IllegalArgumentException("密码格式不对"));
      35. 		}
      36. 		String userName=uList.item(0).getTextContent();
      37. 		String password=pList.item(0).getTextContent();
      38. 		
      39. 		if(!userName.equals("cxf")||!password.equals("123456")){
      40. 			throw new Fault(new IllegalArgumentException("用户名或者密码错误！"));
      41. 		}
      42. 	}
      43.  
      44. }
    8.  Server端启动类 
      1. package com.cxf.webservice.impl;
      2.  
      3.  
      4.  
      5. import org.apache.cxf.interceptor.LoggingInInterceptor;
      6. import org.apache.cxf.interceptor.LoggingOutInterceptor;
      7. import org.apache.cxf.jaxws.JaxWsServerFactoryBean;
      8.  
      9. import com.cxf.interceptor.MyInterceptor;
      10. import com.cxf.webservice.HelloWorld;
      11.  
      12. public class Server {
      13.  
      14. 	public static void main(String[] args) {
      15. 		System.out.println("web service start");
      16. 		HelloWorld implementor=new HelloWorldImpl();
      17. 		String address="http://localhost:8888/helloWorld";
      18. 		// Endpoint.publish(address, implementor); // jdk实现 暴露webservice接口
      19. 		JaxWsServerFactoryBean factoryBean=new JaxWsServerFactoryBean();
      20. 		factoryBean.setAddress(address); // 设置暴露地址
      21. 		factoryBean.setServiceClass(HelloWorld.class); // 接口类
      22. 		factoryBean.setServiceBean(implementor); // 设置实现类
      23. 		factoryBean.getInInterceptors().add(new LoggingInInterceptor()); // 添加in拦截器 日志拦截器
      24. 		factoryBean.getOutInterceptors().add(new LoggingOutInterceptor()); // 添加out拦截器 日志拦截器
      25. 		
      26. 		factoryBean.getInInterceptors().add(new MyInterceptor());
      27. 		factoryBean.create(); // 创建webservice接口
      28. 		System.out.println("web service started");
      29. 	}
      30. }
    9.  启动Server端
      2120ac8e43104c918d69ab5f686aab35.png
    10.  Client端自动生成
      https://pan.baidu.com/s/1wTK2ly-SJgZM99TyAdmPiw?pwd=hbn1 
      1. 1.apache-cxf-3.1.5.zip解压后在环境变量添加bin路径
      2.  
      3. 2.执行命令：wsdl2java -encoding utf-8 -d C:\Users\Administrator\Desktop\wsdl http://localhost:8888/helloWorld?wsdl
      4.  
      5. 3.将C:\Users\Administrator\Desktop\wsdl路径下自动生成的java文件复制到Client端

      11cc871c30ae4196b9f20a752f444b65.png
      17c8239685f1411e8a0f82acea16ce53.png

    11.  Client端pom.xml 
      1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      2.   <modelVersion>4.0.0</modelVersion>
      3.   <groupId>com.java1234.webservice</groupId>
      4.   <artifactId>WS_Client</artifactId>
      5.   <version>0.0.1-SNAPSHOT</version>
      6.  
      7.   <dependencies>
      8.  
      9.   	<dependency>
      10. 		<groupId>org.apache.cxf</groupId>
      11. 		<artifactId>cxf-core</artifactId>
      12. 		<version>3.1.5</version>
      13. 	</dependency>
      14.  
      15.   	<dependency>
      16. 		<groupId>org.apache.cxf</groupId>
      17. 		<artifactId>cxf-rt-frontend-jaxws</artifactId>
      18. 		<version>3.1.5</version>
      19. 	</dependency>
      20.  
      21. 	<dependency>
      22. 		<groupId>org.apache.cxf</groupId>
      23. 		<artifactId>cxf-rt-transports-http-jetty</artifactId>
      24. 		<version>3.1.5</version>
      25. 	</dependency>
      26.  
      27. 	<!--JDK11需要添加此依赖-->
      28. 	<dependency>
      29. 		<groupId>com.sun.xml.ws</groupId>
      30. 		<artifactId>jaxws-ri</artifactId>
      31. 		<version>2.3.1</version>
      32. 	</dependency>
      33.  
      34.   </dependencies>
      35. </project>
    12.  Client端自定义拦截器（发送SOAP消息时调用） 
      1. package com.cxf.interceptor;
      2.  
      3. import java.util.List;
      4.  
      5. import javax.xml.namespace.QName;
      6.  
      7. import org.apache.cxf.binding.soap.SoapMessage;
      8. import org.apache.cxf.headers.Header;
      9. import org.apache.cxf.helpers.DOMUtils;
      10. import org.apache.cxf.interceptor.Fault;
      11. import org.apache.cxf.phase.AbstractPhaseInterceptor;
      12. import org.apache.cxf.phase.Phase;
      13. import org.w3c.dom.Document;
      14. import org.w3c.dom.Element;
      15.  
      16. public class AddHeaderInterceptor extends AbstractPhaseInterceptor<SoapMessage> {
      17.  
      18. 	private String userName;
      19. 	private String password;
      20. 	
      21. 	public AddHeaderInterceptor(String userName,String password) {
      22. 		super(Phase.PREPARE_SEND); // 准备发送SOAP消息的时候调用拦截器
      23. 		this.userName=userName;
      24. 		this.password=password;
      25. 	}
      26. 	
      27. 	/**
      28. 	 * 客户端拦截器和服务端拦截器对应，客户端拦截器向SoapMessage添加的参数可以在服务端拦截器获取到并进行校验
      29. 	 * 校验失败通过：throw new Fault(new IllegalArgumentException("没有Header，拦截器实施拦截"))抛出的异常在客户端控制台可见
      30. 	 * @param message
      31. 	 * @throws Fault
      32. 	 */
      33. 	public void handleMessage(SoapMessage message) throws Fault {
      34. 		List<Header> headerList=message.getHeaders();
      35. 		
      36. 		Document doc=DOMUtils.createDocument();
      37. 		Element ele=doc.createElement("authHeader");
      38. 		Element uElement=doc.createElement("userName");
      39. 		uElement.setTextContent(userName);
      40. 		Element pElement=doc.createElement("password");
      41. 		pElement.setTextContent(password);
      42. 		
      43. 		ele.appendChild(uElement);
      44. 		ele.appendChild(pElement);
      45. 		
      46. 		headerList.add(new Header(new QName("cxf"),ele));
      47. 		
      48. 	}
      49. 	
      50. 	
      51.  
      52. }
    13.   Client端测试类 
      1. package com.cxf.webservice;
      2.  
      3. import java.util.List;
      4.  
      5. import org.apache.cxf.frontend.ClientProxy;
      6. import org.apache.cxf.interceptor.LoggingInInterceptor;
      7. import org.apache.cxf.interceptor.LoggingOutInterceptor;
      8.  
      9. import com.cxf.interceptor.AddHeaderInterceptor;
      10.  
      11. public class Client {
      12.  
      13. 	public static void main(String[] args) {
      14. 		HelloWorldService service=new HelloWorldService();
      15. 		HelloWorld helloWorld=service.getHelloWorldPort();
      16. 		org.apache.cxf.endpoint.Client client=ClientProxy.getClient(helloWorld);
      17. 		
      18. 		client.getOutInterceptors().add(new AddHeaderInterceptor("cxf","123456")); // 添加自定义拦截器
      19. 		
      20. 		client.getInInterceptors().add(new LoggingInInterceptor()); // 添加In拦截器 日志拦截器
      21. 		client.getOutInterceptors().add(new LoggingOutInterceptor()); // 添加Out拦截器 日志拦截器
      22. 		
      23. 		System.out.println(helloWorld.say("cxf"));
      24.  
      25. 		List roles1=helloWorld.getRoleByUser(new User());
      26. 		for(Role role:roles1){
      27. 			System.out.println(role.getId()+","+role.getRoleName());
      28. 		}
      29. 		
      30. 		// 返回值为Map,服务端需要适配转换 @XmlJavaTypeAdapter(MapAdapter.class)-->Map> -> MyRole[]
      31. 		List roles2 = helloWorld.getRoles().item;
      32. 		for (MyRole myRole : roles2) {
      33. 			String key = myRole.getKey();
      34. 			List roles = myRole.getValue();
      35. 			System.out.println(key+":"+roles.toString());
      36. 		}
      37. 		
      38. 	}
      39. }
      f31163d5a90d4d47b3a9dc3c5f5a3a65.png
      b17cee2ba230492fa82121cca81b92fb.png
      32293391822b468db888abfd5ec7c3b5.png
      ab0b8197bbb04304bbdd50b8861e6a97.png

    https://blog.csdn.net/caoli201314?type=blog

     

     

  • 相关阅读:
    问题总结：一个 list 使用 for 遍历，边循环边删除的问题
    爬虫基本原理介绍、实现以及问题解决
    【算法|贪心算法系列No.3】leetcode334. 递增的三元子序列
    力扣面试150 文本左右对齐 贪心 字符串 满注释版
    RDB 做快照的时候数据能修改吗？
    SUB-1G 无线收发芯片CC1101国产替代方案
    双十一买什么比较划算？四款实用性超强不吃灰的数码好物推荐
    C#调用Python脚本
    【前端笔试】关于一些输入输出
    培训机构不会告诉的真相：为什么不招聘培训出来的前端
  • 原文地址：https://blog.csdn.net/tongxin_tongmeng/article/details/126482362