SpringBoot-第十五章 高级篇幅之SpringBoot2.0响应式编程

 

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

 

public class User {
    public User(String id,String name)
    {
        this.id=id;
        this.name=name;
    }
    private String id;
    private String name;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

 

@Service
public class UserService {
    private static final Map<String,User> userMap = new HashMap<String,User>();
    static
{
        userMap.put("1",new User("a1","kevin1"));
        userMap.put("2",new User("a2","kevin2"));
        userMap.put("3",new User("a3","kevin3"));
        userMap.put("4",new User("a4","kevin4"));
        userMap.put("5",new User("a5","kevin5"));
    }

    public Flux<User> list()
    {
       return Flux.fromIterable(userMap.values()).delayElements(Duration.ofSeconds(1));
    }
    public Mono<User> findById(String id)
    {
        return Mono.justOrEmpty(userMap.get(id));
    }
    public Mono<User> del(String id)
    {
        return Mono.justOrEmpty(userMap.remove(id));
    }

}

@RestController
@RequestMapping("/user")
public class UserController {

    @Autowired
private UserService userService;
    @RequestMapping(value = "/list",produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
    public Flux<User> list()
    {
        return userService.list();
    }
    @RequestMapping("/find")
    public Mono<User> findById(String id)
    {
        return userService.findById(id);
    }
    @RequestMapping("/del")
    public Mono<User> del(String id)
    {
        return userService.del(id);
    }
}

 

public class WebClientTest {
    @Test
public void test()
    {
        Flux<String> userFlux = WebClient.create().get().
                uri("http://localhost:8080/user/list").
                accept(MediaType.APPLICATION_STREAM_JSON).retrieve().bodyToFlux(String.class);
        System.out.println(userFlux.blockLast());
    }

    @Test
public void test1()
    {
        Mono<String> userMono = WebClient.create().get().
                uri("http://localhost:8080/user/find?id={id}",1).
                accept(MediaType.APPLICATION_JSON).retrieve().bodyToMono(String.class);
        System.out.println(userMono.block());
    }
}