开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

Quarkus -了解错误请求失败: java.lang.IllegalStateException: SRMSG00028:事件订阅已取消

Quarkus是一种开源的Java框架，用于构建云原生和可扩展的应用程序。它旨在提供快速启动时间和低内存消耗，同时保持高性能和低延迟。Quarkus基于GraalVM和OpenJDK，可以将Java应用程序编译成本地可执行文件，从而减少了启动时间和内存占用。

错误请求失败: java.lang.IllegalStateException: SRMSG00028:事件订阅已取消是一个异常错误，它表示事件订阅已被取消，导致请求失败。这可能是由于以下原因之一引起的：

事件发布者取消了事件的订阅。
订阅者在处理事件时发生了错误，导致订阅被取消。
事件订阅的生命周期已经结束，但仍然有请求尝试访问已取消的订阅。

要解决这个问题，可以采取以下步骤：

检查事件发布者是否正确地保持了事件的订阅。确保没有意外取消了订阅。
检查订阅者的代码，查找可能导致错误的地方。确保订阅者在处理事件时没有抛出异常。
确保订阅的生命周期与请求的生命周期相匹配。如果订阅已经结束，确保不再尝试访问已取消的订阅。

对于Quarkus框架，腾讯云提供了一些相关的产品和服务，可以帮助开发人员构建和部署基于Quarkus的应用程序。以下是一些推荐的腾讯云产品和产品介绍链接地址：

云服务器（Elastic Compute Cloud，简称CVM）：腾讯云提供的可扩展的云服务器实例，用于部署和运行Quarkus应用程序。产品介绍链接：https://cloud.tencent.com/product/cvm
云原生容器服务（Tencent Kubernetes Engine，简称TKE）：腾讯云提供的托管式Kubernetes容器服务，可用于部署和管理Quarkus应用程序的容器化环境。产品介绍链接：https://cloud.tencent.com/product/tke
云数据库MySQL版（TencentDB for MySQL）：腾讯云提供的高性能、可扩展的云数据库服务，可用于存储Quarkus应用程序的数据。产品介绍链接：https://cloud.tencent.com/product/cdb_mysql

请注意，以上仅是一些腾讯云的产品示例，其他云计算品牌商也提供类似的产品和服务，可以根据实际需求选择适合的解决方案。

页面内容是否对你有帮助？

有帮助

没帮助

相关·内容

Java 近期新闻：JDK 22、GraalVM for JDK 22、JDK 23 发布时间表、JMC 9.0

事件和调度处理机制。...类实例时发生错误；在使用虚拟线程时缺少线程名前缀；在 Tomcat 被取消关闭时却报告成功关闭。...字段，用于处理仅当事件符合特定条件时监听器才处理事件的场景；支持开放式应用模块和包信息类型。...Quarkus Quarkus 3.8.3（第二个维护版本，跳过了版本 3.8.0）带来了一些显著变更，例如：解决了由于缺少表而导致 Hibernate 模式验证失败的问题，但实际上表是存在的；支持通过...Eclipse Vert.x 4.5.6 已发布，包含了一些显著变更，例如：重构了 HttpUtils 类中定义的absoluteURI()方法，该方法自己检查请求 URI 的格式，而不是使用 JDK

1191 0

Java 近期新闻：结构化并发、Java 满 27 岁、Micronaut 3.5.0

这可以简化错误处理和取消操作，提高可靠性，并增强可观察性。评审预计将于 2022 年 6 月 2 日结束。InfoQ 后续将带来更详细的新闻报道。...欢迎开发者审查新的 Jakarta EE Core Profile 的 pull 请求，并在必要时提供反馈。...最后，最近发布的 WildFly 27.0.0.Alpha1 的认证请求已提交给 JDK 11 和 JDK 17。...LSP4MP）0.4.0 和 quarkus-ls 0.11.1（LSP4MP 的 Quarkus 扩展）保持一致。...河南赋红码事件程序员不背锅；马斯克：向TikTok和微信学习；华为宣布将调整绩效考核指标 | Q资讯 IE 浏览器已“死”，一个时代的终结被捧上天的 Scrum 敏捷管理为何不受大厂欢迎了？

6692 0

