conn

Documentation

Index

• type Tcp
  • func NewTcp() *Tcp
  • func (t *Tcp) AddProtocol(f TcpHandle)
  • func (t *Tcp) AddRoute(cmd int, f TcpHandle)
  • func (t *Tcp) Start(host string, port int)
• type TcpEngine
  • func (t *TcpEngine) Listen()
• type TcpHandle
• type Web
  • func NewWeb() *Web
  • func (web *Web) AddRoute(path string, r base.Handle)
  • func (web *Web) AddService(i interface{})
  • func (web *Web) Listen(port int)
  • func (web *Web) ServeHTTP(rw http.ResponseWriter, req *http.Request)
  • func (web *Web) Wait() chan struct{}

Types

type Tcp

type Tcp struct {
	//解协议方法
	Protocol TcpHandle
	//解包方法
	Method map[int]TcpHandle
	//连接管理
	Conns map[string]TcpEngine
}

func NewTcp

func NewTcp() *Tcp

func (*Tcp) AddProtocol

func (t *Tcp) AddProtocol(f TcpHandle)

添加协议

func (*Tcp) AddRoute

func (t *Tcp) AddRoute(cmd int, f TcpHandle)

添加锁模块路由

func (*Tcp) Start

func (t *Tcp) Start(host string, port int)

type TcpEngine

type TcpEngine struct {
	Owner  *Tcp
	Handel net.Conn
	Log    *base.Logger
	Cache  []byte
	WC     chan []byte
	Pack   interface{}
}

func (*TcpEngine) Listen

func (t *TcpEngine) Listen()

type TcpHandle

type TcpHandle func(*TcpEngine)

type Web

type Web struct {
	//运行状态
	Run bool
	//Web请求数量
	Process chan struct{}
	// contains filtered or unexported fields
}

func NewWeb

func NewWeb() *Web

func (*Web) AddRoute

func (web *Web) AddRoute(path string, r base.Handle)

func (*Web) AddService

func (web *Web) AddService(i interface{})

添加服务

func (*Web) Listen

func (web *Web) Listen(port int)

func (*Web) ServeHTTP

func (web *Web) ServeHTTP(rw http.ResponseWriter, req *http.Request)

func (*Web) Wait

func (web *Web) Wait() chan struct{}

监听正在处理的进程完成