goutil

README

goutil

Golang 公共库

Documentation

Index

• Variables
• func AesDecrypt(cryted string, key string) string
• func AesEncrypt(orig string, key string) string
• func GetRandomString(length int) string
• func InitLog(stdout bool, path string, prefix string, level string)
• func PKCS7Padding(ciphertext []byte, blocksize int) []byte
• func PKCS7UnPadding(origData []byte) []byte
• type AMQPPrx
  • func SetupQMAPPrx(uri, tag string) *AMQPPrx
  • func (prx *AMQPPrx) Publish(excName, key string, body []byte) error
  • func (prx *AMQPPrx) PublishEx(excName, key string, mandatory, immediate bool, mimeType string, body []byte) error
  • func (prx *AMQPPrx) SetupConsume(queueName, routeKey, excName string) (<-chan amqp.Delivery, error)
  • func (prx *AMQPPrx) SetupConsumeEx(queueName, routeKey, excName string, ...) (<-chan amqp.Delivery, error)
  • func (prx *AMQPPrx) SetupPublish(excName, excType string, durable, autoDelete, noWait bool) error
• type ConfigPrx
  • func SetupConfigPrx(fname string, ftype string) *ConfigPrx
  • func (conf *ConfigPrx) GetSection(name string) map[string]interface{}
• type MQTTPrx
  • func SetupMQTTPrx(uri, user, passwd, cliid string) *MQTTPrx
  • func (prx *MQTTPrx) Pub(topic string, qos byte, payload interface{}) error
  • func (prx *MQTTPrx) Sub(topic string, qos byte) error
• type MongoPrx
  • func SetupMongoPrx(connstr string, dbname string) *MongoPrx
• type TokenPrx
  • func SetupTokenPrx(redisAddr string, redisPasswd string, db int) *TokenPrx
  • func (prx *TokenPrx) CheckToken(token string) bool
  • func (prx *TokenPrx) DelToken(token string)
  • func (prx *TokenPrx) GenToken(data string, seconds int) string
  • func (prx *TokenPrx) GetTokenData(token string) string

Variables

var Log = logrus.New()

Log :

Functions

func AesDecrypt

func AesDecrypt(cryted string, key string) string

AesDecrypt :

func AesEncrypt

func AesEncrypt(orig string, key string) string

AesEncrypt :

func GetRandomString

func GetRandomString(length int) string

GetRandomString : 生成随机字符串

func InitLog

func InitLog(stdout bool, path string, prefix string, level string)

InitLog :

func PKCS7Padding

func PKCS7Padding(ciphertext []byte, blocksize int) []byte

PKCS7Padding : 补码,AES加密数据块分组长度必须为128bit(byte[16])，密钥长度可以是128bit(byte[16])、192bit(byte[24])、256bit(byte[32])中的任意一个。

func PKCS7UnPadding

func PKCS7UnPadding(origData []byte) []byte

PKCS7UnPadding :

Types

type AMQPPrx

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

AMQPPrx :

func SetupQMAPPrx

func SetupQMAPPrx(uri, tag string) *AMQPPrx

SetupQMAPPrx 创建Rabbitmq链接和通道，并返回操作代理

func (*AMQPPrx) Publish

func (prx *AMQPPrx) Publish(excName, key string, body []byte) error

Publish :

func (*AMQPPrx) PublishEx

func (prx *AMQPPrx) PublishEx(excName, key string, mandatory, immediate bool, mimeType string, body []byte) error

PublishEx :

func (*AMQPPrx) SetupConsume

func (prx *AMQPPrx) SetupConsume(queueName, routeKey, excName string) (<-chan amqp.Delivery, error)

SetupConsume ：

func (*AMQPPrx) SetupConsumeEx

func (prx *AMQPPrx) SetupConsumeEx(queueName, routeKey, excName string, durable, autoDelete, exclusive, noWait bool) (<-chan amqp.Delivery, error)

SetupConsumeEx ：

func (*AMQPPrx) SetupPublish

func (prx *AMQPPrx) SetupPublish(excName, excType string, durable, autoDelete, noWait bool) error

SetupPublish ：

type ConfigPrx

type ConfigPrx struct {
	*viper.Viper
}

ConfigPrx :

func SetupConfigPrx

func SetupConfigPrx(fname string, ftype string) *ConfigPrx

SetupConfigPrx :

func (*ConfigPrx) GetSection

func (conf *ConfigPrx) GetSection(name string) map[string]interface{}

GetSection :

type MQTTPrx

type MQTTPrx struct {
	MQTT.Client
	URI      string
	User     string
	Passwd   string
	ClientID string
	MsgChn   chan MQTT.Message
}

MQTTPrx :

func SetupMQTTPrx

func SetupMQTTPrx(uri, user, passwd, cliid string) *MQTTPrx

SetupMQTTPrx :

func (*MQTTPrx) Pub

func (prx *MQTTPrx) Pub(topic string, qos byte, payload interface{}) error

Pub : topic: "/" - 主题层级分隔符;

"#" - 多层通配符, 须是主题过滤器的最后一个字符;
"+" - 单层通配符
"$" - 通配符,只要不是放在主题的最开头,表示匹配一个字符;放在开头，表示匹配开头

qos: 0-最多一次的传输; 1-至少一次的传输; 2-只有一次的传输

func (*MQTTPrx) Sub

func (prx *MQTTPrx) Sub(topic string, qos byte) error

Sub : topic: "/" - 主题层级分隔符;

"#" - 多层通配符, 须是主题过滤器的最后一个字符;
"+" - 单层通配符
"$" - 通配符,只要不是放在主题的最开头,表示匹配一个字符;放在开头，表示匹配开头

qos: 0-最多一次的传输; 1-至少一次的传输; 2-只有一次的传输

type MongoPrx

type MongoPrx struct {
	*mongo.Client
	DB *mongo.Database
}

MongoPrx :

func SetupMongoPrx

func SetupMongoPrx(connstr string, dbname string) *MongoPrx

SetupMongoPrx :

type TokenPrx

type TokenPrx struct {
	*redis.Client
}

TokenPrx :

func SetupTokenPrx

func SetupTokenPrx(redisAddr string, redisPasswd string, db int) *TokenPrx

SetupTokenPrx :

func (*TokenPrx) CheckToken

func (prx *TokenPrx) CheckToken(token string) bool

CheckToken : 获取Token

func (*TokenPrx) DelToken

func (prx *TokenPrx) DelToken(token string)

DelToken : 获取Token

func (*TokenPrx) GenToken

func (prx *TokenPrx) GenToken(data string, seconds int) string

GenToken : 获取Token

func (*TokenPrx) GetTokenData

func (prx *TokenPrx) GetTokenData(token string) string

GetTokenData : 获取Token