我正在尝试实现一个服务器客户端项目，该项目需要服务器每5分钟向客户端发送一次数据，客户端只在连接开始时询问。服务器发送的事件似乎是首选解决方案。
我试图使用Javalin文档中给出的函数。我能够从服务器获得一个简单的get响应。但我无法建立一个sse连接。代码在服务器中输入lambda函数，但客户端没有收到任何内容。我不确定客户端或服务器，甚至两者都有问题。我们从下面的代码得到的唯一输出是在服务器端“连接”。先感谢您。
服务器代码
import io.javalin.Javalin;
public class SimpleTwitter {
public static void main(String[] args) {
Javalin app = Javalin.create().start(7000);
app.sse("/sse", client ->{
System.out.println("connected");
client.sendEvent("message","Hello, SSE");
client.onClose(() -> System.out.println("Client disconnected"));
});
app.get("/", ctx -> ctx.result("Hello World"));
}
}
客户代码
<!DOCTYPE html>
<html>
<body>
<h1>Getting server updates</h1>
<div id="result"></div>
<script>
if(typeof(EventSource) !== "undefined") {
var source = new EventSource("http://localhost:7000/sse");
source.onmessage = function(event) {
document.getElementById("result").innerHTML += event.data + "<br>";
};
} else {
document.getElementById("result").innerHTML = "Sorry, your browser does not support server-sent events...";
}
</script>
</body>
</html>
原来问题不在于代码。通过查看chrome上的开发人员工具，我们看到了以下内容：
“来自'http://localhost:7000/sse'的资源从origin'null'访问已被CORS策略阻止：请求的资源上没有'Access-Control-Allow-Origin'标头。”
当我们安装名为“Allow-Control-Allow-Origin：*”的chrome扩展时，我们能够看到输出。
此外，这里是更新的更好的工作代码：
> <<!DOCTYPE html> <html> <body>
>
> <h1>Tweets</h1>
>
> <script> new
> EventSource('http://localhost:7000/sse').addEventListener( "hi", msg
> =>{ document.write(msg.data); }); </script>
>
> </body> </html>
...
public static void main(String[] args) throws InterruptedException {
Queue<SseClient> clients = new ConcurrentLinkedQueue<>();
Javalin app = Javalin.create().start(7000);
app.sse("/sse", client -> {
clients.add(client);
client.onClose(() -> clients.remove(client));
});
while (true) {
for (SseClient client : clients) {
client.sendEvent("hi", "hello world");
}
TimeUnit.SECONDS.sleep(1);
}
}