mpf

README

代码结构

目录

• api: 外部接口
• mpcache: 缓存
• mpconstant: 常量
• mpdb: 数据库
• mpdp: 设计模式
• mpencrypt: 加解密
• mperr: 自定义错误
• mpframe: 框架
• mplog: 日志
• mpmodule: 模块
• mpmq: 消息队列
• mprequest: 请求
• mpresponse: 响应
• mpserver: 服务
• mpvalidator: 数据校验器

文件

Documentation

Overview

Package mpf bootstrap User: 姜伟 Time: 2020-02-19 04:59:21

Package mpf config User: 姜伟 Time: 2020-02-19 05:14:34

Package mpf env User: 姜伟 Time: 2020-02-19 05:14:47

Package mpf hash User: 姜伟 Time: 2020-02-19 05:30:04

Package mpf http User: 姜伟 Time: 2020-02-19 05:30:24

Package mpf json User: 姜伟 Time: 2020-02-19 05:38:11

Package mpf tool User: 姜伟 Time: 2020-02-19 05:41:08

Index

• Constants
• func EnvDirConfigs() string
• func EnvDirRoot() string
• func EnvProjectKey() string
• func EnvProjectKeyModule() string
• func EnvProjectModule() string
• func EnvProjectTag() string
• func EnvServerDomain() string
• func EnvServerHost() string
• func EnvServerPort() int
• func EnvServerType() string
• func EnvType() string
• func HTTPAddReqHeader(req *fasthttp.Request, headers map[string]string)
• func HTTPCreateParams(data map[string]string, sortType string, encodeType int) string
• func HTTPReqID() string
• func HashCrc32(str string, key string) string
• func HashMd5(str string, key string) string
• func HashMd5Sign(data string, secret string) string
• func HashMd5Verify(data string, secret string, sign string) bool
• func HashSha1(str string, key string) string
• func HashSha256(str string, key string) string
• func HashSha512(str string, key string) string
• func JSONMarshal(data interface{}) string
• func JSONUnmarshal(data []byte, obj interface{}) error
• func JSONUnmarshalMap(data string) (map[string]interface{}, error)
• func LoadBoot(bs *bootstrap)
• func NewBootstrap() *bootstrap
• func NewConfig() *configViper
• func ToolCreateNonceStr(length int, dataType string) string
• func ToolCreateRandNum(startNum, maxNum int) int
• func ToolCreateReqID(reqID string) string
• func ToolGetReqID() string
• func ToolPack(data interface{}) ([]byte, error)
• func ToolUnpack(data []byte, item *interface{}) error
• type HTTPParam
• type HTTPParamKey
  • func NewHTTPParamKey(data map[string]string) *HTTPParamKey
  • func (pk HTTPParamKey) Less(i, j int) bool
• type HTTPParamSorter
  • func (ps HTTPParamSorter) Len() int
  • func (ps HTTPParamSorter) Swap(i, j int)
• type HTTPParamVal
  • func NewHTTPParamVal(data map[string]string) *HTTPParamVal
  • func (pv HTTPParamVal) Less(i, j int) bool
• type HTTPResp
  • func HTTPSendReq(client *fasthttp.Client, req *fasthttp.Request, timeout time.Duration) HTTPResp
  • func NewHTTPResp() HTTPResp
• type HTTPRespResult
  • func NewHTTPRespResult() HTTPRespResult
• type XMLMap
  • func (m XMLMap) MarshalXML(e *xml.Encoder, start xml.StartElement) error
  • func (m *XMLMap) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error

Constants

