springboot整合cxf发布webservice以及调用的方法

<dependency>

  <groupid>org.apache. cxf </groupid>

  <artifactid>cxf-spring-boot-starter-jaxws</artifactid>

  <version> 3.1 . 11 </version>

</dependency>

public class baseresult {

  private string issuccess;

  private string errcode;

  private string message;

  public string getissuccess() {

  return issuccess;

  }

  public void setissuccess(string issuccess) {

  this .issuccess = issuccess;

  }

  public string geterrcode() {

  return errcode;

  }

  public void seterrcode(string errcode) {

  this .errcode = errcode;

  }

  public string getmessage() {

  return message;

  }

  public void setmessage(string message) {

  this .message = message;

  }

}

@xmlrootelement (name = "testresult" )

public class testresult extends baseresult implements serializable {

  private static final long serialversionuid = -7128575337024823798l;

  private list<user> data;

  public list<user> getdata() {

  return data;

  }

  public void setdata(list<user> data) {

  this .data = data;

  }

}

public class user {

  private string name;

  private int age;

  public user(string name, int age) {

  super ();

  this .name = name;

  this .age = age;

  }

  public user() {

  super ();

  }

  public string getname() {

  return name;

  }

  public void setname(string name) {

  this .name = name;

  }

  public int getage() {

  return age;

  }

  public void setage( int age) {

  this .age = age;

  }

}

@webservice

public interface testwservice{

  @webmethod

  @webresult

  testresult list3();

}

@service

@webservice (targetnamespace = "http://ws.**.com/" ,//命名空间,一般是接口的包名倒序)

endpointinterface = "com.**.ws.testwsservice" ) //接口全路径

//**自己改自己的包路径

public class testwsservice impl implements testwsservice {

  @override

  public testresult list3() {

  list<user> list = new arraylist<user>();

  list.add( new user( "张三" , 23 ));

  list.add( new user( "李四" , 24 ));

  testresult testresult = new testresult();

  testresult.setissuccess( "y" );

  testresult.setdata(list);

  testresult.setmessage( "操作成功" );

  return testresult;

  }

}

import javax.xml.ws.endpoint;

import org.apache.cxf.bus;

import org.apache.cxf.bus.spring.springbus;

import org.apache.cxf.jaxws.endpointimpl;

import org.apache.cxf.transport.servlet.cxfservlet;

import org.springframework.beans.factory.annotation.autowired;

import org.springframework.boot.web.servlet.servletregistrationbean;

import org.springframework.context.annotation.bean;

import org.springframework.context.annotation.configuration;

import com.hikvision.hikserviceassign.ws.monitorsurveyws;

import com.hikvision.hikserviceassign.ws.smartlockserviceorderws;

/**

  * webservice 发布服务类

  * @author xupx

  * @date 2018年8月14日 下午4:25:25

  *

  */

@configuration

public class cxfconfig {

  @autowired

  private testwservice testwservice;

  @suppresswarnings ( "all" )

  @bean

  public servletregistrationbean wsservlet() {

   servletregistrationbean bean = new servletregistrationbean( new cxfservlet(), "/soap/*" );

   return bean;

  }

  @bean (name = bus.default_bus_id)

  public springbus springbus() {

   return new springbus();

  }

  @bean

  public endpoint testwservice() {

   //会找到o2owebservice的实现类，所以实现类只能有一个

   endpointimpl endpoint = new endpointimpl(springbus(), testwservice);

   endpoint.publish( "/testwservice" );

   return endpoint;

  }

}

import org.apache.cxf.endpoint.client;

import org.apache.cxf.jaxws.endpoint.dynamic.jaxwsdynamicclientfactory;

import org.junit.test;

import org.junit.runner.runwith;

import org.springframework.boot.test.context. springboot test;

import org.springframework.test.context.junit4.springrunner;

@runwith (springrunner. class )

@springboottest

public class springbootcxfapplicationtests {

  @test

  public void contextloads() throws exception {

  jaxwsdynamicclientfactory dcf = jaxwsdynamicclientfactory.newinstance();

  client client = dcf.createclient( "http://127.0.0.1:8080/soap/testwservice?wsdl" );

  object[] objects = client.invoke( "list3" ,param1,param2); //list3方法名 后面是可变参数

  //输出调用结果

  system.out.println(objects[ 0 ].getclass());

  system.out.println(objects[ 0 ].tostring());

  }

}

testwsimplservice implservice = new testwsimplservice ();

  testservicews ws = implservice.gettestservicewsimplport();

  testresult result = ws.list3();

  system.err.println(result);

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 logininterceptor extends abstractphaseinterceptor<soapmessage> {

  private string username= "root" ;

  private string password= "admin" ;

  public logininterceptor(string username, string password) {

   //设置在发送请求前阶段进行拦截

   super (phase.prepare_send);

   this .username=username;

   this .password=password;

  }

  @override

  public void handlemessage(soapmessage soapmessage) throws fault {

   list<header> headers = soapmessage.getheaders();

   document doc = domutils.createdocument();

   element auth = doc.createelementns( "http://cxf.wolfcode.cn/" , "securityheader" );

   element username = doc.createelement( "username" );

   element userpass = doc.createelement( "password" );

   username.settextcontent(username);

   userpass.settextcontent(password);

   auth.appendchild(username);

   auth.appendchild(userpass);

   headers.add( 0 , new header( new qname( "securityheader" ),auth));

  }

}

import java.util.list;

import javax.xml.soap.soapexception;

import org.apache.commons.lang3.stringutils;

import org.apache.cxf.binding.soap.soapheader;

import org.apache.cxf.binding.soap.soapmessage;

import org.apache.cxf.interceptor.fault;

import org.apache.cxf.phase.abstractphaseinterceptor;

import org.apache.cxf.phase.phase;

import org.w3c.dom.element;

import org.w3c.dom.nodelist;

import org.apache.cxf.headers.header;

public class authinterceptor extends abstractphaseinterceptor<soapmessage> {

  private static final string username= "root" ;

  private static final string password= "admin" ;

  public authinterceptor() {

   //定义在哪个阶段进行拦截

   super (phase.pre_protocol);

  }

  @override

  public void handlemessage(soapmessage soapmessage) throws fault {

   list<header> headers = null ;

   string username= null ;

   string password= null ;

   try {

    headers = soapmessage.getheaders();

   } catch (exception e) {

    e.printstacktrace();

   }

   if (headers == null ) {

    throw new fault( new illegalargumentexception( "找不到header，无法验证用户信息" ));

   }

   //获取用户名,密码

   for (header header : headers) {

    soapheader soapheader = (soapheader) header;

    element e = (element) soapheader.getobject();

    nodelist usernamenode = e.getelementsbytagname( "username" );

    nodelist pwdnode = e.getelementsbytagname( "password" );

     username=usernamenode.item( 0 ).gettextcontent();

     password=pwdnode.item( 0 ).gettextcontent();

    if ( stringutils.isempty(username)||stringutils.isempty(password)){

     throw new fault( new illegalargumentexception( "用户信息为空" ));

    }

   }

   //校验用户名密码

   if (!(username.equals(username) && password.equals(password))){

    soapexception soapexc = new soapexception( "认证失败" );

    throw new fault(soapexc);

   }

  }

}