SpringBoot中的webFlux的使用

￡神魔★判官ぃ 2023-02-25 08:33 33阅读 0赞

@GetMapping("/test")
        public void test(HttpServletRequest httpServletRequest) throws Exception {
            AsyncContext asyncContext = httpServletRequest.startAsync();
            long startTime = System.currentTimeMillis();
            CompletableFuture.runAsync(()->{
                try {
                    TimeUnit.SECONDS.sleep(5);
                    asyncContext.complete();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
            System.out.println(System.currentTimeMillis() - startTime);
            asyncContext.getResponse().getWriter().write("hello");
        }

Mono的用法：

@GetMapping("/test")
        public Mono<String> test() throws Exception {
            log.info("test");
            Mono<String> stringMono = Mono.fromSupplier(() -> {
                try {
                    TimeUnit.SECONDS.sleep(5);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                return "hello,world!!!";
            });
            log.info("test");
            return stringMono;
        }

Flux的用法：（自动推送数据到前端）

@GetMapping(value = "/flux",produces = MediaType.TEXT_EVENT_STREAM_VALUE)
        public Flux<String> flux() throws Exception {
            return Flux.interval(Duration.ofMillis(1000)).map(i -> i + "");
        }

client端：

$(function () {
            let eventSource = new EventSource("https://localhost:81/flux");
            eventSource.onopen = function (event) {
                console.dir("eventSource opened");
            };
    
            eventSource.onmessage = function (event) {
                console.dir(event);
            };
    
            eventSource.onerror = function (event) {
                console.dir("eventSource error");
            };
    eventSource.addEventListener("Event_Text",function (event) {
                console.log(event.data);
            });
        });

![20200711171418560.png][]

[20200711171418560.png]: /images/20230209/8513164eae15431aaf6d6f18d4545b3e.png