common

Documentation

Index

• Constants
• Variables
• func BytesToInt(b []byte) int
• func Call(m map[string]interface{}, name string, params ...interface{}) (result []reflect.Value, err error)
• func FileIsExist(FileName string) bool
• func GetRunDir() string
• func GetServiceName(str string) string
• func IntToBytes(n int) []byte
• func LogToFile()
• func Packet(message []byte) []byte
• func Unpack(buffer []byte, reader *[]byte) []byte
• type Client
  • func InitClient() *Client
  • func (this *Client) ConnWrite(data Msg)
  • func (this *Client) ConnWriteReturn(data Msg) (msg Msg)
  • func (this *Client) HeartBeat()
  • func (this *Client) InitMethods(m map[string]interface{})
  • func (this *Client) MsgReturn(data Msg)
  • func (this *Client) SericeInit()
  • func (this *Client) ServiceHandle(conn net.Conn)
  • func (this *Client) ServiceProcess(str []byte)
  • func (this *Client) ServiceWriteHandle(conn net.Conn)
• type ConfigModel
• type ConnInsID
  • func (self *ConnInsID) Get() int64
• type Msg
• type Resp
• type ServicesModel

Constants

const (
	ConstHeader         = "{28285252_hcaiyue_top_15159898}"
	ConstHeaderLength   = len(ConstHeader)
	ConstSaveDataLength = 8
	ConstFooter         = "{137621_woyaoyigebaojieshula_159687}"
	ConstFooterLength   = len(ConstFooter)
)

Variables

var ServiceName = GetServiceName(os.Args[0])

Functions

func BytesToInt

func BytesToInt(b []byte) int

字节转换成整形

func Call

func Call(m map[string]interface{}, name string, params ...interface{}) (result []reflect.Value, err error)

func FileIsExist

func FileIsExist(FileName string) bool

func GetRunDir

func GetRunDir() string

func GetServiceName

func GetServiceName(str string) string

func IntToBytes

func IntToBytes(n int) []byte

整形转换成字节

func LogToFile

func LogToFile()

func Packet

func Packet(message []byte) []byte

封包

func Unpack

func Unpack(buffer []byte, reader *[]byte) []byte

解包

Types

type Client

type Client struct {
	Conn      net.Conn
	Msgreturn map[string]chan Msg
	Methods   map[string]interface{}
	WriteChan chan []byte
}

func InitClient

func InitClient() *Client

func (*Client) ConnWrite

func (this *Client) ConnWrite(data Msg)

func (*Client) ConnWriteReturn

func (this *Client) ConnWriteReturn(data Msg) (msg Msg)

func (*Client) HeartBeat

func (this *Client) HeartBeat()

func (*Client) InitMethods

func (this *Client) InitMethods(m map[string]interface{})

func (*Client) MsgReturn

func (this *Client) MsgReturn(data Msg)

func (*Client) SericeInit

func (this *Client) SericeInit()

func (*Client) ServiceHandle

func (this *Client) ServiceHandle(conn net.Conn)

func (*Client) ServiceProcess

func (this *Client) ServiceProcess(str []byte)

func (*Client) ServiceWriteHandle

func (this *Client) ServiceWriteHandle(conn net.Conn)

type ConfigModel

type ConfigModel struct {
	Services []ServicesModel   `json:"services"`
	Routing  map[string]string `json:"routing"`
}

type ConnInsID

type ConnInsID struct {
	ID int64
	// contains filtered or unexported fields
}

var CID ConnInsID

func (*ConnInsID) Get

func (self *ConnInsID) Get() int64

type Msg

type Msg struct {
	Method string `json:"method"`
	Data   string `json:"data"`
	To     string `json:"to"`
	ID     string `json:"id"`
}

type Resp

type Resp struct {
	Data   string `json:"data"`
	Status int    `json:"status"`
	ID     string `json:"id"`
}

type ServicesModel

type ServicesModel struct {
	Name string `json:"name"`
	Run  int    `json:"run"`
}