SpringBoot3 实现webclient 通用方法 - ToB企服应用市场:ToB评测及商务社交产业平台

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.0.0</version>
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-tomcat</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
</dependencies>

复制代码

package com.zc.util;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.client.WebClient;
import java.util.List;
/**
* @author zc
* @date 2024/4/15 16:52
* @desc
*/
@Component
public class WebClientUtil {
private final WebClient webClient;
@Autowired
public WebClientUtil(WebClient.Builder webClientBuilder) {
this.webClient = webClientBuilder.
baseUrl("http://127.0.0.1:30003").
build();
}
/**
* get方法
* @param url
* @param responseType
* @return
* @param
*/
public <T> T get(String url, Class<T> responseType) {
return webClient.get().
uri(url).
accept(MediaType.APPLICATION_JSON).
retrieve().
bodyToMono(responseType).
block();
}
/**
* get多条数据
* @param url
* @param responseType
* @return
* @param <T>
*/
public <T> List<T> list(String url, Class<T> responseType){
return webClient.get().
uri(url).
accept(MediaType.APPLICATION_JSON).
retrieve().
bodyToFlux(responseType).collectList().block();
}
/**
* post方法
* @param url
* @param requestBody
* @param responseType
* @return
* @param
*/
public <T> T post(String url, Object requestBody, Class<T> responseType) {
return webClient.post().
uri(url).
contentType(MediaType.APPLICATION_JSON).
bodyValue(requestBody).
accept(MediaType.APPLICATION_JSON).
retrieve().
bodyToMono(responseType).
block();
}
/**
* put方法
* @param url
* @param requestBody
* @param responseType
* @return
* @param
*/
public <T> T put(String url, Object requestBody, Class<T> responseType){
return webClient.put().
uri(url).
contentType(MediaType.APPLICATION_JSON).
bodyValue(requestBody).
accept(MediaType.APPLICATION_JSON).
retrieve().
bodyToMono(responseType).
block();
}
/**
* 删除方法
* @param url
* @param responseType
* @return
* @param
*/
public <T> T delete(String url, Class<T> responseType){
return webClient.delete().
uri(url).
accept(MediaType.APPLICATION_JSON).
retrieve().
bodyToMono(responseType).
block();
}
}

复制代码

import com.alibaba.fastjson.JSON;
import com.zc.Application;
import com.zc.bean.HostDiffBean;
import com.zc.util.WebClientUtil;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import java.util.Date;
import java.util.List;
/**
* @author zc
* @date 2024/2/23 10:40
* @desc
*/
@SpringBootTest(classes = Application.class)
public class TestFF {
@Autowired
private WebClientUtil webClientUtil;
@Test
public void test(){
List<HostDiffBean> list= webClientUtil.list("compare/hostInfo?pageSize=10&pageNum=1", HostDiffBean.class);
System.out.println(JSON.toJSON(list));
HostDiffBean hostDiffBean = new HostDiffBean();
hostDiffBean.setIp("127.0.0.1");
hostDiffBean.setHIp("127.0.0.2");
hostDiffBean.setCreateTime(new Date());
hostDiffBean.setSerialNumber("123");
hostDiffBean.setHDeviceNo("no123");
hostDiffBean.setDeviceNo("NO456");
String result = webClientUtil.post("compare/hostInfo/add", hostDiffBean, String.class);
System.out.println(result);
}
}

复制代码

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.neusoft.bean.*;
import com.neusoft.service.HostDataCompareService;
import io.swagger.annotations.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* @author zc
* @date 2024/3/14 15:00
* @desc
*/
@RestController
@RequestMapping("/compare")
@Api(value = "数据对比接口", tags = "数据对比接口")
public class DataCompareController {
@Autowired
private HostDataCompareService hostDataCompareService;
@GetMapping("/hostInfo")
@ApiOperation(value = "宿主机数量差异查询", notes = "宿主机数量差异查询")
public List<HostInfoBean> getHostInfoBeans(@RequestParam(name = "pageSize") @Validated @ApiParam(value = "每页数", required = true) Integer pageSize,
@RequestParam(name = "pageNum") @Validated @ApiParam(value = "页数", required = true) Integer pageNum) {
Page<HostInfoBean> list = hostDataCompareService.getHostInfoBeans(pageSize, pageNum);
return list.getRecords();
}
@PostMapping("/hostInfo/add")
@ApiOperation(value = "宿主机数量差异查询", notes = "宿主机数量差异查询")
public String addHostInfoBeans(@RequestBody HostDiffBean hostDiffBean){
return "success";
}
}

复制代码