Tengo algún método de servicio que se ejecuta durante 3 segundos. Me gustaría enviar información al cliente cuando comience el procesamiento (HTTPStatus.PROCESSING), y después (3 segundos) cuando termine (HTTPSTATUS.OK). Ahora tengo esto. No puedo darme cuenta de cómo mejorar. no funciona correctamente
Controlador
@RestController public class MainController { private ExecutorService nonBlockingService = Executors .newCachedThreadPool(); @Async @CrossOrigin @GetMapping("/sse") public SseEmitter handleSse() throws IOException, InterruptedException { SseEmitter emitter = new SseEmitter(); emitter.send(HttpStatus.PROCESSING); TestService.doSMG(); emitter.send(HttpStatus.OK); return emitter; } }Servicio
public class TestService { public static void doSMG() throws InterruptedException { TimeUnit.SECONDS.sleep(1); } }Cliente
<html> <head> <script> var sse = new EventSource('http://localhost:8080/sse'); sse.onmessage = function (evt) { var el = document.getElementById('sse'); el.appendChild(document.createTextNode(evt.data)); el.appendChild(document.createElement('br')); }; </script> </head> <body> <p id = "sse"> </p> </body> </html>Su solución actual es totalmente secuencial, lo que significa que ejecuta todo en orden. Debe devolver el SseEmitter lo antes posible y ejecutar todo lo demás en un subproceso en segundo plano.
Para ejecutar cosas en un subproceso en segundo plano, desea inyectar un TaskExecutor o, mejor aún, un AsyncTaskExecutor para que pueda enviarle tareas para su posterior ejecución (tan pronto como haya un subproceso disponible para su procesamiento).
Esto se vería algo como esto
@RestController public class MainController { private final AsyncTaskExecutor taskExecutor; public MainController(AsyncTaskExecutor taskExecutor) { this.tashExecutor=taskExecutor; } @CrossOrigin @GetMapping("/sse") public SseEmitter handleSse() throws IOException, InterruptedException { SseEmitter emitter = new SseEmitter(); taskExecutor.submit(() -> { emitter.send(HttpStatus.PROCESSING); TestService.doSMG(); emitter.send(HttpStatus.OK); }); return emitter; } } Esto ejecutará la tarea en segundo plano, mientras devuelve inmediatamente el SseEmitter .