Java 近期新闻：JDK 21 发布计划、Payara 平台、JBang、JHipster、WildFly

它使得远程攻击者能够通过不安全的对象请求代理（ORB）监听器，利用远程 JNDI 访问将恶意代码加载到面向公众的 Payara Server 安装中。...此外，该版本还取消了对 MicroProfile Metrics 和 MicroProfile OpenTracing 规范的支持。要了解关于这个版本的更多细节，请查看发布说明。...Gradle Gradle 8.1 的第 2 个候选版本提供了以下新特性：对配置缓存的持续改进；支持依赖关系验证；改进 Groovy 闭包的错误报告；支持 Java lambdas；支持使用...它提供了 Java社区日历，供开发人员查看和添加事件。日历是开放的，不需要专门的帐户就可以添加内容，而且内容是经过审核的。...原文链接： https://www.infoq.com/news/2023/04/java-news-roundup-mar27-2023/ 相关阅读：甲骨文推出新的 Java SE 通用订阅 Java

2K2 0

Quarkus初体验

官方地址：https://quarkus.io/ 先决条件要完成本指南，您需要：少于15分钟一个IDE 已JAVA_HOME正确配置JDK 8或11+ Apache Maven 3.6.2以上构建项目...hello shaojie - 0", "hello shaojie - 1", "hello shaojie - 2" ] 这里有一个小坑，官方没有提供完整的依赖，因为缺少依赖，所以这个请求并不能拿到当前的...正如@Produces注释所定义的那样SERVER_SENT_EVENTS，JAX-RS需要它知道每个（嵌套的）事件的内容类型。...，感觉还可以，后面深入去了解一下Quarkus 第一眼看上去竟然不知道怎么读的，翻译也翻译不出来，然后网上有一段介绍是：红帽公司中间件团队在3月7日正式发布了Quarkus项目。...说不出来的奇怪，不深究这个，反正英文水平一般，就上面的例子而言，有些地方的语法有点蹩脚，但是不知道是不是因为还不了解的原因，线了解一下，防止后面看不懂。简单了解，有错误或者不对的地方请指正，谢谢！

1.3K2 0

Combine-Subscriber

Publisher 根据 Subscriber 的请求提供数据。如果没有任何订阅请求，Publisher 不会提供任何数据。...所以可以这样说，Subscriber负责向 Publisher 请求数据并接收数据（或失败）。...Publisher调用此方法发布新的数据 func receive(_ input: Self.Input) -> Subscribers.Demand /// Publisher调用此方法发送错误或完成事件...这里的 completion 可以是正常.finished，也可以是.failure的，如果是.failure的会携带一个错误信息。注意：如果中途取消了订阅，Publisher 将不发送完成事件。...Sink和Assign都实现了Cancellable 协议，所以可以调用cancel方法来取消订阅。

9392 0

Java 近期新闻：字符串模板、Quarkus、Open Liberty、PrimeFaces、JobRunr、Devnexus

Quarkus Quarkus 3.0.0 的第 2 个候选版本提供的新特性包括：Gradle 任务quarkusUpdate，用于将 Quarkus 升级到新版本；Dev UI 2 现在默认通过/q...Quarkus 2.16.6.Final 是第 6 个维护版本，带来了一些重要的更改，如：如果 ID 令牌验证失败，则删除会话 cookie；允许在 REST 客户端请求体中使用null；在响应式消息传递中支持可重复的...Apache Camel Apache Camel 3.18.6 发布，带来了重大修复、依赖项升级和改进，如：允许返回包含空值的 HTTP 响应头，以支持需要此功能的应用程序；改进了允许或禁止 HTTP 请求体的处理过程...；如果在vertx-websocket 消费者执行阻塞操作之后进行路由处理，则可能会阻塞 Vert.x 事件循环，该版本修复了这个问题。...Gradle Gradle 8.1 的第 3 个候选版本带来了一些新特性，包括：对配置缓存的持续改进；支持依赖关系验证；改进 Groovy 闭包的错误报告；支持 Java lambdas；支持使用 JDK

1.6K3 0

【Axios】：Axios 的请求取消特性是什么原理？

