代码拉取完成,页面将自动刷新
package ws
import (
"github.com/gorilla/websocket"
"net/http"
"time"
)
type Message struct {
Content any `json:"content,omitempty"`
Sender string `json:"sender,omitempty"`
Recipients []string `json:"recipients,omitempty"`
Groups []string `json:"groups,omitempty"`
}
type Client struct {
Hub *Hub
Conn *websocket.Conn
Send chan *Message
Id string
Groups []string
}
type Hub struct {
Clients map[string]*Client
Broadcast chan *Message
Register chan *Client
Unregister chan *Client
}
const (
writeWait = 10 * time.Second
pongWait = 60 * time.Second
pingPeriod = 55 * time.Second
maxMessageSize = 2048
)
var _upgrader = websocket.Upgrader{
CheckOrigin: func(r *http.Request) bool {
return true
},
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。