问题描述
我正在使用一个自定义聚合器来聚合我的Spring云流的相关消息。我正在使用ConfigurableMongoDbMessageStore作为消息存储。
消息的数量大约为300-400k。当文档数量超过70k时，我发现聚合器的运行速度相当慢。我尝试扩展聚合器实例。这会短暂地提供帮助，然后在某些时候再次遇到性能瓶颈。现在，这种缓慢的问题在于，消息最终会在队列中堆积，当达到Rabbit最大消息长度时，这些消息就会被Rabbit丢弃。
我不想使用SimpleMessageStore，因为当消息数超过90-100k时，它最终会导致聚合器出现内存不足的问题。此外，持久性消息存储为我提供了更好的弹性。
关于如何解决此缓慢问题，是否有任何建议？
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）