; // 取消令牌注意事项：在已取消的令牌上订阅的事件，会立即触发。 const CancelToken = require("....(), "[已取消]:触发(取消事件1)(取消原因："+reason+"); 并将于5秒后, 在已取消前提下, 订阅(取消事件2);"); setTimeout(()=>{ console.log...(new Date().toLocaleTimeString(), "[已取消]:订阅(取消事件2);"); token.subscribe((reason)=>{...console.log(new Date().toLocaleTimeString(), "[已取消]:触发(取消事件2);"); }); }, 5000) }); setTimeout...通过分析 CancelToken 的原理， Axios 接收到外部传入的 CancelToken 令牌对象后，只需要订阅令牌的取消事件，并在取消事件被触发时，作出相应处理即可订阅：取消订阅：

2.5K1 1

Quarkus的RESTEasy Reactive集成已合并master

前言 Quarkus和RESTEasy团队非常高兴地宣布了Quarkus中的RESTEasy Reactive集成已进入master分支，并将成为下一个Quarkus 1.11发行版的一部分。...新的请求/响应过滤器设计 JAX-RS过滤器需要实现一个接口并将上下文对象作为字段注入，这既昂贵又不灵活。...该项目已降落在Quarkus主分支，所以，如果你渴望尝试一下，你就必须按照从源代码编译Quarkus这和使用遵循正确BOM和版本此。...尽管该项目几乎通过了JAX-RS TCK的全部，但它只是第一个发行版，因此请记住，它可能比典型的经过战斗的库具有更多的错误，而某些新的API和SPI可能会损坏。...尽管这是第一个发行版，但我们确实预想这项工作将在不久的将来成为Quarkus的默认REST层。如新功能部分所述，默认情况下，请求是在事件循环线程上处理的。

1893 0

源码分析Kafka 消息拉取流程（文末两张流程图）

代码＠３：如果当前消费者未订阅任何主题或者没有指定队列，则抛出错误，结束本次消息拉取。代码＠４：使用 do while 结构循环拉取消息，直到超时或拉取到消息。...代码@4：如果已缓存的分区信息中存在某些分区缺少偏移量，如果拉取的超时时间大于失败重试需要阻塞的时间，则更新此次拉取的超时时间为失败重试需要的间隔时间，主要的目的是不希望在 poll 过程中被阻塞【后续会详细介绍...我们也来简单的了解一下其内部数据结果。 Errors error 分区拉取的相应结果，Errors.NONE 表示请求成功。...代码@3：如果出现如下3种错误码，则使用 debug 打印错误日志，并且向服务端请求元数据并更新本地缓存。...代码@3：从本地消费者缓存中获取该队列已消费的偏移量，在发送拉取消息时，就是从该偏移量开始拉取的。

2.1K2 0

你可能用错了 kafka 的重试机制

这样，消费者就可以通过这条消息的偏移量请求下一条消息。主题事件日志分为几个主题（topic），每个主题都定义了要发布给它的消息类型。...消息失败时有发生，我们需要制定一种策略来处理它……要未雨绸缪，而非亡羊补牢。因此，了解这是一种迟早会发生的问题并设计针对性的解决方案是我们要做的第一步。...我们通常允许同步请求失败。例如，对我们的 UserAccount 服务所做的一个“create-user”POST 可能包含错误或丢失的数据。...它忽略了不同类型的错误第一个问题是，它没有考虑到导致事件消费失败的两大原因：可恢复错误和不可恢复错误。可恢复错误指的是，如果我们多次重试，这些错误最终将得以解决。...同样，我们的消费者将针对该主题的每个事件执行相同的操作。因此，如果消息 A 由于数据库中断而失败，那么消息 B、消息 C 等也将失败。不可恢复错误指的是无论我们重试多少次都将失败的错误。

5722 0

从源码分析Hystrix工作机制

