【发布时间】:2021-08-11 09:45:03
【问题描述】:
我需要并行访问 100 个 sqs 来轮询消息并访问另一个服务。我想象的是如何启动 100 个协程并永远运行它,以便每个协程并行访问 SQS,并根据结果,我可能会访问另一个微服务。我对使用这样的协程没有什么疑问
- 我可以让我的协程永远打开吗,即启动的协程将有一个循环,该循环将永远运行以从 SQS 获取消息并调用不同的微服务。
- 我的协程是否有可能被杀死(当我执行此类非结束操作时,我对微服务和 SQS 抛出的异常有适当的 try/catch,如果是这样,它是如何通过 Kotlin 处理的。
- 还有其他方法可以完成许多这种并行工作吗?我的应用程序是 Kotlin/Spring 启动应用程序。
有人可以指导一下这个场景
【问题讨论】:
-
您能否详细说明什么是 SQS?
-
@HiranChaudhuri "Amazon Simple Queue Service (SQS) 是一个完全托管的消息队列服务"。
标签: java multithreading asynchronous parallel-processing kotlin-coroutines