golang 推送系统怎么做消息合并优化？

[laravel]

比如服务端有 5000 人在线，每秒消息数 100 条，如果不优化，每秒的广播将是 50 万， 现在我想把 1s 之内的消息合并成 1 条，这样就只有 5000 次广播了，聊天这种 1s 延迟可以忍受。

现在的问题是 这种消息怎么保存？方便消费

语言 golang

[lewinlan]

在发送出口做个限流器呗。1 秒内的消息都 append 进一个 slice 里，用一个 Ticker 计时发送并清空 slice，很简单吧

[vvmint233]

或许在广播的前面加上一层缓冲区, 达到一定大小就清空缓冲区然后分发出去

[zz554952942]

聊天数据发送到 kafka，或者 RabbitMQ(确保数据不丢失)
然后启一个携程, time.tick 定时 1s 从消息队列取即可

[zz554952942]

亦或者可以用 Redis, 以用户 ID 做哈希键 然后当接收到消息的时候则把需要推送的用户 ID 的信息写到 Redis 上（这样子就把当个用户所需要的消息进行了合并）
然后携程定时从 Redis 里取所有数据 然后发送（取到的是一个哈希数组就是每个用户应该接收到的消息）

[laravel]

我已经打算 redis 或者用 go 实现 redis 的 list 也行，一次取 100-1000 条合并之后再广播