请问大佬，根据前端条件对 websocket 推送的数据进行筛选和分页怎么做啊？？实在没有头绪。

[fragrans23]

请问一下各位大佬，最近公司有这样一个需求，公司要通过请求第三方接口将数据放入 redis 队列中，订阅队列后，通过 websocket 推送给前端。现在我有一个问题，其中有一个需求是这样的，要根据分组名称多选进行查看。我写的代码是每 5 秒请求第三方接口放入 redis 队列，有消息通过 websocket 进行推送。如何根据条件多选呢？还有要进行分页。websocket 可以通讯，但拿数据和推数据不是一起的，想了很久了？有大佬能提供一个解决方案吗（我将我写的这部分代码，单独拿出来写了个 demo，地址： https://gitee.com/feng2333/websocket-demo.git ）哭！！！

[gleams]

根据分组不同，将数据放到不同的队列里，前端请求的时候根据请求条件，取不同队列的数据，这样，分页就好做了

[fragrans23]

@gleams 分组的数量可能很大，几十上百个，会不会对 redis 有影响？而且我只有请求接口时才得到分组的数据，要怎么写呢？。。。以前没用过 redis 做队列的用法，对这些不是很熟悉

[zhady009]

@fragrans23 用可以 redisson 解决你不会用队列的问题 做完之后可以回头看看别人怎么玩的

[meeop]

这个需求看起来就是想根据一定条件领取数据,数据别放 mysql 根据一定条件查不就好了
另外如果分组是有限的,就能实现预留比如 1w 个队列,然后根据条件去领取

[ipwx]

你在自己的后端做这件事啊。。。

后端有个统一的 pub-sub，需要什么 topic 向 redis 增量订阅，不需要的取消。

前端 websocket 去向你自己的后端 pub-sub 订阅，这里就能直接规定每个 subscriber 需要订阅哪些 topic 了。

这样你的后端项目只要加入口机横向扩展，就能迅速扩大规模。毕竟你的 redis 只要抗住每个入口机一个订阅者就行。

[ipwx]

后端实现 pub-sub 多简单的事情。python asyncio 可以闭着眼睛给你写一个，我写过。

其他 node.js ，Java vert.x 我觉得也不是难事。

[fragrans23]

@ipwx 感谢回复，redis 增量订阅哪里有 java 的例子吗，好像没怎么看到

[ipwx]

@fragrans23 我没搞过 redis 消息队列，我搞过 kafka 。kafka => python asyncio 内部 pub-sub => websocket