const (
	// EnvTypeDev 环境类型-测试
	EnvTypeDev = "dev"
	// EnvTypeProduct 环境类型-生产
	EnvTypeProduct = "product"

	// EnvServerTypeAPI 服务类型-API
	EnvServerTypeAPI = "api"
	// EnvServerTypeRPC 服务类型-RPC
	EnvServerTypeRPC = "rpc"
	// EnvServerModeDaemon 服务运行模式-守护进程
	EnvServerModeDaemon = "daemon"
	// EnvServerModeChild 服务运行模式-子进程
	EnvServerModeChild = "child"

	// GoEnvReqID 请求ID
	GoEnvReqID = "MP_REQ_ID"
	// GoEnvDirRoot 项目根目录
	GoEnvDirRoot = "MP_DIR_ROOT"
	// GoEnvEnvType 环境类型
	GoEnvEnvType = "MP_ENV_TYPE"
	// GoEnvProjectTag 项目标识
	GoEnvProjectTag = "MP_PROJECT_TAG"
	// GoEnvProjectModule 项目模块
	GoEnvProjectModule = "MP_PROJECT_MODULE"
	// GoEnvProjectKey 项目代号,由环境类型+项目标识组成
	GoEnvProjectKey = "MP_PROJECT_KEY"
	// GoEnvProjectKeyModule 项目模块代号,由项目标识+项目模块组成
	GoEnvProjectKeyModule = "MP_PROJECT_KEY_MODULE"
	// GoEnvServerMode 服务运行模式 daemon:守护进程 child:子进程
	GoEnvServerMode = "MP_SERVER_MODE"
)

const (
	// XMLKeyName KeyName
	XMLKeyName = "_name"
	// XMLKeyCData KeyCData
	XMLKeyCData = "_cdata"
)

Functions

func EnvDirConfigs

func EnvDirConfigs() string

EnvDirConfigs DirConfigs

func EnvDirRoot

func EnvDirRoot() string

EnvDirRoot DirRoot

func EnvProjectKey

func EnvProjectKey() string

EnvProjectKey ProjectKey

func EnvProjectKeyModule

func EnvProjectKeyModule() string

EnvProjectKeyModule ProjectKeyModule

func EnvProjectModule

func EnvProjectModule() string

EnvProjectModule ProjectModule

func EnvProjectTag

func EnvProjectTag() string

EnvProjectTag ProjectTag

func EnvServerDomain

func EnvServerDomain() string

EnvServerDomain ServerDomain

func EnvServerHost

func EnvServerHost() string

EnvServerHost ServerHost

func EnvServerPort

func EnvServerPort() int

EnvServerPort ServerPort

func EnvServerType

func EnvServerType() string

EnvServerType ServerType

func EnvType

func EnvType() string

EnvType Type

func HTTPAddReqHeader

func HTTPAddReqHeader(req *fasthttp.Request, headers map[string]string)

HTTPAddReqHeader 添加请求的头信息

func HTTPCreateParams

func HTTPCreateParams(data map[string]string, sortType string, encodeType int) string

HTTPCreateParams 生成请求参数,生成的结果按照键名的ASCII码排序

data map[string]string 原数据
sortType string 排序类型 none:不排序 key:键名升序 val:键值升序
encodeType int 编码类型
  1:url_encode(k1=v1&k2=v2&...)
  2:json
  3:xml
  4:k1=v1&k2=v2&...
  5:k1v1k2v2...

func HTTPReqID

func HTTPReqID() string

HTTPReqID 生成请求ID

func HashCrc32

func HashCrc32(str string, key string) string

HashCrc32 Crc32

func HashMd5

func HashMd5(str string, key string) string

HashMd5 Md5

func HashMd5Sign

func HashMd5Sign(data string, secret string) string

HashMd5Sign md5签名

func HashMd5Verify

func HashMd5Verify(data string, secret string, sign string) bool

HashMd5Verify 验证md5签名

func HashSha1

func HashSha1(str string, key string) string

HashSha1 Sha1

func HashSha256

func HashSha256(str string, key string) string

HashSha256 Sha256

func HashSha512

func HashSha512(str string, key string) string

HashSha512 Sha512

func JSONMarshal

func JSONMarshal(data interface{}) string

JSONMarshal 序列化

func JSONUnmarshal

func JSONUnmarshal(data []byte, obj interface{}) error

JSONUnmarshal 反序列化

func JSONUnmarshalMap

func JSONUnmarshalMap(data string) (map[string]interface{}, error)

JSONUnmarshalMap 解析未知结构json字符串为map

func LoadBoot

func LoadBoot(bs *bootstrap)

LoadBoot 初始化加载

func NewBootstrap

func NewBootstrap() *bootstrap

NewBootstrap 实例化

func NewConfig

func NewConfig() *configViper

NewConfig 获取配置单例

func ToolCreateNonceStr

func ToolCreateNonceStr(length int, dataType string) string

