备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

webservice cxf与spring详解

2016-08-28 2151
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： wsdl文档结构图JDK方式开发server端代码package server;import javax.jws.WebMethod;import javax.jws.WebService;/** *  *  * SEI:Service Endpoint Interface 发布的服务接口 * */@WebServicepublic interface He


wsdl文档结构图

wKiom1ZMVDyQVc4QAAF5AdHQQEQ210.png


  1. JDK方式开发


server端代码

package server;

import javax.jws.WebMethod;
import javax.jws.WebService;
/**
 * 
 * 
 * SEI:Service Endpoint Interface 发布的服务接口
 *
 */
@WebService
public interface HelloWS {
@WebMethod
    public String sayHello(String name);
}
package server;


import javax.jws.WebService;
/**
 * 
 * 
 * SEI的实现
 *
 */
@WebService
public class  HelloWSImpl  implements HelloWS{

    @Override
    public String sayHello(String name) {
        System.out.println("server sayHello()"+name);
        return "Hello"+name;
    }

}
package server;

import javax.xml.ws.Endpoint;

public class ServerPublish {

    
    public static void main(String[] args) {
        
        String address="http://localhost:8090/sayhello";
        //对应的wsdl文档地址http://localhost:8090/sayhello?wsdl
        Endpoint.publish(address, new HelloWSImpl());
        System.out.println("发布服务成功");
    }
}


根据wsdl文件生成客户端代码

远程
wsimport -keep 

.net代码写的需要修改里面的

<s:sequence>
    <s:element ref="s:schema"/>
    <s:any/>
</s:sequence>

为
  <s:sequence>
    <s:any minOccurs="2" maxOccurs="2" />
  </s:sequence>

 
本地
wsimport -keep  WeatherWS.wsdl


使用以下代码发送请求

package weather;

import java.util.List;

import cn.com.webxml.ArrayOfString;
import cn.com.webxml.WeatherWS;
import cn.com.webxml.WeatherWSSoap;

public class ClientTest {

    public static void main(String[] args) {
        
        WeatherWS weatherWS  =new WeatherWS();
        
        WeatherWSSoap  weatherWSSoap =weatherWS.getWeatherWSSoap();
        ArrayOfString  arrayOfString= weatherWSSoap.getWeather("上海", null);
        List<String> list=arrayOfString.getString();
        System.out.println(list);
        for(String s:list){
            
            System.out.println(s+"***");
        }
        
    }
}


2.CXF方式

CXF支持map，jdk自带不支持map数据结构


使用wsdl2java +wsdl文件地址  生成客户端调用代码


cxf3.1.4添加日志服务器和客户端拦截器


服务器

package server;



import java.util.List;

import org.apache.cxf.frontend.ServerFactoryBean;
import org.apache.cxf.interceptor.Interceptor;
import org.apache.cxf.interceptor.LoggingInInterceptor;
import org.apache.cxf.interceptor.LoggingOutInterceptor;
import org.apache.cxf.message.Message;

public class ServerPublish {

    
    public static void main(String[] args) {
        
        String address="http://localhost:8090/sayhello";
        HelloWSImpl hw = new HelloWSImpl();
        ServerFactoryBean sfb = new ServerFactoryBean();
        sfb.setServiceClass(HelloWS.class);
        sfb.setServiceBean(hw);
        sfb.setAddress(address);
        //服务器端的日志入拦截器
        List<Interceptor<? extends Message>> inInterceptors =sfb.getInInterceptors();
        inInterceptors.add(new LoggingInInterceptor() );
        
      //服务器端的日志出拦截器
        List<Interceptor<? extends Message>> outInterceptors =sfb.getOutInterceptors();
        outInterceptors.add(new LoggingOutInterceptor());
        sfb.create();
        System.out.println("发布服务成功");
    }
}


客户端

package client;

import java.util.List;

import org.apache.cxf.endpoint.Client;
import org.apache.cxf.frontend.ClientProxy;
import org.apache.cxf.interceptor.Interceptor;
import org.apache.cxf.interceptor.LoggingInInterceptor;
import org.apache.cxf.interceptor.LoggingOutInterceptor;
import org.apache.cxf.message.Message;

import server.HelloWS;
import server.HelloWSPortType;


public class client_test {

