如何解决Spring Cloud Stream自定义聚合器处理器-性能问题
我正在使用一个自定义聚合器来聚合我的Spring云流的相关消息。我正在使用ConfigurableMongoDbMessageStore作为消息存储。
消息的数量大约为300-400k。当文档数量超过70k时,我发现聚合器的运行速度相当慢。我尝试扩展聚合器实例。这会短暂地提供帮助,然后在某些时候再次遇到性能瓶颈。现在,这种缓慢的问题在于,消息最终会在队列中堆积,当达到Rabbit最大消息长度时,这些消息就会被Rabbit丢弃。
我不想使用SimpleMessageStore,因为当消息数超过90-100k时,它最终会导致聚合器出现内存不足的问题。此外,持久性消息存储为我提供了更好的弹性。
关于如何解决此缓慢问题,是否有任何建议?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。