ToolCreateNonceStr 生成随机字符串

length int 生成字符串的长度
dataType string 数据类型
  lower: 小写字母
  numlower: 数字和小写字母
  total: 数字和大小写字母

func ToolCreateRandNum

func ToolCreateRandNum(startNum, maxNum int) int

ToolCreateRandNum 生成随机整数

startNum int 起始值
maxNum int 最大值

func ToolCreateReqID

func ToolCreateReqID(reqID string) string

ToolCreateReqID 生成请求ID

func ToolGetReqID

func ToolGetReqID() string

ToolGetReqID 获取请求ID

func ToolPack

func ToolPack(data interface{}) ([]byte, error)

ToolPack 压缩数据

func ToolUnpack

func ToolUnpack(data []byte, item *interface{}) error

ToolUnpack 解压数据

Types

type HTTPParam

type HTTPParam struct {
	Key string
	Val string
}

HTTPParam HTTPParam

type HTTPParamKey

type HTTPParamKey struct {
	HTTPParamSorter
}

HTTPParamKey HTTPParamKey

func NewHTTPParamKey

func NewHTTPParamKey(data map[string]string) *HTTPParamKey

NewHTTPParamKey NewHTTPParamKey

func (HTTPParamKey) Less

func (pk HTTPParamKey) Less(i, j int) bool

Less Less

type HTTPParamSorter

type HTTPParamSorter struct {
	Params []HTTPParam
}

HTTPParamSorter HTTPParamSorter

func (HTTPParamSorter) Len

func (ps HTTPParamSorter) Len() int

Len Len

func (HTTPParamSorter) Swap

func (ps HTTPParamSorter) Swap(i, j int)

Swap Swap

type HTTPParamVal

type HTTPParamVal struct {
	HTTPParamSorter
}

HTTPParamVal HTTPParamVal

func NewHTTPParamVal

func NewHTTPParamVal(data map[string]string) *HTTPParamVal

NewHTTPParamVal NewHTTPParamVal

func (HTTPParamVal) Less

func (pv HTTPParamVal) Less(i, j int) bool

Less Less

type HTTPResp

type HTTPResp struct {
	RespCode      uint                `json:"resp_code"` // 响应状态码
	Msg           string              `json:"msg"`       // 错误信息
	Content       string              `json:"content"`   // 响应内容
	Body          []byte              // 响应体源数据
	ContentLength int                 `json:"content_length"` // 响应内容长度
	StatusCode    int                 `json:"status_code"`    // HTTP状态码
	Headers       map[string]string   `json:"headers"`        // 响应头
	Cookies       map[string][]string `json:"cookies"`        // cookies
}

HTTPResp HTTPResp

func HTTPSendReq

func HTTPSendReq(client *fasthttp.Client, req *fasthttp.Request, timeout time.Duration) HTTPResp

HTTPSendReq 发送http请求

func NewHTTPResp

func NewHTTPResp() HTTPResp

NewHTTPResp NewHTTPResp

type HTTPRespResult

type HTTPRespResult struct {
	ReqID string                 `json:"req_id"` // 请求ID
	Time  int64                  `json:"time"`   // 请求时间
	Code  uint                   `json:"code"`   // 状态码
	Msg   string                 `json:"msg"`    // 错误信息
	Data  map[string]interface{} `json:"data"`   // 响应数据
}

HTTPRespResult HTTPRespResult

func NewHTTPRespResult

func NewHTTPRespResult() HTTPRespResult

NewHTTPRespResult NewHTTPRespResult

type XMLMap

type XMLMap map[string]string

XMLMap XMLMap

func (XMLMap) MarshalXML

func (m XMLMap) MarshalXML(e *xml.Encoder, start xml.StartElement) error

MarshalXML 重写xml编码方法 用法: <pre>

xmlMap := map[string]string{
    "key1": "One",
    "key2": "Two",
}

mapStr, _ := xml.Marshal(tool.XmlMap(xmlMap)) </pre>

func (*XMLMap) UnmarshalXML

func (m *XMLMap) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error

UnmarshalXML 重写xml解码方法 用法: <pre> newMap := make(map[string]string) xml.Unmarshal(mapStr, (*tool.XmlMap)(&newMap)) </pre>