当前位置： 首页 > news >正文

SpringBoot整合WebService

news 2025/7/9 6:22:09

SpringBoot整合WebService

WebService是一个比较旧的远程调用通信框架，现在企业项目中用的比较少，因为它逐步被SpringCloud所取代，它的优势就是能够跨语言平台通信，所以还有点价值，下面来看看如何在SpringBoot项目中使用WebService

我们模拟从WebService客户端发送请求给WebService服务端暴露的下载文件服务，并获取服务端返回的文件保存到本地

环境

SpringBoot2.7.3

Jdk17

服务端

在SpringBoot中整合WebService的服务端，需要通过一个配置文件将服务接口暴露出去给客户端调用

项目结构

image-20230727183518916

配置

服务端POM

<?xml version="1.0" encoding="UTF-8"?>
<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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.7.3</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.example</groupId><artifactId>webservice</artifactId><version>0.0.1-SNAPSHOT</version><name>webservice</name><description>webservice</description><properties><java.version>17</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!--cxf--><dependency><groupId>org.apache.cxf</groupId><artifactId>cxf-rt-transports-http</artifactId><version>3.5.1</version></dependency><dependency><groupId>org.apache.cxf</groupId><artifactId>cxf-rt-frontend-jaxws</artifactId><version>3.5.1</version></dependency><!--hutool--><dependency><groupId>cn.hutool</groupId><artifactId>hutool-all</artifactId><version>5.8.12</version></dependency><!--fastjson--><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>2.0.16</version></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><configuration><excludes><exclude><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></exclude></excludes></configuration></plugin></plugins></build></project>

服务端YML

server: # 必须配置端口，客户端需要port: 7001

FileCxfConfig

该文件为WebService服务暴露配置文件

package com.example.webservice.config;import com.example.webservice.service.FileCxfService;
import com.example.webservice.service.impl.FileCxfServiceImpl;
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;@Configuration
public class FileCxfConfig {@Bean(name = Bus.DEFAULT_BUS_ID)public SpringBus springBus() {return new SpringBus();}@Bean(name = "downloadFileBean")public ServletRegistrationBean dispatcherServlet() {ServletRegistrationBean wbsServlet = new ServletRegistrationBean(new CXFServlet(), "/file/*");return wbsServlet;}@Beanpublic FileCxfService fileCxfService() {return new FileCxfServiceImpl();}@Beanpublic Endpoint endpointPurchase(SpringBus springBus, FileCxfService fileCxfService) {EndpointImpl endpoint = new EndpointImpl(springBus(), fileCxfService());endpoint.publish("/download");System.err.println("服务发布成功！地址为：http://localhost:7001/file/download?wsdl");return endpoint;}}

FileCxfService

该类指定了暴露的服务接口，注意类中的注解都很重要，不能丢，具体可以看说明

package com.example.webservice.service;import javax.jws.WebMethod;
import javax.jws.WebParam;
import javax.jws.WebResult;
import javax.jws.WebService;
import javax.xml.ws.BindingType;@BindingType(value = "http://www.w3.org/2003/05/soap/bindings/HTTP/")
@WebService(serviceName = "FileCxfService", // 与接口中指定的name一致targetNamespace = "http://webservice.example.com" // 与接口中的命名空间一致,一般是接口的包名倒
)
public interface FileCxfService {@WebMethod(operationName = "downloadFile")@WebResult(name = "String")String downloadFile(@WebParam(name = "params", targetNamespace = "http://webservice.example.com") String params,@WebParam(name = "token", targetNamespace = "http://webservice.example.com") String token);}

FileCxfServiceImpl

该类指定了暴露的服务接口的具体实现，注意类中的注解都很重要，不能丢，具体可以看说明