    public static void main(String[] args) {
        HelloWS helloWS = new HelloWS();
        HelloWSPortType helloWSPortType = helloWS.getHelloWSPort();
        Client client=ClientProxy.getClient(helloWSPortType);
         //客户端的日志入拦截器
        List<Interceptor<? extends Message>> inInterceptors =client.getInInterceptors();
        inInterceptors.add(new LoggingInInterceptor() );
        
      //客户端的日志出拦截器
        List<Interceptor<? extends Message>> outInterceptors =client.getOutInterceptors();
        outInterceptors.add(new LoggingOutInterceptor());
        
        String s=helloWSPortType.sayHello(" yuanhai");
        
        System.out.println(s);
    }
}



cxf添加自定义拦截器实现密码用户名验证


客户端拦截器

package client;

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 AddUserInterceptor  extends AbstractPhaseInterceptor<SoapMessage>{

    
    private String name;
    private String password;
    public AddUserInterceptor(String name, String password) {
        super(Phase.PRE_PROTOCOL);//准备协议化时拦截
        this.name=name;
        this.password=password;
        
    
    }

    
    /*
     在soap中加个head
     <Envelope>
     <head>
         <atguigu>
             <name>yuanhai</name>
             <password>123456<password>
         </atguigu>
         <atguigu2>
             <name>yuanhai</name>
             <password>123456<password>
         </atguigu2>
     </head>
     <Body>
         <sayHello>
             <arg0>yuanhai</arg0>
         </sayHello>
     </Body>
     
     </Envelope>
     
     
     */
    @Override
    public void handleMessage(SoapMessage msg) throws Fault {
    List<Header> headers=    msg.getHeaders();
    
    Document document=DOMUtils.createDocument();
        Element rootEle=document.createElement("atguigu");
        Element nameEle=document.createElement("name");
        nameEle.setTextContent(name);
        Element passwordEle=document.createElement("password");
        passwordEle.setTextContent(password);
        rootEle.appendChild(nameEle);
        rootEle.appendChild(passwordEle);
        
        headers.add(new Header(new QName("atguigu"), rootEle));//QName必须跟rootEle的标签一样
        System.out.println("client handleMessage()...");
    }

    
    
}


调用代码

package client;

import java.util.List;

import org.apache.cxf.endpoint.Client;
import org.apache.cxf.frontend.ClientProxy;
import org.apache.cxf.interceptor.Interceptor;
import org.apache.cxf.interceptor.LoggingInInterceptor;
import org.apache.cxf.interceptor.LoggingOutInterceptor;
import org.apache.cxf.message.Message;

import server.HelloWS;
import server.HelloWSPortType;


public class client_test {

    public static void main(String[] args) {
        HelloWS helloWS = new HelloWS();
        HelloWSPortType helloWSPortType = helloWS.getHelloWSPort();
        
        Client client=ClientProxy.getClient(helloWSPortType);
         //客户端的日志入拦截器
        List<Interceptor<? extends Message>> inInterceptors =client.getInInterceptors();
        inInterceptors.add(new LoggingInInterceptor() );
        
      //客户端的日志出拦截器
        List<Interceptor<? extends Message>> outInterceptors =client.getOutInterceptors();
        outInterceptors.add(new LoggingOutInterceptor());
        outInterceptors.add(new AddUserInterceptor("yuanhai","123456"));
        String s=helloWSPortType.sayHello(" yuanhai");
        
        System.out.println(s);
    }
}



服务端拦截器

package server;

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.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
import org.w3c.dom.Element;

/*
 * 检查用户的拦截器
 */
public class CheckUserInterceptor extends AbstractPhaseInterceptor<SoapMessage> {

    public CheckUserInterceptor() {
        super(Phase.PRE_PROTOCOL);
    
    }

    @Override
    public void handleMessage(SoapMessage msg) throws Fault {
        
    Header header=    msg.getHeader(new QName("atguigu"));
        if(header!=null){
            Element atguiguEle =(Element) header.getObject();
            
            String name=atguiguEle.getElementsByTagName("name").item(0).getTextContent();
            String password=atguiguEle.getElementsByTagName("password").item(0).getTextContent();
            if("yuanhai".equals(name)&&"123456".equals(password)){
                
                System.out.println("Server 通过拦截器...");
                return;
            }
            
        }
        //不能通过
        System.out.println("Server 未通过拦截器...");
        throw new Fault(new RuntimeException("请求需要一个正确的用户名和密码"));
        
    }

}

调用代码

package server;



import java.util.List;

import org.apache.cxf.frontend.ServerFactoryBean;
import org.apache.cxf.interceptor.Interceptor;
import org.apache.cxf.interceptor.LoggingInInterceptor;
import org.apache.cxf.interceptor.LoggingOutInterceptor;
import org.apache.cxf.message.Message;

