utils

Documentation

Index

• func BytesToInt64(buf []byte) int64
• func BytesToStr(b []byte) string
• func Int64ToBytes(i int64) []byte
• func IsNil(i interface{}) bool
• func NChars(b []byte, n int) string
• func PathExists(path string) (bool, error)
• func Sm4Dec(value []byte) []byte
• func Sm4En(value []byte) []byte
• func StrToBytes(s string) []byte
• type GlobalObj
  • func (g *GlobalObj) Reload()
• type ServerPem
  • func GeneratePem(connId int64) (ServerPem, *sm2.PrivateKey)

Functions

func BytesToInt64

func BytesToInt64(buf []byte) int64

BytesToInt64 bytes字符转int64

func BytesToStr

func BytesToStr(b []byte) string

BytesToStr bytes转str字符

func Int64ToBytes

func Int64ToBytes(i int64) []byte

Int64ToBytes int64转bytes字符

func IsNil

func IsNil(i interface{}) bool

IsNil 判断interface{} 是否为空

func NChars

func NChars(b []byte, n int) string

NChars 创建相同字符的字符串

func PathExists

func PathExists(path string) (bool, error)

PathExists 判断一个文件是否存在

func Sm4Dec

func Sm4Dec(value []byte) []byte

Sm4Dec 解密

func Sm4En

func Sm4En(value []byte) []byte

Sm4En 加密

func StrToBytes

func StrToBytes(s string) []byte

StrToBytes 字符str转bytes

Types

type GlobalObj

type GlobalObj struct {
	/*
		Server
	*/
	TcpServer ziface.IServer //当前的全局Server对象
	Host      string         `json:"host"` //当前服务器主机IP
	Port      int            `json:"port"` //当前服务器主机监听端口号
	Name      string         `json:"name"` //当前服务器名称

	Version          string        `json:"version"`             //当前版本号
	MaxPacketSize    uint32        `json:"max-packet-size"`     //都需数据包的最大值
	MaxConn          int           `json:"max-conn"`            //当前服务器主机允许的最大链接个数
	WorkerPoolSize   int64         `json:"worker-pool-size"`    //业务工作Worker池的数量
	MaxWorkerTaskLen uint32        `json:"max-worker-task-len"` //业务工作Worker对应负责的任务队列最大任务存储数量
	MaxMsgChanLen    uint32        `json:"max-msg-chan-len"`    //SendBuffMsg发送消息的缓冲最大长度
	PairTime         time.Duration `json:"pair-time"`           //首次通信时长 默认60s

	HeartbeatInterval int `json:"heartbeat-interval"` // 心跳间隔时间检查

	/*
		连接限流设置
	*/
	Limiter int `json:"limiter"` //每秒连接数限制
}

GlobalObj 存储一切有关框架的全局参数，供其他模块使用 一些参数也可以通过 用户根据 config.json 来配置

var GlobalObject *GlobalObj

GlobalObject 定义一个全局的对象

func (*GlobalObj) Reload

func (g *GlobalObj) Reload()

Reload 读取用户的配置文件

type ServerPem

type ServerPem struct {
	UA        []byte `json:"ua"`
	Sign      []byte `json:"sign"`
	PublicKey []byte `json:"public-key"`
}

ServerPem 服务端的钥匙

func GeneratePem

func GeneratePem(connId int64) (ServerPem, *sm2.PrivateKey)

GeneratePem 获取服务端密钥对