websocket+队列（先进先出）解决PSS云计算书排队难题

hotqin888

发布于 2021-08-05 15:46:18

3320

发布于 2021-08-05 15:46:18

原来想用NSQ消息队列，原来不适合我的场景。 NSQ无序？也不晓得什么无序，是否先进先出。而http协议又是只能一次请求一个回复。而排队就必须不断的广播目前前面有多少人，过几秒再刷新一下还有几人，后面又来了几个人……甚是热闹，这不就是直播（聊天室）刷弹幕嘛…… 只能硬着头皮弄成websocket了，其实就3行+2行代码而已：服务端：

ws, err := upgrader.Upgrade(c.Ctx.ResponseWriter, c.Ctx.Request, nil)//服务端建立websocket连接
err := client.WriteJSON(msg)//向浏览器客户端写入信息
err := ws.ReadJSON(&msg)//从浏览器读取计算参数

页面：

var ws = new WebSocket('ws://' + window.location.host + '/v1/mathcad/postmath2');//与服务端建立websocket连接
ws.send(obj);//向服务器发送计算信息

要计算前面有多少人就必须用队列吧（还有其他啥法子么？） golang队列我搜…… 代码也就几行

//向队列中添加元素
func (entry *sliceEntry) Offer(e Element) {
entry.element = append(entry.element, e)
}
//移除队列中最前面的额元素
func (entry *sliceEntry) Poll() Element {
if entry.IsEmpty() {
fmt.Println("queue is empty!") return nil
}
firstElement := entry.element[0]
entry.element = entry.element[1:]//从index=1开始，即移除了
return firstElement
}

那如果说这都没怎么体现咱们设计要素？继续看。不同的人使用同一个模板计算，就必须排队。而不同的人用不同的模板计算，则用多线程计算即可，不用排队（当然也是要有限度……）看出来了吧，给用户浏览器发送消息的时候就必须考虑哪些用户是一个组的，即，使用同一个模板的用户是一个组，排队信息就只能发给这个组的所有人，而这个组的每个人收到的前面还剩多少人在排队的数量是不同的。利用上面这个队列代码，稍加改造，即element里要存用户websocket连接信息，templeID模板id，userID，websocket连接信息为var clients = make(map[*websocket.Conn]bool)

map是无序的。map用来对数组去重似乎是最佳方案（还有更好的去重方法吗？）先到这了，继续探索。某些队列组件是支持分组的。

本文参与腾讯云自媒体分享计划，分享自作者个人站点/博客。

原始发表：2021-06-20 ，如有侵权请联系 cloudcommunity@tencent.com 删除

element