public class ServerPublish {

    
    public static void main(String[] args) {
        
        String address="http://localhost:8090/sayhello";
        HelloWSImpl hw = new HelloWSImpl();
        ServerFactoryBean sfb = new ServerFactoryBean();
        sfb.setServiceClass(HelloWS.class);
        sfb.setServiceBean(hw);
        sfb.setAddress(address);
        //服务器端的日志入拦截器
        List<Interceptor<? extends Message>> inInterceptors =sfb.getInInterceptors();
        inInterceptors.add(new LoggingInInterceptor() );
        inInterceptors.add(new CheckUserInterceptor());
      //服务器端的日志出拦截器
        List<Interceptor<? extends Message>> outInterceptors =sfb.getOutInterceptors();
        outInterceptors.add(new LoggingOutInterceptor());
        sfb.create();
        System.out.println("发布服务成功");
    }
}




3.cxf与spring集成

server段代码


实体类order

package bean;

public class Order {
    
    public Order(int id, String name, double price) {
    
        this.id = id;
        this.name = name;
        this.price = price;
    }
    private int id;

    private String name;
    
    private double price;
    
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public double getPrice() {
        return price;
    }
    public void setPrice(double price) {
        this.price = price;
    }
    
}


webservice接口

package ws;

import javax.jws.WebMethod;
import javax.jws.WebService;

import bean.Order;
@WebService
public interface OrderWS {

    
    @WebMethod
    public Order getOrderById(int id);
}

webservice实现类

package ws;

import bean.Order;

public class OrderWsImpl  implements OrderWS {

    
    public OrderWsImpl(){
        System.out.println("OrderWsImpl()");
    }
    @Override
    public Order getOrderById(int id) {
        
        System.out.println("server getOrderById()"+id);
        return new Order(id, "飞机", 100000);
    }

}


spring配置文件beans.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:jaxws="http://cxf.apache.org/jaxws" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    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">
        
        <!--  引入cxf的一些核心配置-->
    <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-servlet.xml" /> -->

    <jaxws:endpoint id="orderWS" implementor="ws.OrderWsImpl" address="/orderws" >
    
    <jaxws:inInterceptors>
    <bean class="ws.CheckUserInterceptor"/>
    </jaxws:inInterceptors>
     </jaxws:endpoint>
    
</beans>


