Потребитель событий на стороне сервера из весенней загрузки

Вопрос 1-> можно ли это сделать с помощью restTemplate и каким-то образом класса SseEmitter (для потоковой передачи в пользовательский интерфейс) для потоковой передачи событий из службы-A.

Вопрос 1: Да, можно использовать поток SSE (события, отправленные сервером) из службы A с помощью RestTemplate, но это не самый эффективный подход. RestTemplate является синхронным и блокирующим, а SSE — асинхронным и неблокирующим протоколом. Однако вы все равно можете использовать RestTemplate с обходным решением для обработки SSE. Вам потребуется создать отдельный поток для непрерывного чтения из потока SSE и обработки событий. SseEmitter не совместим напрямую с RestTemplate, поскольку является частью Spring WebFlux, предназначенного для реактивного программирования.

Учитывая, что этот сервис-B представляет собой обычный MVC с интеграцией безопасности Spring. Могу ли я также использовать Webflux, чтобы оба работали?

Вопрос 2: Да, вы можете использовать Spring WebFlux вместе со Spring MVC с интеграцией Spring Security. Spring WebFlux предназначен для бесперебойной работы с Spring MVC, что позволяет постепенно переходить к реактивной архитектуре. Вы можете использовать оба приложения вместе.

есть ли какие-либо другие потенциальные решения для этого сценария.

Вопрос 3. Возможные решения для вашего сценария включают:

а. Используйте WebClient (реактивный подход). Вместо RestTemplate вы можете использовать WebClient из Spring WebFlux, который является неблокирующим и реактивным. Он лучше подходит для потребления реактивных потоков, таких как SSE.

b.Прокси-сервис: создайте отдельный сервис Spring WebFlux, который использует поток SSE из сервиса-A и предоставляет REST API. Затем ваша служба Spring MVC-B может использовать этот REST API с помощью RestTemplate.

НЕБЛОКИРУЮЩИЙ - Реактивный -SSE

@RestController
public class SSEController {

    @GetMapping(value = "/events", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<ServerSentEvent<String>> streamEvents() {
        return Flux.interval(Duration.ofSeconds(1))
                .map(sequence -> ServerSentEvent.<String>builder()
                        .id(String.valueOf(sequence))
                        .event("event")
                        .data("SSE Event #" + sequence + " at " + LocalTime.now())
                        .build());
    }
}

ЗАВИСИМОСТЬ

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

БЛОКИРОВОЧНАЯ МОДЕЛЬ SERLVET SSE

@RestController
public class SSEController {

    @GetMapping("/events")
    public SseEmitter streamEvents() {
        SseEmitter emitter = new SseEmitter();
        
        // Using a scheduled executor service to simulate periodic events
        ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
        executorService.scheduleAtFixedRate(() -> {
            try {
                // Send event data
                emitter.send(SseEmitter.event().data("SSE Event at " + LocalTime.now()));
            } catch (IOException e) {
                // Log or handle the exception
            }
        }, 0, 1, TimeUnit.SECONDS);

        // Complete the emitter after a fixed delay
        executorService.schedule(() -> {
            emitter.complete();
            executorService.shutdown();
        }, 10, TimeUnit.SECONDS);

        return emitter;
    }
}

Помимо Spring.main.web-application-type: servlet, вы можете написать следующий код для запуска другого контейнера веб-сервиса.

 SpringApplication app = new SpringApplication(Application.class);
        app.setWebApplicationType(WebApplicationType.SERVLET);
        app.run(args);

public enum WebApplicationType {
    NONE,
    SERVLET,
    REACTIVE;
}