如何通过REST将传入数据转发到Quarkus中的SSE流
通过REST将传入数据转发到Quarkus中的SSE流可以通过以下步骤实现：
- 确保你已经熟悉REST（Representational State Transfer）的概念和基本原则。REST是一种基于HTTP协议的架构风格，用于构建分布式系统。
- 首先，你需要创建一个RESTful API来接收传入的数据。可以使用任何你熟悉的编程语言和框架来实现这个API。在这个API中，你需要定义一个POST请求的接口，用于接收数据。
- 在接收到数据后，你可以使用Quarkus框架来创建一个SSE（Server-Sent Events）流。Quarkus是一个基于Java的微服务框架，可以帮助你构建高效的云原生应用。
- 在Quarkus中，你可以使用Quarkus RESTEasy Reactive扩展来处理SSE流。这个扩展提供了一组用于构建响应式RESTful API的工具和特性。
- 在你的Quarkus应用程序中，你可以创建一个专门用于接收传入数据的RESTful资源类。在这个资源类中，你可以定义一个POST请求的方法，用于接收数据并将其转发到SSE流。
- 在这个方法中，你可以使用Quarkus提供的SSE支持来向客户端发送数据。你可以使用
@SseElementType注解来指定SSE流中的数据类型，并使用@Sse注解来标记该方法为SSE流的入口点。 - 最后，你可以使用腾讯云的相关产品来部署和托管你的Quarkus应用程序。腾讯云提供了一系列云计算服务，包括云服务器、容器服务、云原生应用托管等，可以帮助你快速部署和运行你的应用程序。
总结起来，通过REST将传入数据转发到Quarkus中的SSE流的步骤包括创建RESTful API接收数据、使用Quarkus创建SSE流、使用Quarkus RESTEasy Reactive扩展处理SSE流、定义接收数据的RESTful资源类、使用腾讯云相关产品部署应用程序。这样可以实现将传入数据转发到Quarkus中的SSE流，并实现实时数据推送的功能。
腾讯云相关产品推荐：
- 云服务器（ECS）：https://cloud.tencent.com/product/cvm
- 云原生应用托管（Cloud Native Application Bundle）：https://cloud.tencent.com/product/tke
- 容器服务（TKE）：https://cloud.tencent.com/product/tke
相关·内容
在我的设置中，我希望通过SSE通道(服务器发送的事件)转发某些状态更改。状态更改是通过调用REST端点启动的。因此，我需要将传入的状态更改转发到SSE流。在Quarkus中完成此操作的最佳/最简单方法是什么。 我能想到的一种解决方案是使用EventBus (https:/&
浏览 24提问于2020-04-23得票数 2
回答已采纳
我设置了这个流，它通过http工作，但在将SSL添加到服务器后，事件流被创建，服务器抛出501 - Not implemented错误。我对此感到非常困惑，如果有人能帮助我理解这个问题和解决它的最好方法，我将非常感激。客户端通过aws elb负载均衡器向服务器发送请求，该负载均衡器从请求中剥离ssl并将请求转发到服务器。有没有可能，当负载均衡器在将请求转发到服务器之前从请求中</e
浏览 8提问于2019-11-13得票数 0
我有一些问题让SSE通过我的zuul反向代理工作 我的设置： Spring boot version: 2.1.1.RELEASEsse.onerror = (error) => {}; 如果我命中/increment端点，服务将收到递增的sse事件。) => {
console.log(event)
浏览 148提问于2018-12-18得票数 2
回答已采纳
我想保持与Google Firebase持续建立的连接，监视数据库值的变化，并能够写入数据库，并能够在相同的连接上执行两个操作。这有可能吗？因为做分开的事情他们就能工作。DZSQwLoNWAneWA9BcEfAgnelmY965pq98HF4pITU HTTP/1.1 Host: eletronica-ab6b1.firebaseio.com Accept: text/event-stream LINE FEED (3)，此时我正在监视数据库
浏览 2提问于2020-01-31得票数 0
回答已采纳
3回答
我在Quarkus中实现了一个GET方法，它应该向客户端发送大量数据。数据使用JPA/Hibernate从数据库中读取，序列化为JSON，然后发送到客户端。如果没有内存中的全部数据，如何才能有效地做到这一点呢？我尝试了以下三种可能性，但都没有成功：
使用JPA中的getResultList，并返回以列表为主体的Response。MessageBodyWr
浏览 3提问于2021-11-26得票数 0
1回答
这是一个更好的实践问题。在我的当前系统(monolith)中，一个传入的http API请求可能需要从多个后端源收集类似的结构化数据，聚合它，然后在api的响应中将数据返回给客户端。在当前的实现中，我只需使用一个线程池并行地将所有请求发送到后端源，并使用倒计时锁存器来知道所有返回的请求。我正试图找出使用reactice堆栈(如vert.x/quarkus )来转换上面描述
浏览 5提问于2022-05-23得票数 0
回答已采纳
我的菲尼克斯应用程序需要与第三方API集成，该API通过以流格式发送数据。我第一次了解SSE；SSE流看起来很像websockets，只是它们是单向的，而且简单得多。我看到了很多关于如何将SSE数据从Elixir应用程序作为服务器发送的建议(用于ex )。，，) --但我没有看到关于Elixir应用程序如何将SSE</e
浏览 2提问于2021-05-28得票数 2
在我的Angular5 / NodeJS web应用程序中，我们有一个需要实时数据的仪表板。socket.io能帮助实现这一点吗？
不确定，它如何知道数据库中是否有任何数据更改？
浏览 0提问于2018-06-13得票数 3
我有一个REST，它应该使用Keycloak来授权传入的请求。在API中配置所需的作用域时，我遇到了问题。一个权限允许具有管理角色的用户对资源执行范围读取和删除。另一个允许具有监视角色的用户读取资源。
我了解到，我的端点的路径将根据Keycloak客户端资源中定义的路径进行检查。这里我的具体问题是，我不知道如何告诉我的端点，他需
浏览 3提问于2019-12-18得票数 2
回答已采纳
在rtc中，使用RTC中的公共存储库工作区的目的是什么。2)是否所有用户都能将代码下发到已连接的流。
3)如何从其他用户获取传入的更改。
浏览 14提问于2016-07-27得票数 1
2回答
我要做的是在交换机中安装规则，以转发最初发送到连接到此交换机的主机的数据包。H1-S1-S2-H3示例: H1向H3和H4发送特定的数据包，当它们到达S2时，它们必须被转发到控制器。我考虑的是在启动控制器时安装这些规则，但要做到这一点，我需要将主机连接到交换机。
有没有什么方法可以知道连接到给定交换机的主机？
浏览 3提问于2017-11-15得票数 0
1回答
它通过UDP侦听器线程接收来自远程源的流数据(让我们称之为“传入数据流”)。
还有一个TCP侦听器线程，用于侦听来自另一个远程源的命令。在协议中实现了各种命令，但我只实现了'send configuration data‘(发送配置数据)(它确实这样做了，而且工作正常)和开始/停止流数据。此开始/停止流数据应将(编码
浏览 3提问于2014-09-24得票数 2
我使用以下命令将传入的通信从端口30转发到端口1234。但这不管用。在Wireshark中，也没有指向端口1234的数据包的跟踪。
浏览 0提问于2018-07-20得票数 1
我在Quarkus应用程序中实现了REST端点。为了验证目的，我使用hibernate-验证器。因此，我向传入参数添加了@Valid注释，并向该类添加了一些约束。每件事都像预期的那样运作。当发送包含无效数据的请求时，我会看到这样的响应： "exception": null, "classViolations": [&qu
浏览 6提问于2022-10-20得票数 0
回答已采纳
我有React web application和REST API (Express.js)。我发现，如果不想使用长轮询或套接字(不需要发送数据客户端->服务器)，使用EventStream是更好的选择。脲酶：
用户打开页面，其中是空表，其他用户可以在其中添加数据，POST /data.This表中填充来自API的初始数据，GET /data.Then页面连接到EventStream on /data/可以将此更改(新增行)从
浏览 5提问于2019-09-20得票数 0
如何通过Spring Integration使用服务器发送的事件？我知道Spring通过Webflux支持SSE，但是如何将传入的Flux转换为单独的消息实例？并可能将这些代码封装到某个Spring-Integration-Lifecycle感知组件中(MessageProducerSupport?)WebClient client = WebClient.create("http:&#x
浏览 6提问于2021-11-26得票数 1
在Azure中，我能够使用Call Mode: SOAP to REST创建到SOAP端点的连接器。此Service需要一个名为Cookie的Header，其值为LoginCert=。在修改此连接器的请求时，我无法找到在REST请求中添加Cookie HTTP头的方法，并将相同的Cookie添加到SOAP请求中。是否有人知道如何或是否可能将REST请求的HTTP头
浏览 0提问于2019-03-08得票数 0
回答已采纳
1回答
如何在HDFS中存储特定的网站tweet？水槽和sqoop也有助于存储数据。所以，请给我建议一下，在HDFS中存储tweet时，水槽和sqoop是如何工作的？
浏览 4提问于2013-09-19得票数 1
1回答
我有一个通过POST请求接收消息的REST服务(Play Framework2.0 w/Scala)。根据文档，为了创建SSE流，我使用了一个Enumerator/Enumeratee/Iteratee链。我的问题是:如何将从POST请求接收到的
浏览 0提问于2012-11-09得票数 2
回答已采纳
1回答
我正在使用工业设备，在SQL Server 2008数据库每次循环时(大约每25秒)都会插入一些文本数据。我期待着将这些数据实时转发到mongo数据库，以便与内部Meteor应用程序一起使用。有什么明显的起点吗？我发现的最接近的答案是：
Q:那么，我应该如何使用数据库中的数据呢？通过REST接口和/
浏览 0提问于2015-04-20得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
