基于gorilla/websocket库进行二次封装

• 自定义路由
• 自定义鉴权，自定义描述符id目前支持 string
• 链接管理器
• 限制连接数
• 支持单聊
• 自定义连接属性
• wooker pool
• task queue
• 自定义用户tag
• 发布订阅模式，向某种tag标签的用户发送消息
• 数据压缩

todo

• 自定义数据解析器，json,protobuf
• 数据校验validator
• context上下文
• 负载均衡 Gateway 网关
• 跨服务通信
• 日志收集
• 链路追踪

使用方法

package main

import (
	"net/http"

	"github.com/liujingkaiai/x-websocekt/xnet"
)

func main() {
	//实例化websocket 服务
	s := xnet.NewDefault()  
	// 设置ws路径
	http.HandleFunc("/ws", s.Shake)
	//开启http服务
	http.ListenAndServe(":9997", nil)
}

路由

消息格式 消息id + 消息内容 |uint32|消息内容二进制

const (
	Hello uint32 iota
)

//定义路由
func HelloHandler(req xnet.Request) {
	//  向连接写入消息  id:0  写入内容 world
	req.SendMsg(Hello , []byte("world"))
}


// 实例化 webscoket server 
s := xnet.NewDefault() 
// 设置路由 id:0 处理方法  HelloHandler
s.AddRouter(Hello, HelloHandler) 

单聊

s := xnet.NewDefault() 

// uid 链接id  msgID 消息类型 data 消息内容	
s.ChatWith(uid, msgID,data); 

自定义tag,发布订阅