从Spring调试服务器发送的事件

Question

从Spring调试服务器发送的事件

Mar*_*pel 7 java spring project-reactor spring-webflux

根据Spring文档，当返回a时Flux，Spring应该为订阅返回的每个元素发出一个服务器发送的事件。

这是一个示例性的REST控制器：

package myapp.controller;

import myapp.MyOutput;

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiResponse;
import io.swagger.annotations.ApiResponses;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;

@RestController
@RequestMapping("/api/v1/test")
@Api(tags = "Test API")
public class TestController {

    @ApiOperation(
        value = "Test",
        response = MyOutput.class,
        produces = MediaType.TEXT_EVENT_STREAM_VALUE
    )
    @RequestMapping(
        value = "",
        method = RequestMethod.PATCH,
        produces = MediaType.TEXT_EVENT_STREAM_VALUE
    )
    @ApiResponses(
        value = {
            @ApiResponse(code = 200, message = "Service execution successful"),
            @ApiResponse(code = 400, message = "Bad input data"),
            @ApiResponse(code = 500, message = "An internal server error occurred."),
            @ApiResponse(code = 503, message = "The service is not available.")
        }
    )
    public ResponseEntity<Flux<MyOutput>> test() {
        return ResponseEntity.ok().header("Connection", "Keep-Alive")
            .body(Flux.range(0, 1000)
                .delayElements(Duration.ofSeconds(1))
                .map(MyOutput::new)
            );
    }
}

Run Code Online (Sandbox Code Playgroud)

使用wget的示例响应：

data:{"recordCount":0}

data:{"recordCount":148}

data:{"recordCount":226}

data:{"recordCount":266}

data:{"recordCount":272}

data:{"recordCount":286}

data:{"recordCount":287}

data:{"recordCount":293}

data:{"recordCount":294}

Run Code Online (Sandbox Code Playgroud)

使用Chrome或Postman调试端点时，客户端似乎将事件解释为分块响应的一部分，而不是事件流。我已经确认响应数据是相同的，并且需要预期的时间。在下面的“ Chrome网络”标签中查看屏幕截图：

EventStream-选项卡为空：

将此与http://www.emojitracker.com/等网站的标题进行比较：

EventStream选项卡正确显示事件的位置：

重要的事实是，当在Spring端点上使用a时WebClient，我可以在使用预期的时间成功接收到每个事件.bodyToFlux。因此，事件似乎缺少了Chrome从服务器发送的事件流中期望的某种形式的配置-但是哪一个呢？

Answer 1

JEY*_*JEY 9

首先在浏览器中使用EventSource时会执行GET请求，因此使用PATCH在浏览器中并不真正兼容。

如果我们获取您的代码并更改 GET 中的 PATCH，我们将创建一个简单的页面：

<html lang="fr">
    <head>
        <title>Test SSE</title>
        <script>
            const evtSource = new EventSource("/api/v1/test");
            evtSource.onmessage = function(event) {
                const newElement = document.createElement("li");
                const eventList = document.getElementById("results");
                newElement.textContent = "message: " + event.data;
                eventList.appendChild(newElement);
            }
        </script>
    </head>
    <body>
        <ul id="results">

        </ul>
    </body>
</html>

Run Code Online (Sandbox Code Playgroud)

让您的应用程序提供此静态文件并在 Chrome 中打开它。您将在“事件”选项卡中正确地看到事件。但是，如果您直接请求 /api/v1/test ，您将在页面中而不是在“事件”选项卡中执行此事件。我认为事件选项卡会拦截 EventSource 对象，并且如果未创建 EventSource，则不会使用事件选项卡。

归档时间：	6 年前
查看次数：	120 次
最近记录：	5 年，11 月前