聊天记录存储问题

Question

请问一下 如果聊天室聊天记录是要存储的，我是不是也可以使用task异步存储，如果聊天并发很大的话？一般做法是存redis，然后定时再存mysql好，还是直接存mysql好呢？老师，如果你来做，你怎么存储呢？谢谢

Answer 1

singwa 2018-04-12 10:09:36

你好，你的问题问的非常好，如果是高并发流量非常大的情况下 我们的做法是

1、先写本地日志(通过Swoole里面的异步IO 文件写 或者用task机制来写)， 

2、然后每台直播swoole机器会部署agent采集工具 这个agent负责传输实时的日志到spark中  spark 可以按每分钟或者5分钟 聚合后负责写elasticsearch中，祝你学习愉快

如果流量不是很大的情况下 直接写MySQL就可以了。所以都是看具体的场景哈。祝学习愉快

• 十年砍柴mmws #1

  老师啊,搞个中小型公司使用的吧,先写到redis,在存进mysql,然后存到elasticserach里面,spark,agent大数据基本没用过