问题描述
NSQ的消息过来是在内存中的吗,想要把每条过来的消息都存储到日志里要怎么做?
想到一个办法是对一个topic,建一个channel,启动一个消费者监听并写入文件。
不过很多topic的话岂不是每个都得重复操作,这样做很low啊。。而且还会在nsqadmin看到一个写文件日志消费者在那,请问有什么好的办法啊。
NSQ的消息过来是在内存中的吗,想要把每条过来的消息都存储到日志里要怎么做?
想到一个办法是对一个topic,建一个channel,启动一个消费者监听并写入文件。
不过很多topic的话岂不是每个都得重复操作,这样做很low啊。。而且还会在nsqadmin看到一个写文件日志消费者在那,请问有什么好的办法啊。
首先,配置项 -mem-queue-size:队列在内存中保留的消息数量,默认 10000 。你可以设置为 0 ,这样所有的消息都将被写入到磁盘中,但是吞吐量会变差。
其次,你不一定非要 nsq 本身去做持久化,你完全可以结合使用 mysql、kafka 等其他工具。