package com.example.webservice.service.impl;import cn.hutool.core.codec.Base64;
import com.alibaba.fastjson2.JSONObject;
import com.example.webservice.pojo.FileDto;
import com.example.webservice.service.FileCxfService;import javax.jws.WebService;@WebService(serviceName = "FileCxfService", // 与接口中指定的name一致targetNamespace = "http://webservice.example.com" // 与接口中的命名空间一致,一般是接口的包名倒
)
public class FileCxfServiceImpl implements FileCxfService {@Overridepublic String downloadFile(String params, String token) {//下载文件System.err.println("params : " + params);FileDto fileDto = JSONObject.parseObject(params, FileDto.class);System.err.println("fileDto : " + fileDto);String data = null;try {data = Base64.encode("C:\\Users\\YIQI\\Desktop\\ebook\\Java70.pdf");} catch (Exception e) {e.printStackTrace();}System.err.println(data);return data;}}

FileDto

该类为参数实体类，用于接受客户端传来的参数

package com.example.webservice.pojo;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.ToString;@Data
@AllArgsConstructor
@ToString
public class FileDto {private String fileId;private String newFileId;private String bucketName;}

客户端

在SpringBoot中整合WebService的客户端，需要指定服务端暴露的服务接口

项目结构

image-20230727184202714

配置

客户端POM

<?xml version="1.0" encoding="UTF-8"?>
<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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.7.3</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.example</groupId><artifactId>webclient</artifactId><version>0.0.1-SNAPSHOT</version><name>webclient</name><description>webclient</description><properties><java.version>17</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!--cxf--><dependency><groupId>org.apache.cxf</groupId><artifactId>cxf-rt-transports-http</artifactId><version>3.5.1</version></dependency><dependency><groupId>org.apache.cxf</groupId><artifactId>cxf-rt-frontend-jaxws</artifactId><version>3.5.1</version></dependency><!--hutool--><dependency><groupId>cn.hutool</groupId><artifactId>hutool-all</artifactId><version>5.8.12</version></dependency><!--fastjson--><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>2.0.16</version></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><configuration><excludes><exclude><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></exclude></excludes></configuration></plugin></plugins></build></project>

客户端YML

server: # 可以不配置port: 1000

FileCxfService

这个文件和服务端的FileCxfService保持一致，用于指定客户端请求的方式

package com.example.webclient.service;import javax.jws.WebParam;
import javax.jws.WebService;@WebService(name = "FileCxfService", // 暴露服务名称targetNamespace = "http://webservice.example.com"// 命名空间,一般是接口的包名倒序
)
public interface FileCxfService {String downloadFile(@WebParam(name = "data", targetNamespace = "http://webservice.example.com") String data,@WebParam(name = "token", targetNamespace = "http://webservice.example.com") String token);}

FileCxfClient

这个类是客户端的主类，里面有发送WebService请求的方法

package com.example.webclient.client;import cn.hutool.core.codec.Base64;
import com.alibaba.fastjson2.JSONObject;
import com.example.webclient.pojo.FileDto;
import com.example.webclient.service.FileCxfService;
import com.example.webclient.util.ConvertBASE64;import javax.xml.bind.DatatypeConverter;
import javax.xml.namespace.QName;
import javax.xml.ws.Service;
import java.net.URL;public class FileCxfClient {public static void main(String[] args) throws Exception {// 创建wsdl的urlURL url = new URL("http://localhost:7001/file/download?wsdl");// 指定命名空间和服务名称QName qName = new QName("http://webservice.example.com", "FileCxfService");Service service = Service.create(url, qName);// 通过getPort方法返回指定接口FileCxfService myServer = service.getPort(FileCxfService.class);// 调用方法返回数据FileDto fileDto = new FileDto();fileDto.setFileId("1");fileDto.setNewFileId("1");fileDto.setBucketName("book");String params = JSONObject.toJSONString(fileDto);Long st = System.currentTimeMillis();String file = myServer.downloadFile(params, "TOKEN:ABC");// 解析文件到本地// 可以解析成字节数组，如果服务端返回的也是字节数组的话byte[] decode= Base64.decode(file);// 也可以将Base64写入到本地文件中ConvertBASE64.decoderBase64File(file, "C:\\Users\\YIQI\\Desktop\\ebook\\demo70.pdf");System.err.println("decode : " + decode.toString());System.err.println("result get file success!");System.err.println("cost time : " + (System.currentTimeMillis() - st) / 1000 + " s.");}}

FileDto

这个类是封装请求参数的实体类，和服务端的FileDto保持一致

package com.example.webclient.pojo;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
public class FileDto {private String fileId;private String newFileId;private String bucketName;}

ConvertBASE64

该类是Base64工具类，可以完成Base64字符串和文件的互换

package com.example.webclient.util;import cn.hutool.core.codec.Base64Decoder;
import cn.hutool.core.codec.Base64Encoder;
import cn.hutool.core.io.FileUtil;
import com.alibaba.fastjson2.JSONObject;import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;public class ConvertBASE64 {/*** 将文件转成base64编码字符串** @param path* @return* @throws Exception*/public static String encodeBase64File(String path) throws Exception {File file = new File(path);FileInputStream inputFile = new FileInputStream(file);byte[] buffer = new byte[(int) file.length()];inputFile.read(buffer);inputFile.close();return new Base64Encoder().encode(buffer);}/*** 将base64编码字符串转成文件** @param base64Code* @param targetPath* @throws Exception*/public static void decoderBase64File(String base64Code, String targetPath)throws Exception {byte[] buffer = Base64Decoder.decode(base64Code);FileOutputStream out = new FileOutputStream(targetPath);out.write(buffer);out.close();}/*** 将base64字节装成文件** @param base64Code* @param targetPath* @throws Exception*/public static void toFile(String base64Code, String targetPath)throws Exception {byte[] buffer = base64Code.getBytes();FileOutputStream out = new FileOutputStream(targetPath);out.write(buffer);out.close();}public static String toJson(Object obj) {return JSONObject.toJSONString(obj);}public static Object toObject(String JSONString, Class cls) {return JSONObject.parseObject(JSONString, cls);}public static void writeByteArrayToFile(File desFile, byte[] data)throws IOException {FileUtil.writeBytes(data, desFile);}public static byte[] readFileToByteArray(File srcFile)throws IOException {return FileUtil.readBytes(srcFile);}public static String encode(String string) {return new String(Base64Encoder.encode(string.getBytes()));}public static void main(String[] args) {try {String a = encodeBase64File("C:\\Users\\YIQI\\Desktop\\工作文件\\bg2.jpg");// String base64Code = encodeBase64File("D:/0101-2011-qqqq.tif");System.out.println(a);decoderBase64File(a, "C:\\Users\\YIQI\\Desktop\\工作文件\\bg3.jpg");// toFile(base64Code, "D:\\three.txt");} catch (Exception e) {e.printStackTrace();}}}

测试

先启动服务端，可以看到对外发布的服务

image-20230727190423700

在启动客户端给服务端发送请求的方法，可以看到服务端返回的数据

image-20230727190539581

因为我把从服务端获取的文件写入到了本地，所以可以在文件目录中看到该文件

image-20230727190638111

http://www.lryc.cn/news/106053.html

相关文章：

  • 【LangChain】向量存储之FAISS
  • 小研究 - 主动式微服务细粒度弹性缩放算法研究（三）
  • 驱动开发相关内容复盘
  • 2.2 身份鉴别与访问控制
  • C++ 注释
  • Spring事务（声明式事务）（Spring的事务，Spring隔离级别，事务传播机制）
  • Linux运维面试题（四）之Linux服务管理
  • ChatGPT能否撰写科研论文？
  • 2023 电赛 E 题 K210方案
  • 网络知识介绍
  • MapStruct设置全局的ComponentModel
  • LinearAlgebraMIT_6_ColumnSpaceAndNullSpace
  • 出版物经营许可办理 出版物许可地址变更 出版物零售延期
  • 【LeetCode每日一题】——807.保持城市天际线
  • JavaScript--Date（日期）对象
  • 一文讲清多线程与多线程同步
  • 《Java-SE-第二十六章》之线程池
  • 【数据库】将excel数据导入mysql数据库
  • 无涯教程-Lua - repeat...until 语句函数
  • 环形链表 LeetCode热题100
  • 使用python将每组两行数据合并一行
  • 14-1_Qt 5.9 C++开发指南_网络编程及主机信息查询_HostInfo
  • 【iOS】通知原理
  • 创建邮件服务器（小微企业）
  • android app控制ros机器人四（调整界面布局）
  • 稍微深度踩坑haystack + whoosh + jieba
  • 微信小程序(van-tabs) 去除横向滚动条样式(附加源码解决方案+报错图)
  • 激光切割机所发出的辐射是否会对人体产生危害呢
  • Redis 高可用：主从复制、哨兵模式、集群模式
  • 在GitHub上管理和协作的完全指南