我可以在Java中订阅SseEmitter吗
在Java中，SseEmitter 是 Spring 框架提供的一种用于服务器发送事件（Server-Sent Events, SSE）的机制。SSE 是一种允许服务器向客户端推送实时更新的技术，通常用于实时通知、消息推送等场景。
SseEmitter 主要用于在服务器端推送事件到客户端。客户端可以使用 JavaScript 的 EventSource 对象来接收这些事件。
如何在Java中使用 SseEmitter
以下是一个简单的示例，展示如何在 Spring Boot 应用中使用 SseEmitter 来实现服务器发送事件。
1. 添加依赖
首先，确保你的项目中包含 Spring Boot 相关的依赖。如果你使用 Maven，可以在 pom.xml 中添加以下依赖：
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
</dependencies>2. 创建控制器
创建一个 Spring 控制器来处理 SSE 连接和事件推送。
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
@RestController
public class SseController {
@GetMapping("/sse")
public SseEmitter handleSse() {
SseEmitter emitter = new SseEmitter();
ExecutorService executor = Executors.newSingleThreadExecutor();
executor.execute(() -> {
try {
for (int i = 0; i < 10; i++) {
emitter.send("Message " + i);
TimeUnit.SECONDS.sleep(1);
}
emitter.complete();
} catch (IOException | InterruptedException e) {
emitter.completeWithError(e);
}
});
return emitter;
}
}在这个示例中，/sse 端点会返回一个 SseEmitter 对象，并在一个单独的线程中每秒发送一条消息给客户端。
3. 客户端代码
在客户端，可以使用 JavaScript 的 EventSource 对象来接收服务器发送的事件。
<!DOCTYPE html>
<html>
<head>
<title>SSE Example</title>
</head>
<body>
<h1>Server-Sent Events</h1>
<div id="messages"></div>
<script>
const eventSource = new EventSource('/sse');
eventSource.onmessage = function(event) {
const newElement = document.createElement("div");
newElement.innerHTML = "Received: " + event.data;
document.getElementById("messages").appendChild(newElement);
};
eventSource.onerror = function(event) {
console.error("EventSource failed:", event);
};
</script>
</body>
</html>这个简单的 HTML 页面会连接到 /sse 端点，并显示接收到的消息。
相关·内容
我正在用Java开发一个Spring项目。我们在那里需要ServerSentEvents，使用SseEmitter看起来像是一种向客户端发送事件的简单方法。
我们还需要用Java实现客户端。我能找到的每个教程都展示了如何在Javascript中订阅发射器，而SseEmitter似乎没有任何订阅方法。有人知道如何在Java中监听传入的事件吗？
浏览 48提问于2021-03-07得票数 2
2回答
我不熟悉Server Sent Events，但不熟悉Spring。我做了一个控制器，它由UI上的一个按钮触发，该按钮启动SSEEmitter并将其传递给另一个线程，该线程在循环中每隔4秒向UI发送消息。到目前为止，我正在运行一个10的循环，每个循环休眠4秒，但是突然在6或7次循环的迭代中，我得到了异常"Exception in thread "Thread-4“java.lang.IllegalStateExce
浏览 0提问于2016-03-30得票数 3
3回答
为群集环境创建列表
、、、、
在我的应用程序中，有一个列表publisherPostListenerList，它接收来自RabbitMQ队列的实时用户发布，然后发送给订阅者/消费者。下面的控制器方法通过getter方法获取列表元素&基于逻辑将帖子推送给订阅者。流程如下
用户编写一个post，-> Post进入DB +队列，队列中的->消息被添加到一个列表中，这个列表是要向用户的订阅者推送的publisherPostListenerList。我<
浏览 8提问于2016-11-24得票数 4
回答已采纳
我使用spring 4.3.7.RELEASE来设置服务器发送的事件。并使用@scheduled注释每2秒发送一次消息。这是控制器。= sseEmitter) { }我是从eclipse但是过了一段时间，它停止发送消息，我在eclipse控制台中看到了下面的异常。:158)
at org.springf
浏览 7提问于2017-03-16得票数 5
4回答
角2弹簧引导服务器附带事件
、、、、
谁能给我举个春季引导服务器附带事件的例子吗？public class SSEController {
@RequestMapping(path = "/stream", metho
浏览 0提问于2016-12-06得票数 16
回答已采纳
1回答
我的服务器端是spring，我同样使用spring SseEmitter。
我根据客户端的特定用户事件打开一个新的SSE连接。我可以看到请求到达服务器，SSE事件被记录下来，我可以看到响应也被创建了。我想以json的身份给你回复。我基本上是在尝试发送数据更新，并使用更新的数据创建一个json。但是SSE从来没有到达浏览器。它只提供给Eventsource.onerror方法。所以浏览器一直在
浏览 9提问于2018-01-10得票数 4
回答已采纳
1回答
SSE不同客户端接收消息
、、、
我正在用Spring编写一个信使，我希望那个在线用户可以从服务器接收消息。最好的解决方案是我找到了它的SSE，创建了这个方法，但是如果所有的活动(在线)用户都订阅了这个方法，那么服务器必须如何知道哪个用户应该接收这个消息呢？@GetMapping("/stream-sse-mvc") SseEmitter emitter = new SseEmitter<
浏览 4提问于2020-10-09得票数 0
回答已采纳
2回答
我正试图向我的网站发送通知。我的EventSource不会一直打开。它会无限期地关闭和打开。它几秒钟都不会打开。// Result to xhr polling :( }Java}}
有什么想法吗？没有任何线索，我设法做了不同的事情。我有一个No
浏览 1提问于2016-02-29得票数 1
我目前正在本地机器上运行，以进行测试，并得到以下不间断错误。应用程序本身似乎运行良好，但我的日志中充斥着这些错误。我不知道为什么..。RELEASE] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExe
浏览 2提问于2016-10-04得票数 17
回答已采纳
1回答
我正在使用sse发射器实现通知系统，1-客户端调用订阅APi，服务器创建新的ssEmtter并将其返回给客户端。SseEmitter sseEmitter = new SseEmitter(24 * 60 * 60 * 1000l);
return sseEmitter;2-在</em
浏览 19提问于2022-03-23得票数 1
我使用JHipster 3.5.0与弹簧引导和角度构建一个应用程序。我想使用服务器发送事件从后端发送更新到UI，但是我无法让它工作。final List<SseEmitter> sseEmitters = new CopyOnWriteArrayList<>();
浏览 15提问于2016-09-13得票数 1
回答已采纳
1回答
我使用SseEmitter Spring公开了一个简单的SSE端点，将所有发射器都保存在一个ConcurrentHashMap中。每个发射器的超时设置为24小时。每隔10秒我就给所有的客户发个信息。客户端订阅本机EventSource实现，侦听具有特定名称的事件。
不幸的是，我注意到每5分钟连接就会丢失并重新建立--尽管发射器的超时时间被显式设置为24小时。客户端的部分确实将其记录为错误，但是在服务器端没有任何错误。这个问题发生在Tomcat和Jetty身上。我
浏览 6提问于2022-02-21得票数 1
回答已采纳
我需要展示一个服务器发送事件的示例。我在一次春季谈话中了解到了这一点。人们在那里使用Webflux来展示反应原理。我理解了这将如何释放线程资源的部分，因为在作业完成和服务器返回响应之前，请求线程不会被阻塞。如您所见，我有一个GetMapping来<e
浏览 11提问于2018-02-12得票数 1
回答已采纳
我正在尝试使用Spring4(tomcat7，servlet-api 3.0.1)创建服务器发送的事件。@RequestMapping(value = "subscribe", method = Re
浏览 0提问于2015-12-09得票数 11
1回答
关于中的SSEEmitter，我有一个问题。下面的代码可以在中在客户机和服务器之间建立连接。我已经将SseEmitter对象的超时值设置为long的最大值。现在，出现了如下情况:我关闭浏览器中的选项卡，服务器上的sseemitter对象不关闭。服务器上有这么多的对象。这会导致内存问题。@RequestMapping(value = "/subscribe&quo
浏览 6提问于2022-01-16得票数 4
2回答
当我调用服务器上的控制器时，我试图通知一个简单的html页面。我有一个android应用程序调用我的控制器，当这件事完成时，我想通知我的网页控制器被调用了。emitter = new SseEmitter(); emitter.send("Hallokes"); }
emitter.com
浏览 1提问于2016-02-19得票数 5
回答已采纳
我在中使用服务器端事件(SSE)。每当新客户端订阅事件服务时，我都会在REST控制器上执行以下代码：emitter.onCompletion(() -(TAG + "Emitter completed."); });然后，每当需要将事件通知我执行的客户端时e
浏览 0提问于2015-12-30得票数 7
回答已采纳
嗨，当我加载页面时，SSE的第一个订阅请求运行良好。但是当SSE超时并再次订阅时，将得到503个错误。我的后端代码：@Slf4j @Autowired SseEmitter</
浏览 28提问于2022-04-24得票数 0
回答已采纳
我正在web应用程序中实现SSE事件。我的用例需要有选择地将事件发送到部分或所有订阅的客户端。我已经有了一个在服务器端/ Spring和客户端/ Angular -基于这个的实现的工作草案。现在，因为SSE需要维护连接，所以我的应用程序变得有状态，我需要以某种方式管理该状态。我唯一想到的就是将它作为Map<UserId存储在内存中，SseEmitter>是单例服务中的
浏览 3提问于2020-08-31得票数 0
1回答
我正在尝试使用Spring实现，如本所述。但是，我可以看到多个EventStream类型的请求从客户端触发并到达服务器。按照我的理解，EventSource应该发送一个HTTP请求，然后从服务器维护一个half duplex连接，使用哪个服务器将事件发送给客户机。贝娄是我正在使用的密码。服务器代码
import java.uti
浏览 6提问于2016-05-24得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
