我正在使用 Kinesis 在 Spring Boot 应用程序中使用流。我为此使用 AWS 提供的 KCL 并启动它，您定义一个 Kinesiscom.amazonaws.services.kinesis.clientlibrary.lib.worker.Worker实例并调用.run()它。我不想为这项任务使用弹簧集成。
我想在这里构建一个抽象，以便开发人员可以创建多个工作人员并让它们在应用程序启动期间或之后自动运行，然后.shutdown()在应用程序终止时调用相应的方法。现在我通过@Component为每个 Worker 创建一个然后run()在@PostConstructand上来做到这一点@PreDestroy。
有没有更好的办法？