在 JMS 世界中,您可以通过调整消息驱动 bean (MDB) 中的maxSession属性轻松定义并发度。现在 Quarkus 显然没有 MDB,但是如何实现相同级别的并发调优呢?
我查看了指南(Quarkus - Using JMS),但示例中的所有消费者所做的都是使用无限循环获取消息。我认为这是一个非常糟糕的例子。我了解语法,但它使用消息的方式对我来说似乎很忙。
所以我想也许我没有抓住重点,而响应式消息传递是更有效地处理更多消息的方法。我查看了Quarkus 指南 - Using AMPQ with Reactive messages但是它再次没有说明消费者的并发性。在最后一个示例中,Price Generator bean 是一个应用程序范围的 bean,它使用响应式消息注释从 Artemis 代理消费消息,这很酷,但是并发呢?
如果我希望传入通道(或 JMS 队列)的消耗速度比其他通道快,那么如何在 Quarkus 上实现呢?你能分享一个例子吗?