SpringBoot整合WebService服务

WebService是一个SOA&＃xff08;面向服务的编程&＃xff09;的架构&＃xff0c;它是不依赖于语言&＃xff0c;不依赖于平台&＃xff0c;可以实现不同的语言间的相互调用&＃xff0c;通过Internet进行基于Http协议的网络应用间的交互。 其实WebService并不是什么神秘的东西&＃xff0c;它就是一个可以远程调用的类&＃xff0c;或者说是组件&＃xff0c;把你本地的功能开放出去共别人调用。

为什么使用WebService&＃xff1f;

简单解释一下WebService&＃xff0c;比如你的项目需要查询某银行账户余额。你能直接查吗&＃xff0c;肯定不行&＃xff0c;因为数据库是银行的&＃xff0c;他不可能给你权限。你想访问他的数据库获取数据&＃xff0c;这就需要用到WebService。通过调用银行暴露的接口来得到你想要的数据。

适用场景&＃xff1a; 

软件的集成和复用&＃xff0c;如气象局(服务端系统)、天气查询网站等。

发布一个服务(对内/对外),不考虑客户端类型,不考虑性能,建议WebService

服务端已经确定使用webservice,客户端不能选择,必须使用WebService

软件集成:通过远程调用技术,将两个系统整合到一起,从而实现软件集成。

软件复用:同一个款软件的多次集成,最终实现复用。

不适用场景&＃xff1a;

考虑性能时不建议使用WebService

同构程序下不建议使用WebService

Axis2与CXF的区别

目前java开发WebService的框架主要包括Axis2和CXF&＃xff0c;如果你需要多语言的支持&＃xff0c;你应该选择Axis2。如果你需要把你的实现侧重java并希望和Spring集成&＃xff0c;CXF就是更好的选择&＃xff0c;特别是把你的WebService嵌入其他的程序中。

SpringBoot使用CXF集成WebService

1.向pom.xml中添加集成WebService的相关依赖

org.springframework.bootspring-boot-starter-web-services

org.apache.cxfcxf-rt-frontend-jaxws3.1.6

org.apache.cxfcxf-rt-transports-http3.1.6



2.创建服务端接口

package com.primeton.mq.service;
import javax.jws.WebService;
&＃64;WebService(name &＃61; "DemoService", // 暴露服务名称targetNamespace &＃61; "http://service.mq.primeton.com"// 命名空间,一般是接口的包名倒序
)
public interface DemoService {public String sayHello(String user);
}


3.创建服务端接口实现类

package com.primeton.mq.service.impl;
import com.primeton.mq.service.DemoService;
import javax.jws.WebService;
import java.util.Date;
&＃64;WebService(serviceName &＃61; "DemoService", // 与接口中指定的name一致targetNamespace &＃61; "http://service.mq.primeton.com", // 与接口中的命名空间一致,一般是接口的包名倒endpointInterface &＃61; "com.primeton.mq.service.DemoService"// 接口地址
)
public class DemoServiceImpl implements DemoService {&＃64;Overridepublic String sayHello(String user) {return user&＃43;"&＃xff0c;现在时间&＃xff1a;"&＃43;"("&＃43;new Date()&＃43;")";}
}


4.创建CXF配置类

package com.primeton.mq.webServiceConfig;
import com.primeton.mq.service.DemoService;
import com.primeton.mq.service.impl.DemoServiceImpl;
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.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.xml.ws.Endpoint;&＃64;Configuration
public class CxfConfig {&＃64;Beanpublic ServletRegistrationBean dispatcherServlet() {return new ServletRegistrationBean(new CXFServlet(),"/demo/*");}&＃64;Bean(name &＃61; Bus.DEFAULT_BUS_ID)public SpringBus springBus() {return new SpringBus();}&＃64;Beanpublic DemoService demoService() {return new DemoServiceImpl();}&＃64;Beanpublic Endpoint endpoint() {EndpointImpl endpoint &＃61; new EndpointImpl(springBus(), demoService());endpoint.publish("/api");return endpoint;}
}


5.启动SpringBoot服务

输入http://localhost:8090/demo/api?wsdl即可&＃xff0c;注意我设置的端口是8090&＃xff0c;视情况而定。

6.创建客户端

在idea中进入File > New Project…菜单打开新建项目窗口&＃xff0c;依次选择Java、WebServices&＃xff0c;Version项选择Apache Axis&＃xff0c;Libraries项选择 Download。然后点击Next按钮进入下一页。

在下一页中输入项目名称&＃xff0c;然后点击Finish按钮开始下载依赖包。依赖包下载完成后进入新建的项目。

选WebServices > Generate Wsdl From Java Code&＃xff0c;生成wsdl

然后选择服务地址

确定之后&＃xff0c;创建一个测试类&＃xff0c;代码如下&＃xff1a;

package test;
import example.DemoServiceImplService;
public class demo {public static void main(String[] args) {DemoServiceImplService webServiceImpl &＃61; new DemoServiceImplService();String result &＃61; webServiceImpl.getDemoServiceImplPort().sayHello("没有说");System.out.println("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;");System.out.println(result);System.out.println("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;");}
}


注意&＃xff1a;实现WebService客户端不一定要生成客户端的代码&＃xff0c;可以通过地址动态调用。

package com.primeton.mq.test;
import com.primeton.mq.service.DemoService;
import org.apache.cxf.endpoint.Client;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
import org.apache.cxf.transport.http.HTTPConduit;
import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
public class demo {public static void main(String[] args) {//创建动态客户端JaxWsDynamicClientFactory factory &＃61; JaxWsDynamicClientFactory.newInstance();Client client &＃61; factory.createClient("http://localhost:8090/demo/api?wsdl");// 需要密码的情况需要加上用户名和密码//client.getOutInterceptors().add(new ClientLoginInterceptor(USER_NAME,PASS_WORD));HTTPConduit conduit &＃61; (HTTPConduit) client.getConduit();HTTPClientPolicy httpClientPolicy &＃61; new HTTPClientPolicy();httpClientPolicy.setConnectionTimeout(2000); //连接超时httpClientPolicy.setAllowChunking(false); //取消块编码httpClientPolicy.setReceiveTimeout(120000); //响应超时conduit.setClient(httpClientPolicy);//client.getOutInterceptors().addAll(interceptors);//设置拦截器try{Object[] objects &＃61; new Object[0];// invoke("方法名",参数1,参数2,参数3....);objects &＃61; client.invoke("sayHello", "sujin");System.out.println("返回数据:" &＃43; objects[0]);}catch (Exception e){e.printStackTrace();}}
}