Spring Web Flux Websocket push после того, как данные получили существующий ресурс - PullRequest
Новая
       14

Spring Web Flux Websocket push после того, как данные получили существующий ресурс

0 голосов
/ 28 сентября 2018 
package org.springframework.webflux.websocket.webfluxwebsocketdemo;

import java.net.URISyntaxException;
import java.time.Duration;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.reactive.HandlerMapping;
import org.springframework.web.reactive.handler.SimpleUrlHandlerMapping;
import org.springframework.web.reactive.socket.WebSocketHandler;
import org.springframework.web.reactive.socket.server.support.WebSocketHandlerAdapter;

import reactor.core.publisher.Flux;

@SpringBootApplication
@RestController
public class WebFluxWebSocketDemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(WebFluxWebSocketDemoApplication.class, args);
    }

    @GetMapping(path = "/pushData")
    public void getRemoteStreaming( @RequestParam("message") String message ) throws URISyntaxException {



    }


    @Bean
    public HandlerMapping webSocketMapping() {
        Map<String, WebSocketHandler> map = new HashMap<>();

        map.put("/echo", session -> session.send(
            Flux.<String>generate(sink -> sink.next(String.format("{ message: 'got local message', date: '%s' }", new Date())))
                .delayElements(Duration.ofSeconds(1)).map(session::textMessage)));

        SimpleUrlHandlerMapping mapping = new SimpleUrlHandlerMapping();
        mapping.setUrlMap(map);
        mapping.setOrder(1);
        return mapping;
    }

    @Bean
    public WebSocketHandlerAdapter handlerAdapter() {
        return new WebSocketHandlerAdapter();
    }

}

Приведенный выше код будет отправлять сообщение каждую секунду клиенту веб-сокета "{сообщение: 'получено локальное сообщение', дата: 'вт 02 окт. 11:34:17 IST 2018'}"

Нокак мы отправляем сообщение всякий раз, когда я получаю данные от ресурса «pushData», тогда я должен передать его клиенту websocket.

...