zzserver

README

zzServer

该项目是一个简易的socket服务端程序，

1. 支持webSocket以及普通tcpSocket
2. websocket支持BinaryMessage和TextMessage,且能支持同时解析json和protobuf协议
3. websocket同时支持gin

使用示例

• 服务端

//开启服务
srv := zzserver.NewZZServer()

//设置gin,不设置会生成一个默认的
g := gin.Default()
g.GET("/hello", func(c *gin.Context) {
  c.JSON(http.StatusOK, gin.H{"code": 0})
})

srv.SetGinEngine(g)          //设置gin
srv.SetRouter(&protocol.P{}) //绑定路由接口
srv.SetWebsocketPort(9999)   //websocket端口
srv.SetTCPPort(9988)         //不设置就不会启动监听
srv.Start()


//遍历客户端

srv.Range(func(c *zzserver.Client) bool {
	fmt.Println(c.LastMsgTime)
	return true
})

• 客户端

ws://127.0.0.1:9999?messageType=text  发送字符串消息 (默认值)
ws://127.0.0.1:9999?messageType=binary   发送binary消息
http://127.0.0.1:9999/hello             http访问

请参考 example

喜欢请 start 一下

by. douya

Documentation

Index

• type BaseRouter
  • func (b *BaseRouter) OnConnected(c *Client)
  • func (b *BaseRouter) OnDisconnect(c *Client)
  • func (b *BaseRouter) OnMessage(c *Client, message []byte)
  • func (b *BaseRouter) OnServerClose()
  • func (b *BaseRouter) OnServerUpdate()
• type Client
  • func (c *Client) Close()
  • func (c *Client) GetRemoteAddr() string
  • func (c *Client) SendByte(bytes []byte)
  • func (c *Client) SendJson(obj interface{}) error
  • func (c *Client) SendText(msg string)
• type IRouter
• type Server
  • func NewZZServer() *Server
  • func (h *Server) Close()
  • func (h *Server) Online() int
  • func (h *Server) Range(f func(c *Client) bool)
  • func (h *Server) SendToAll(message []byte)
  • func (h *Server) SendToAllJson(obj interface{})
  • func (h *Server) SetGinEngine(g *gin.Engine)
  • func (h *Server) SetRouter(r IRouter)
  • func (h *Server) SetTCPPort(port int)
  • func (h *Server) SetWebsocketPort(port int)
  • func (h *Server) Start()
  • func (h *Server) WaitCloseSignal(f func())

Types

type BaseRouter

type BaseRouter struct{}

BaseRouter 用于重写, 这样就不需要写出所有方法

func (*BaseRouter) OnConnected

func (b *BaseRouter) OnConnected(c *Client)

func (*BaseRouter) OnDisconnect

func (b *BaseRouter) OnDisconnect(c *Client)

func (*BaseRouter) OnMessage

func (b *BaseRouter) OnMessage(c *Client, message []byte)

func (*BaseRouter) OnServerClose

func (b *BaseRouter) OnServerClose()

func (*BaseRouter) OnServerUpdate

func (b *BaseRouter) OnServerUpdate()

type Client

type Client struct {
	Server          *Server     //server对线
	User            interface{} //用户对象
	UserData        sync.Map    //保存一些用户自定义内容
	ConnectionIndex int         //
	LastMsgTime     time.Time   //最后收到消息时间
	Ip              string      //登录IP
	WsMessageType   int         //websocket的协议类型,1:text, 2:binary
	// contains filtered or unexported fields
}

Client 保存客户端连接和用户

func (*Client) Close

func (c *Client) Close()

func (*Client) GetRemoteAddr

func (c *Client) GetRemoteAddr() string

GetRemoteAddr 获取地址

func (*Client) SendByte

func (c *Client) SendByte(bytes []byte)

SendByte 发送byte, socket会进行编码后再发送

func (*Client) SendJson

func (c *Client) SendJson(obj interface{}) error

func (*Client) SendText

func (c *Client) SendText(msg string)

SendText 发送消息 封装

type IRouter

type IRouter interface {
	OnMessage(c *Client, message []byte) // OnMessage 用户协程中调用
	OnDisconnect(c *Client)              // OnDisconnect hub协成中调用
	OnServerClose()                      // 关闭服务器执行一次
	OnServerUpdate()
	OnConnected(c *Client)
}

IRouter 方法2: 接口

type Server

type Server struct {
	ConnectionIndex int64 //连接计数
	// contains filtered or unexported fields
}

func NewZZServer

func NewZZServer() *Server

func (*Server) Close

func (h *Server) Close()

func (*Server) Online

func (h *Server) Online() int

func (*Server) Range

func (h *Server) Range(f func(c *Client) bool)

Range 在同一个go中执行, 不要执行很久的操作

func (*Server) SendToAll

func (h *Server) SendToAll(message []byte)

SendToAll 广播消息

func (*Server) SendToAllJson

func (h *Server) SendToAllJson(obj interface{})

SendToAllJson 广播消息

func (*Server) SetGinEngine

func (h *Server) SetGinEngine(g *gin.Engine)

func (*Server) SetRouter

func (h *Server) SetRouter(r IRouter)

func (*Server) SetTCPPort

func (h *Server) SetTCPPort(port int)

func (*Server) SetWebsocketPort

func (h *Server) SetWebsocketPort(port int)

func (*Server) Start

func (h *Server) Start()

func (*Server) WaitCloseSignal

func (h *Server) WaitCloseSignal(f func())