编年史队列事件侦听器
共有1个答案
实现侦听器模式的推荐模式是使用MethoDreader/MethodWriter，它还可以在读到的时间戳结束时处理时间戳。
我建议您从第1部分开始，从下而上阅读https://vanilla-java.github.io/tag/microservices/。
对于tailer来说，它知道有消息的唯一方法是读取/轮询队列的末尾。如果appender和tailer在同一个过程中，您可以使用您选择的不同机制。
-
编年史队列doco指定可以在不同的盒子上有编年史接收器，事件通过网络从单个编年史队列分发到它。（http://chronicle.software/products/chronicle-queue/）
-
我有一个web服务器（比如tomcat)，它为http请求服务 每个请求处理都可能生成一些跟踪信息。 我将把这些跟踪信息写入编年史队列（以字节[]为单位，我将自己进行编组/解编组，就像使用protobuf一样） 我将有一个专用的线程来使用裁剪器从编年史队列中读取。每个消息将只处理一次，如果失败，我将使用自己的重试策略将其放回队列以允许下次尝试。 基于以上用例，我有以下问题： > 应该使用多少追加器
-
几天前我开始使用chronicle-queue，我正在浏览它的文档。
-
当我们执行一些负载测试时，我们注意到明显的性能下降，所有的调查都指出Kafka主题、生产者和消费者延迟的大幅增加。无论我们改变了多少配置或添加了更多资源，我们都无法摆脱症状。 目前，我们的需求是每秒处理10个事务(TPS)，负载测试是执行20个TPS，但随着系统的发展和增加更多的功能，我们知道我们将达到500TPS的需求阶段，所以我们开始担心是否可以用Kafka实现这一点。 作为概念证明，我尝试切
-
在这篇文章中，加里·拉塞尔解释了如何通过编程创建多个Kafka列斯汀来聆听多个主题。。Kafka·斯普林：如何动态或在循环中创建监听器？ 现在我想有一个类似的设置也适用于JMSListeners-在那里我可以有一个带有一个@JMSListener的类，并且我可以以编程方式创建该JMSListener的多个实例，每个实例都注入了自己的queueName。 我发现这篇文章Spring JMS开始根据请