CXF 搭建 webservice 服务

港控/mmm° 2022-05-17 04:53 257阅读 0赞
  1. 基于jdk 搭建 webservice

<1> 定义类型

  1. public class Person {
  3.     private Integer id;
  4.     private String name;
  5.     private Integer age;
  7.     public Person() {
  8.     }
  10.     public Person(Integer id, String name, Integer age) {
  11.         this.id = id;
  12.         this.name = name;
  13.         this.age = age;
  14.     }
  16.     public Integer getId() {
  17.         return id;
  18.     }
  20.     public void setId(Integer id) {
  21.         this.id = id;
  22.     }
  24.     public String getName() {
  25.         return name;
  26.     }
  28.     public void setName(String name) {
  29.         this.name = name;
  30.     }
  32.     public Integer getAge() {
  33.         return age;
  34.     }
  36.     public void setAge(Integer age) {
  37.         this.age = age;
  38.     }
  39. }

<2> 定义接口

  1. @WebService
  2. @SOAPBinding(style= SOAPBinding.Style.DOCUMENT, use= SOAPBinding.Use.LITERAL, parameterStyle= SOAPBinding.ParameterStyle.BARE)
  3. @BindingType(value = "http://www.w3.org/2003/05/soap/bindings/HTTP/")
  4. public interface PeresionService {
  6.     void create(Person person);
  8.     Person getById(Integer id);
  10.     Person getByName(String name);
  11. }

<3> 定义接口实现

  1. @WebService
  2. @SOAPBinding(style= SOAPBinding.Style.DOCUMENT, use= SOAPBinding.Use.LITERAL, parameterStyle= SOAPBinding.ParameterStyle.BARE)
  3. @BindingType(value = "http://www.w3.org/2003/05/soap/bindings/HTTP/")
  4. public class PersonSeviceImpl implements PeresionService {
  6.     @Override
  7.     public void create(Person person) {
  9.     }
  11.     @Override
  12.     public Person getById(Integer id) {
  13.         return new Person(id, "mall", 3);
  14.     }
  16.     @Override
  17.     public Person getByName(String name) {
  18.         return new Person(4, name, 3);
  19.     }
  20. }

<4> 服务发布

  1. public class PersonTest {
  3.     public static void main(String[] args) {
  5.         String address = "http://localhost:8686/ws/person";
  6.         Endpoint endpoint = Endpoint.publish(address, new PersonSeviceImpl());
  8.         System.out.println("发布 person webservice成功!");
  9.     }
  10. }

访问wsdl : http://localhost:8686/ws/person?wsdl

  1. 引入cxf 框架

    1.  <dependency>
    2.    <groupId>org.apache.cxf</groupId>
    3.    <artifactId>cxf-rt-core</artifactId>
    4.    <version>2.6.2</version>
    5.  </dependency>
    7.  <dependency>
    8.    <groupId>org.apache.cxf</groupId>
    9.    <artifactId>cxf-rt-frontend-jaxws</artifactId>
    10.    <version>2.6.2</version>
    11.  </dependency>
    13.  <dependency>
    14.    <groupId>org.apache.cxf</groupId>
    15.    <artifactId>cxf-rt-transports-http</artifactId>
    16.    <version>2.6.2</version>
    17.  </dependency>
    19.  <dependency>
    20.    <groupId>org.apache.cxf</groupId>
    21.    <artifactId>cxf-rt-transports-http-jetty</artifactId>
    22.    <version>2.6.2</version>
    23.  </dependency>

<1> 引入日志拦截器，记录服务调用情况，服务调用前，服务调用后

  1. // cxf 服务端
  2.         EndpointImpl endpointimpl = (EndpointImpl) endpoint;
  4.         // 添加请求处理前日志拦截器
  5.         List<Interceptor<? extends Message>> inInterceptors = endpointimpl.getInInterceptors();
  6.         inInterceptors.add(new LoggingInInterceptor());
  8.         // 添加请求处理后日志拦截器
  9.         endpointimpl.getOutInterceptors().add(new LoggingOutInterceptor());

<2> 自定义拦截器，如对soap信息认证：

  1. public class CheckUsernamePasswordInterceptor extends AbstractPhaseInterceptor<SoapMessage> {
  3.     public CheckUsernamePasswordInterceptor() {
  4.         super(Phase.PRE_PROTOCOL);
  5.     }
  7.     /*  请求消息
  8.      <soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope" xmlns:ser="http://service.dmall.dtdream.com/">
  9.        <soap:Header>
  10.         <atguigu>
  11.                 <username>itcast</username>
  12.                 <password>atguigu</password>
  13.           </atguigu>
  14.        <soap:Header/>
  15.        <soap:Body>
  16.           <ser:getById>3</ser:getById>
  17.        </soap:Body>
  18.     </soap:Envelope>
  20.     */
  22.     @Override
  23.     public void handleMessage(SoapMessage message) throws Fault {
  25.         Header header = message.getHeader(new QName("atguigu"));
  27.         if (null == header) {
  28.             throw new Fault(new RuntimeException("用户验证失败"));
  29.         }
  31.         Element atguigu = (Element) header.getObject();
  33.         String username = atguigu.getElementsByTagName("username").item(0).getTextContent();
  34.         String password = atguigu.getElementsByTagName("password").item(0).getTextContent();
  36.         if ("itcast".equals(username) && "atguigu".equals(password)) {
  37.             System.out.println("用户验证通过！");
  38.             return;
  39.         }
  41.         throw new Fault(new RuntimeException("用户验证失败"));
  42.     }

添加至服务前置拦截器：

  1. inInterceptors.add(new CheckUsernamePasswordInterceptor());

发表评论

表情：
评论列表 （有 0 条评论，257人围观）

还没有评论，来说两句吧...

相关阅读