；【执行】实际开始执行业务调用，若执行失败或异常，则进入降级逻辑；若执行成功，则正常返回；【超时】通过定时器延时任务检测业务调用执行是否超时，若超时则取消业务执行的线程，进入降级逻辑；若未超时，则正常返回...Hystrix提供的熔断器就有类似功能，应用调用某个服务提供者，当一定时间内请求总数超过配置的阈值，且窗口期内错误率过高，那Hystrix就会对调用请求熔断，后续的请求直接短路，直接进入降级逻辑，执行本地的降级策略...，若当前请求数据大于一定值且错误率大于阈值，自动更新熔断器状态为opened，后续请求短路，不再实际调用服务提供者，直接进入降级逻辑。...properties.circuitBreakerRequestVolumeThreshold().get()) { } else { //判断请求错误率是否超过配置错误率阈值...()⽅法将事件按时间分组，并通过 flatMap()⽅法将事件按类型（成功、失败等）聚合成桶，形成桶流；再将各个桶使⽤Observable.window()按窗口内桶数量聚合成滑动窗⼝数据；将滑动窗口数据聚合成数据对象

6272 0

Quarkus的拦截器ContainerRequestFilter注入Bean异常（19）

public void filter(ContainerRequestContext requestContext) throws IOException { //保存请求日志...} } 这是一段拦截器代码，用于统一拦截请求记录请求的日志信息，注入的对象是一个日志服务对象，日志服务对象中包含了访问数据库的JPA对象EntityManager实例，然后就报错了异常信息...cn.keking.project.capital.thirdparty.service.LogService_Bean.create(LogService_Bean.zig:149) 异常的message中已说明了...，在实例化filter的时候，EntityManager对象还未初始化，所有注入失败了。...如果用异常message搜解决方案肯定都是搜索到quarkus的CDI文档，quarkus的CDI文档中确实给出了解决方案，但是实施起来比较复杂，最终博主在一个stackoverflow解答中找到了灵感解决了问题

1164 0

如何借助 Quarkus 和 MicroProfile 实现微服务

在这种情况下，很重要的一点就是遏制故障，避免错误通过其他的服务进行传播。...现在，组件以服务的形式分布在多个节点上，因此，为了全面了解日志跟踪的情况，我们需要一个统一的日志系统 / 数据收集器。.../mvnw compile quarkus:dev 最后，我们可以发送请求来获取图书信息并提供一个合法的 JSON Web Token 作为 bearer token。...● @CircuitBreaker：当执行反复失败时，该服务会自动地快速失败。 ● @Fallback：当执行失败的时候，提供一个替代方案 / 默认值。...就本例来讲，当连接 rating service 失败的时候，我们会返回一个值为 0 的评分值。

1.6K5 0

Java 近期新闻综述：CVE-2022-22968、Vector API、Jakarta EE 10 更新

Open Liberty 22.0.0.5-beta 版也已发布，特性包括：支持 MicroProfile GraphQL 2.0；分布式安全缓存（这样多个 Liberty 服务器就可以通过JCache...Apache Camel Quarkus 为了与 Quarkus 保持一致，Apache 发布了 Camel Quarkus 2.8.0，包含 Camel 3.16.0 和 Quarkus 2.8.0...要了解关于这个版本的更多信息，可以查看已关闭问题列表。...2.0，其特性包括：支持 Kotlin 1.6.20；通过一个简化的扩展 API 提供了更简单的插件创建方式；支持 Kotlin/Native，作为对现有 GraalVM 支持的补充；提供新的 API，取消...post和get方法，简化 HTTP 请求；内置支持重试。

1.7K2 0

解决 ERROR o.s.boot.SpringApplication - Application run failed: `java.lang.IllegalStateException: Fail

错误背景该错误通常在Spring Boot项目启动过程中出现，通常与CommandLineRunner的执行失败有关。...3.3 代码优化和重构优化代码，确保所有依赖已注入并具备执行条件。...Q2: 是否有第三方库引起这种错误？ A: 有可能。如果项目中依赖多个库，请逐一排查版本兼容性。 Q3: 如何确保所有的Bean依赖已注入？...小结通过本文的详细解析与实际代码示例，我们了解了java.lang.IllegalStateException: Failed to execute CommandLineRunner 错误的潜在原因...文件读写异常检查文件路径和权限缺少外部服务确保服务可用且配置正确总结与未来展望 CommandLineRunner在启动阶段执行重要的初始化工作，发生Application run failed错误可能导致启动失败

4191 0

Go 事件驱动编程：实现一个简单的事件总线

可扩展性：新的订阅者可以轻松订阅事件，不需要修改现有的发布者代码。错误隔离：事件处理的失败不会直接影响其他服务的正常运行。...取消订阅：允许各个服务将本身已订阅的事件删除。...事件总线的方法实现事件总线实现了三个方法，分别为发布事件（Publish）和订阅事件（Subscribe）以及取消订阅事件（Unsubscribe）。...该方法接收两个参数：topic（已订阅的主题）和 ch（被颁发的通道）。...文章从事件总线的优势开始，介绍了其解耦、异步处理、可扩展性和错误隔离等特点。然后详细解释了如何定义事件数据结构和事件总线结构，并实现了发布、订阅和取消订阅事件的方法。

1707 3

分布式事务saga_分布式事务代码例子

6.1 协同式 Saga 协同式 Saga没有中央协调器，Saga参与方订阅彼此的事件并做出相应的响应。...紧耦合的风险：每个Saga参与方都需要订阅所有影响它们的事件。例如，AccountingService 必须订阅所有可能导致消费者信用卡被扣款或退款的事件。...取消订单的Saga包含以下事务: Consumer Service：增加可用额度。 Order Service：将Order 状态更改为已取消。 Delivery Service：取消送货。 ...Order Service：将Order 状态更改为已取消。 Delivery Service：取消送货。 Customer Service：增加可用信用额度。 ...如果记录已更改，则Saga将中止并可能重新启动。

9213 0

干货 | 深入浅出Apple响应式框架Combine

订阅者（Subscriber）接收发布者发送的Value。订阅者遵循的协议如下： ? 订阅者接受一个Input类型的Value以及接收到事件失败的类型Failure。...而Subscriber订阅者接受一个Input类型的Value或者接收到事件已经发送成功或者失败。...然后通过sink产生订阅者连接，sink方法返回的是Anycancellabel对象，它表示一个发布者和订阅者的链接可取消，通过store方法将其保存在外部变量setList数组中，这样能保证订阅者不会被释放...1）我们定义了常见的网络请求的错误类型； 2）UserResponse返回的是服务端的json数据Model； 3）判断URL是否有误，如果异常，返回PassthroughSubject生成的订阅者，发送...大多情况这是我们想要的，但是某些情况如果想要限制订阅者的请求次数，那么就可以通过定义具体的max携带的Int值，比如： ?

3.5K3 1

快速进阶 Kotlin Flow：掌握异步开发技巧

你会注意到，在冷流中，每个订阅者都会从头开始接收数据，而在热流中，所有已订阅的订阅者会立即接收到最新的数据。...在实际应用中，处理异步操作时必须考虑错误和异常情况。...CollectLatest collectLatest 策略会在新的数据到达时取消之前的数据处理，并只处理最新的数据。这在处理用户输入等连续事件时特别有用。...cancelled") } // 处理数据 } } finally { // 进行资源清理，如关闭数据库连接、取消网络请求等...RxJava 适用场景：如果你已经在项目中广泛使用了 RxJava，或对 RxJava 有深入的了解，继续使用它可能更加方便。

6603 0

支持JDK19虚拟线程的web框架，上篇：体验

框架已支持使用虚拟线程处理web请求，欣宸原创的《支持JDK19虚拟线程的web框架》系列会陪伴大家，全程以实战动手为主，从快速体验，再到实际编码，以及部署构建都有详细说明，确保读者们既有成就感，又能学点小技能...接下来说说本篇的主要内容：整个体验环境，由quarkus应用和数据库组成，当我们向quarkus应用发起请求的时候，应用会去查询数据再将数据返回给前端 quarkus应用提供了两个接口，第一个名为/...vt/persons，使用虚拟线程来处理web请求，第二个名为/pool/persons，使用传统线程池来处理web请求，整体上如下图所示由于quarkus对于响应式编程的支持比较完善，因此，quarkus...，这里显示100.00%，表示全部通过 http_req_waiting：等待响应的事件，这里avg=33.83ms，表示平均等待时间为33.83毫秒 http_reqs：每秒处理请求数，即常说的QPS...，SpringBoot的平均等待时间略高，QPS略低至此，咱们通过实际对比的方式，已体验过quarkus使用虚拟线程的web服务，同在quarkus框架中，虚拟线程带来的提升并不明显，在对比未做优化的

1.1K3 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