当前位置: 首页 > 知识库问答 >
问题:

EventBus google guava关闭挂钩

詹亮
2023-03-14

目前,我在应用程序中使用guava EventBus方法。侦听器尝试做一些工作,如果失败,事件应该返回总线并重新发送
我的问题是:如果我的应用程序正在关闭(执行关闭),该怎么办?它会在总线中发送剩余的事件吗?

我正在寻找一些方法,例如在ActiveMQ中实现关闭how

代理是否应该安装一个关闭挂钩,以便在JVM终止时正确关闭自己

不幸的是,我没有在EventBus番石榴中找到类似的东西。

共有1个答案

蓟捷
2023-03-14

标准的GuavaEventBus是同步器,它没有内部Thread或类似的东西。如果调用post(Object event)的线程死亡,EventBus将停止传递事件(因为它使用调用者的线程)。

另一方面,AsyncEventBus在构造过程中接收一个用于调度事件的执行器java.util.concurrent包。在这种情况下,这取决于您使用的执行器实现。例如,ThreadPoolExector需要Shutdown Now()调用来停止传递消息。

 类似资料:
  • 问题内容: 我在程序中添加了以下代码: 但是,我没有看到该消息。附加信息:我正在Java 7的Netbeans IDE内部运行该程序。 编辑:我忘了补充说,有一个使程序保持活动状态的全局线程。我通过按Netbeans右下角的[x]来关闭它。 问题答案: JVM可以有序或突然关闭。关闭挂钩会运行以有序关闭:当最后一个线程终止时,有人呼叫或通过其他平台特定的方式(例如,按Ctrl-C)。 Shutdo

  • 我有一个Spring启动应用程序在负载均衡器后面的两台服务器上运行。 我定义了一个关闭钩子,它将应用程序中的/healthcheckendpoint设置为返回404错误,等待30秒以完成所有操作,然后停止JVM。负载平衡器被配置为在看到404错误时将服务器置于维护模式。(这与“停机”状态不同——允许在维护模式下完成飞行中的连接) 问题是负载平衡器从未看到这些404响应。相反,它会拒绝第4层TCP连

  • 问题内容: 我只是不明白为什么必须使用Runtime.addShutdownHook。如果要在jvm退出时进行一些清理,为什么不重载daemon类的finalize方法。使用shutdown钩子而不是finalize方法的好处是什么。 还有一个不赞成使用的函数runFinalizersOnExit。如果将其设置为false,我相信终结器将不会运行。这与java保证终结器始终在垃圾回收之前运行是矛盾

  • 问题内容: 我需要在Java Web应用程序停止或tomcat停止时保存一些数据。如何才能做到这一点?编辑:如果我使用jvm shutdown钩有什么缺点? 问题答案: 使用在您的web.xml 中实现ServletContextListener的类:

  • 为了避免在这些情况下中断工作线程,可以向JVM运行时插入一个shutdown钩子,该钩子在JVM关闭启动后正确地停止LoggerContext 我想知道如何在Spring Boot应用程序中停止AsyncAppender。在Spring引导的哪个位置,我应该定义关机钩?

  • 问题内容: 我试图确保我的Java应用程序采取合理的步骤来增强功能,并且其中的一部分涉及正常关闭。我正在阅读有关关机挂钩的信息,但实际上并没有实际使用它们的方法。 有没有实际的例子? 假设我有一个非常简单的应用程序,例如下面的程序,它以100为批号将数字写入文件,将10写入行,并且如果程序被中断,我想确保给定的批处理完成。我知道如何注册一个关闭钩子,但是我不知道如何将其集成到我的应用程序中。有什么