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

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

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

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

怎么解决?

慕姐8265434
浏览 1189回答 4
4回答

哔哔one

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

料青山看我应如是

不是有个RejectedExecutionHandler吗?

qq_遁去的一_1

都内存泄露了还不死机啊。RejectedExecutionHandler对拒绝的任务进行处理,要不看看用redis,哈哈
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Java