springboot webflux webclient 使用示例

曾经终败给现在 2023-02-20 04:47 8阅读 0赞

--------------------

### springboot webflux webclient 使用示例 ###

### \*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\* ###

**示例**

**HelloController**

@RestController
    public class HelloController {
    
        @RequestMapping("/hello")
        public Map<String,String> hello(ServerWebExchange exchange){
            exchange.getRequest().getHeaders().forEach((key,value) ->{
                System.out.println(key+" ==> "+value);
            });
    
            Map<String,String> map=new HashMap<>();
            map.put("info","hello world");
    
            return map;
        }
    
        @RequestMapping("/hello2/{name}")
        public String hello2(@PathVariable("name") String name){
            return "hello "+name;
        }
    
        @RequestMapping("/hello3")
        public String hello3(String name){
            return "hello "+name;
        }
    
        @RequestMapping("/hello4")
        public Person hello4(String name,Integer age){
            Person person=new Person();
            person.setName(name);
            person.setAge(age);
    
            System.out.println(name+"  "+age);
            return person;
        }
    
        @RequestMapping("/hello5")
        public Mono<Person> hello5(ServerWebExchange exchange){
            return exchange.getFormData().flatMap(map -> {
                Person person=new Person();
                person.setName(map.getFirst("name"));
                person.setAge(Integer.parseInt(Objects.requireNonNull(map.getFirst("age"))));
    
                return Mono.just(person);
            });
        }
    
        @RequestMapping("/hello6")
        public Person hello6(@RequestBody Person person){
            System.out.println(person);
    
            return person;
        }
    
        @RequestMapping("/hello8")
        public String hello8(ServerWebExchange exchange){
            exchange.getRequest().getHeaders().forEach((key,value) -> {
                System.out.println(key+" ==> "+value);
            });
    
            return "success";
        }
    
    }

**Hello2Controller**

@RestController
    public class Hello2Controller {
    
        @RequestMapping("/test")
        public Mono<String> hello(){
            System.out.println("test");
    
            return WebClient.create().get().uri("http://localhost:8080/hello")
                    .retrieve().bodyToMono(String.class);
        }
    
        @RequestMapping("/test2")
        public Mono<String> hello2(){
            System.out.println("test2");
    
            return WebClient.create().get().uri("http://localhost:8080/hello2/{name}","瓜田李下")
                    .retrieve().bodyToMono(String.class);
        }
    
        @RequestMapping("/test3")
        public Mono<String> hello3(){
            System.out.println("test3");
    
            Map<String,String> params=new HashMap<>();
            params.put("name","瓜田李下");
    
            return WebClient.create().get().uri("http://localhost:8080/hello2/{name}",params)
                    .retrieve().bodyToMono(String.class);
        }
    
        @RequestMapping("/test4")
        public Mono<String> hello4(){
            System.out.println("test4");
    
            return WebClient.create().get().uri("http://localhost:8080/hello3?name={name}","瓜田李下")
                    .retrieve().bodyToMono(String.class);
        }
    
        @RequestMapping("/test5")
        public Mono<String> hello5(){
            System.out.println("test5");
    
            Map<String,String> params=new HashMap<>();
            params.put("name","瓜田李下");
    
            return WebClient.create().get().uri("http://localhost:8080/hello3?name={name}",params)
                    .retrieve().bodyToMono(String.class);
        }
    
        @RequestMapping("/test6")
        public Mono<Person> test6(){
            System.out.println("test6");
    
            Map<String,String> params=new HashMap<>();
            params.put("name","瓜田李下");
            params.put("age","20");
    
            return WebClient.create().get().uri("http://localhost:8080/hello4?name={name}&age={age}",params)
                    .retrieve().bodyToMono(Person.class);
        }
    
        @RequestMapping("/test7")
        public Mono<Person> hello7(){
            System.out.println("test7");
    
            return WebClient.create().post().uri("http://localhost:8080/hello5")
                    .body(BodyInserters.fromFormData("name","瓜田李下").with("age","20"))
                    .retrieve().bodyToMono(Person.class);
        }
    
        @RequestMapping("/test8")
        public Mono<Person> hello8(){
            System.out.println("test8");
    
            return WebClient.create().post().uri("http://localhost:8080/hello5")
                    .body(BodyInserters.fromFormData("name","瓜田李下").with("age","20"))
                    .exchange().flatMap(response -> response.bodyToMono(Person.class));
        }
    
        @RequestMapping("/test9")
        public Mono<String> hello9(){
            System.out.println("test9");
    
            Person person=new Person();
            person.setName("瓜田李下");
            person.setAge(20);
    
            return WebClient.create().post().uri("http://localhost:8080/hello6")
                    .body(Mono.just(person),Person.class)
                    .retrieve().bodyToMono(String.class);
        }
    
        @RequestMapping("/test10")
        public Mono<String> hello10(){
            System.out.println("test10");
    
            return WebClient.create().get().uri("http://localhost:8080/hello8")
                    .headers(headers -> headers.add("custom","custom header"))
                    .retrieve().bodyToMono(String.class);
        }
    }

## ##

### \*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\* ###

**使用测试**

**localhost:8080/test，输出**

![20200623195359352.png][]

**localhost:8080/test2，输出：hello 瓜田李下**

**localhost:8080/test3，输出：hello 瓜田李下**

**localhost:8080/test4，输出：hello 瓜田李下**

**localhost:8080/test5，输出：hello 瓜田李下**

**localhost:8080/test6，输出**

![20200623201337837.png][]

**localhost:8080/test7，输出**

![20200623201343783.png][]

**localhost:8080/test8，输出**

![20200623201343783.png][]

**localhost:8080/test9，输出**

![20200623201343783.png][]

**localhost:8080/test10，控制台输出**

test10
    accept-encoding ==> [gzip]
    user-agent ==> [ReactorNetty/0.9.8.RELEASE]
    host ==> [localhost:8080]
    accept ==> [*/*]
    custom ==> [custom header]

**自定义header添加成功**

[20200623195359352.png]: https://img-blog.csdnimg.cn/20200623195359352.png
[20200623201337837.png]: https://img-blog.csdnimg.cn/20200623201337837.png
[20200623201343783.png]: https://img-blog.csdnimg.cn/20200623201343783.png