前言

非阻塞、响应式HTTP客户端

1、创建webClient

WebClient client = WebClient.create();

2、准备数据

        Map<String,String> params = new HashMap<>();
        params.put("area","西安");

3、执行请求

        Mono<String> mono = client.get()
                .uri("要请求的接口")
                .accept(MediaType.APPLICATION_JSON)  //定义响应的内容类型，以json格式赶回
                .header("Authorization","APPCODE 93b7e19861a24c519a7548b17dc46d75")
                .retrieve()
                .bodyToMono(String.class)
        return mono;
    }

4、接收返回响应到的数据

    @GetMapping("/weather")
    public Mono<String> weather(@RequestParam("city") String city){
//        查询天气
        Mono<String> weather = weatherService.weather(city);
        return weather;
    }

整体代码

package com.atguigu.boot305ssm.service;

import org.springframework.http.MediaType;
import org.springframework.stereotype.Service;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;

import java.util.HashMap;
import java.util.Map;

/**
 * @author jitwxs
 * @date 2024年03月03日 10:15
 */
@Service
public class WeatherService {
    public Mono<String> weather(String city){
//        远程调用api

//        创建webClient
        WebClient client = WebClient.create();

//        准备数据
        Map<String,String> params = new HashMap<>();
        params.put("area","西安");

//       定义发送请求行为
        Mono<String> mono = client.get()
                .uri("要请求的接口")
                .accept(MediaType.APPLICATION_JSON)  //定义响应的内容类型，以json格式赶回
                .header("Authorization","APPCODE 93b7e19861a24c519a7548b17dc46d75")
                .retrieve()
                .bodyToMono(String.class)
        return mono;
    }
}