web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
        xmlns:web="http://java.sun.com/xml/ns/javaee" 
        xmlns="http://java.sun.com/xml/ns/javaee" 
        xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
        http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" version="2.5">
  <context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>classpath*:beans.xml</param-value>
  </context-param>
  <listener>
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  </listener>
  <servlet>
    <servlet-name>CXFServlet</servlet-name>
    <servlet-class>org.apache.cxf.transport.servlet.CXFServlet</servlet-class>
  </servlet>
  <servlet-mapping>
    <servlet-name>CXFServlet</servlet-name>
    <url-pattern>/*</url-pattern>
  </servlet-mapping>
</web-app>



客户端


spring配置文件client-beans.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:jaxws="http://cxf.apache.org/jaxws" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    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">
        
    

    <jaxws:client id="orderClient" 
    serviceClass="ws.OrderWS" 
    address="http://localhost:8080/webservice_cxf_spring_server/orderws">
    
    <jaxws:outInterceptors>
    <bean class="test.AddUserInterceptor">
    <constructor-arg name="name" value="yuanhai"/>
    <constructor-arg name="password" value="123456"/>
    </bean>
    </jaxws:outInterceptors>
    
     </jaxws:client>
    
</beans>


客户端调用代码

package test;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import ws.Order;
import ws.OrderWS;

public class client_test {

    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
                new String[] { "client-beans.xml" });
        OrderWS orderWs = (OrderWS) context.getBean("orderClient");
        Order order = orderWs.getOrderById(24);
        System.out.println(order);
    }
}


本文出自 “点滴积累” 博客，请务必保留此出处http://tianxingzhe.blog.51cto.com/3390077/1714748

文章标签：
日志服务
Java
Spring
数据格式
XML
关键词：
Spring webservice
Spring CXF
cxf Spring
相关实践学习
日志服务之使用Nginx模式采集日志
本文介绍如何通过日志服务控制台创建Nginx模式的Logtail配置快速采集Nginx日志并进行多维度分析。
神巧合
目录
相关文章
程序员DMZ
在使用SSH+Spring开发webservice ，报的一些异常及处理方法
在使用SSH+Spring开发webservice ，报的一些异常及处理方法
程序员DMZ
201 0
在使用SSH+Spring开发webservice ，报的一些异常及处理方法
流烟默
|
4月前
|
XML Java 应用服务中间件
WebService - Axis2与Spring整合并发布多个service(同样使用services.xml)
WebService - Axis2与Spring整合并发布多个service(同样使用services.xml)
流烟默
77 0
流烟默
|
4月前
|
Java 应用服务中间件 Spring
WebService - Axis2使用services.xml进行开发server与client(未与Spring整合)
WebService - Axis2使用services.xml进行开发server与client(未与Spring整合)
流烟默
44 0
流烟默
|
4月前
|
Java 应用服务中间件 Spring
WebService - CXF 与Spring整合(Service+Client)
WebService - CXF 与Spring整合(Service+Client)
流烟默
24 0
牧小农
|
XML Java 数据格式
java WebService CXF Spring 自定义拦截器 附实例源码
java WebService CXF Spring 自定义拦截器 附实例源码
牧小农
150 0
java WebService CXF Spring 自定义拦截器 附实例源码
牧小农
|
XML Java Apache
java WebService CXF Spring 自定义拦截器 附实例源码
java WebService CXF Spring 自定义拦截器 附实例源码
牧小农
165 0
java WebService CXF Spring 自定义拦截器 附实例源码
沉默王二
|
XML 存储 Java
WebService对象调用spring注解
WebService对象调用spring注解
沉默王二
147 0
科技小能手
|
XML Java 数据格式
xfire+spring+maven构建webservice服务器和客户端
科技小能手
1272 0
程序界小强
|
XML Java 数据格式
用cxf编写基于spring的webservice之上篇
版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.
程序界小强
936 0
程序界小强
|
JavaScript Java 网络架构
用cxf编写基于spring的webservice之下篇
版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.
程序界小强
699 0

热门文章

最新文章

  • 1
    Spring Security的授权管理器实现
  • 2
    Spring Security的授权&鉴权
  • 3
    SpringBoot3集成Swagger出现错误Error starting ApplicationContext. To display the condition evaluation repor
  • 4
    9种设计模式在Spring中的运用
  • 5
    Spring+SpringMVC+Mybatis的分布式敏捷开发系统架构
  • 6
    Springboot+Spring security +jwt认证+动态授权
  • 7
    【深入浅出Spring原理及实战】「缓存Cache开发系列」带你深入分析Spring所提供的缓存Cache功能的开发实战指南（一）
  • 8
    【深入浅出Spring原理及实战】「EL表达式开发系列」深入解析SpringEL表达式理论详解与实际应用
  • 9
    Spring轻量级开发框架（二）
  • 10
    SpringBoot 项目瘦身指南
  • 1
    Spring5深入浅出篇:Spring切入点详解
    16
  • 2
    解锁安全之门：探索Spring Security中的路径匹配方案
    12
  • 3
    深入理解Spring Boot的@ComponentScan注解
    20
  • 4
    Spring Framework 中的 @Autowired 注解：概念与使用方法
    28
  • 5
    Spring Boot实现各种参数校验
    11
  • 6
    第10章 Spring Security 的未来趋势与高级话题（2024 最新版）（下）
    17
  • 7
    第10章 Spring Security 的未来趋势与高级话题（2024 最新版）（上）
    22
  • 8
    第7章 Spring Security 的 REST API 与微服务安全（2024 最新版）（上）
    24
  • 9
    第5章 Spring Security 的高级认证技术（2024 最新版）（上）
    29
  • 10
    第3章 Spring Security 的用户认证机制（2024 最新版）（下）
    29

    • 相关课程

    更多
  • 全面讲解Spring Cloud Alibaba技术栈（知识精讲+项目实战）第一阶段
  • 精通Spring Cloud Alibaba
  • 微服务框架 Spring Cloud 快速入门
  • Java Web开发系列课程 - Spring框架入门
  • Spring Boot 2.5.x开发实战
  • Spring Cloud微服务架构设计与开发实战

    • 相关电子书

    更多
  • 云栖社区特邀专家徐雷Java Spring Boot开发实战系列课程（第20讲）：经典面试题与阿里等名企内部招聘求职面试技巧
  • 微服务架构模式与原理Spring Cloud开发实战
  • 阿里特邀专家徐雷Java Spring Boot开发实战系列课程（第18讲）：制作Java Docker镜像与推送到DockerHub和阿里云Docker仓库

    • 相关实验场景

    更多
  • 从零搭建Spring Boot的Hello World
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）