WebsocketDealer

Documentation

Overview

@Title WebsocketDealer.go @Description 实现websocket低成本call 需要客户端配合 @Author Dorbmon

Index

• Constants
• Variables
• func InitWebsocketDealer()
• type Conn
• type ConnectData
• type Ranger
• type Replier
  • func (z *Replier) Call(functionName string, args ...interface{}) (interface{}, error)
  • func (z *Replier) Return(data interface{}) error
• type Session
  • func NewSession() *Session
• type StandardCall
• type StandardReply
• type WebsocketDealFunction
• type WebsocketDealer
  • func New() (r WebsocketDealer)
  • func (z *WebsocketDealer) BindFunction(FunctionName string, Function WebsocketDealFunction) error
  • func (z *WebsocketDealer) BroadCast(ranger Ranger) error
  • func (z *WebsocketDealer) BroadCastIdRange(ranger Ranger, ids []uint64) error
  • func (z *WebsocketDealer) Handler(context *RWeb.Context)
• type WebsocketResponse

Constants

const (
	ModuleName    = "WebsocketDealer"
	ModuleVersion = 0.2
)

const (
	EventNewConnection = iota
)

const EventNum = 1

Variables

var NewConnectDataPool = sync.Pool{New: func() interface{} {
	return new(ConnectData)
}}

var Once sync.Once

Functions

func InitWebsocketDealer

func InitWebsocketDealer()

Types

type Conn

type Conn struct {
	// contains filtered or unexported fields
}

type ConnectData

type ConnectData struct {
	Session *Session
	Context *RWeb.Context
}

type Ranger

type Ranger func(data *ConnectData, replier *Replier) error

type Replier

type Replier struct {
	// contains filtered or unexported fields
}

func (*Replier) Call

func (z *Replier) Call(functionName string, args ...interface{}) (interface{}, error)

func (*Replier) Return

func (z *Replier) Return(data interface{}) error

type Session

type Session struct {
	Data       interface{}
	CreateTime int64
	// contains filtered or unexported fields
}

func NewSession

func NewSession() *Session

type StandardCall

type StandardCall struct {
	Function string          `json:"function"`
	Argument []interface{}   `json:"argument"`
	Id       jsoniter.Number `json:"id"`
	IsReply  bool            `json:"reply"` //只是保留，客户端不需要实现 若为Reply时，需要设置为true
}

type StandardReply

type StandardReply struct {
	Id   jsoniter.Number `json:"id"`
	Data string          `json:"data"`
}

type WebsocketDealFunction

type WebsocketDealFunction func(replier *Replier, session *Session, arguments []interface{})

type WebsocketDealer

type WebsocketDealer struct {
	OriginCheck func(ctx *RWeb.Context) bool

	Events event.System
	// contains filtered or unexported fields
}

func New

func New() (r WebsocketDealer)

func (*WebsocketDealer) BindFunction

func (z *WebsocketDealer) BindFunction(FunctionName string, Function WebsocketDealFunction) error

func (*WebsocketDealer) BroadCast

func (z *WebsocketDealer) BroadCast(ranger Ranger) error

func (*WebsocketDealer) BroadCastIdRange

func (z *WebsocketDealer) BroadCastIdRange(ranger Ranger, ids []uint64) error

func (*WebsocketDealer) Handler

func (z *WebsocketDealer) Handler(context *RWeb.Context)

*

使用此函数作为引擎的绑定函数

type WebsocketResponse

type WebsocketResponse struct {
	Id   jsoniter.Number `json:"id"`
	Data interface{}     `json:"data"`
}