ikit

基础功能库

• ikit
  • 安装
  • 功能
  • 使用文档
    • igoroutine
      • NewMulti(num int) *Multi
      • (m *Multi) Run(f func() error)
      • (m *Multi) Wait() []error
      • NewDivide(multi *Multi, opts ...DivideOption) *Divide
      • OptTotal(total int) DivideOption
      • OptPageSize(pageSize int) DivideOption
      • OptPage(page int) DivideOption
      • (d *Divide) GetTotal() int
      • (d *Divide) Run(f func(page, pageSize int) (total int, err error)) []error
    • ihttp
      • POST(opt *Options) (*Result, error)
      • GET(opt *Options) (*Result, error)
    • ilog
    • iutil
      • HanLess(s1, s2 string) bool
      • MinInt(a, b int) int
      • MaxInt(a, b int) int
      • LoadYaml(filename, subPath string, s interface{})
      • SetRootPath(r string)
      • GetRootPath() string
      • ToJson(input interface{}) string
      • Trim(str string) string
      • StringBytes(s string) []byte
      • BytesString(b []byte) string
      • StructMap(st interface{}, m map[string]interface{}) error

安装

go get -u github.com/weirwei/ikit

功能

• ihttp 请求
• ilog 日志
• iutil 工具包

使用文档

igoroutine

对go 的协程进行一些封装，提供便利的工具

• Multi: 协程控制器，可以控制单次任务的最大协程数
• Divide: 分批处理器，可以并发分批处理数据

NewMulti(num int) *Multi

创建一个Multi，控制协程数为num

---

(m *Multi) Run(f func() error)

Multi 并发执行f()

---

(m *Multi) Wait() []error

阻塞，等待协程执行完毕，返回错误信息

---

NewDivide(multi *Multi, opts ...DivideOption) *Divide

创建一个Divide，用于并发分批处理数据

---

OptTotal(total int) DivideOption

设置数据总量

---

OptPageSize(pageSize int) DivideOption

设置分页大小

---

OptPage(page int) DivideOption

设置分页

---

(d *Divide) GetTotal() int

获取数据总量

---

(d *Divide) Run(f func(page, pageSize int) (total int, err error)) []error

进行分组运行，入参为执行的函数，返回参数为错误信息

---

---

ihttp

发送http 请求 目前仅支持post 和get 请求 使用方式见 测试文件

POST(opt *Options) (*Result, error)

发送post 请求

---

GET(opt *Options) (*Result, error)

发送get 请求

---

---

ilog

简单封装了log 使用时仅直接调用方法即可

ilog.Infof("get a info %s", m)

---

---

iutil

网罗了一些好用的工具

HanLess(s1, s2 string) bool

比较两个汉字字符串，如果 s1 < s2 返回 true

• 拼音相同，字不同，比较编码大小
• 字相同，比较下一个字
• 有字 > 无字
• 字符串完全相同返回ture

---

MinInt(a, b int) int

返回较小值

---

MaxInt(a, b int) int

返回较大值

---

LoadYaml(filename, subPath string, s interface{})

加载应用根目录（可通过 SetRootPath(r string) 设置应用根目录路径）下相对路径为 subPath 下的 yaml 文件内容到 s 结构体。

---

SetRootPath(r string)

设置应用根目录路径，默认为 .

---

GetRootPath() string

返回当前应用根目录

---

ToJson(input interface{}) string

将结构体转化为 json 字符串，如果序列化失败，返回空字符串

---

Trim(str string) string

去除所有空白字符

---

StringBytes(s string) []byte

字符串转 byte 数组（使用同一片内存）

---

BytesString(b []byte) string

byte 数组转字符串（使用同一片内存）

---

---

StructMap(st interface{}, m map[string]interface{}) error

将结构体转 map，依赖 json 转换，需要 json tag