当消息生产者生产消息的能力远远大于消息的消费者的消费能力时，该如何解决内存泄漏的问题？

Question

当消息生产者生产消息的能力远远大于消息的消费者的消费能力时,程序会发生什么事?

例如我这里有组桥接的生产者,每30秒会发布3700万条消息,而消费者就是一个简单的客户端,处理这3700万条消息,消费者会发生什么事?

//我知道消费者的缓冲队列会爆满溢出,导致内存泄露

怎么解决?

Answer 1

首先，这个不叫内存泄漏。叫法有点不严谨 对可靠性要求不高可以考虑随机丢掉一些 扩展硬件 对可靠性有要求的话。简单来说就是先扔到硬盘or数据库里，总而言之不能放内存里了。有点像Java中的Socket 实例都有一个 InputStream 和 OutputStream分别会维护一个SendQ队列和RecvQ队列，不过它是在内存中，我们放到了硬盘中而已。

Answer 2

不是有个RejectedExecutionHandler吗？

Answer 3

都内存泄露了还不死机啊。RejectedExecutionHandler对拒绝的任务进行处理，要不看看用redis，哈哈