Language: 🇨🇳 | 🇺🇸
go get github.com/GrumpyOmer/gotools@latest
「
goroutine
mysql
redis
es
configController
download
logCenter
」
_ "github.com/GrumpyOmer/gotools/goroutine"
SetGoroutineNumber(CPUCoreNum)
使用时通过调用 MakeTask(func(), *sync.WaitGroup) error 方法。需要将业务逻辑封装进 func() 函数内，以及生成的管控业务逻辑的WaitGroup两个作为参数传递进去，该方法会响应一个error来告知应用层任务是否成功丢进协程池(任务执行是异步的)，外部如果有业务需要必须自己用等待组的Wait()方法去等待业务执行结束。
var (
a int
b int
err1 error
err2 error
w = sync.WaitGroup{}
tempFunc1 = func() {
b = a+1
//自行传入错误和捕捉错误
err1 = errors.New("this is a demo")
}
tempFunc2 = func() {
b = a+1
//自行传入错误和捕捉错误
err2 = errors.New("this is a demo")
}
)
w.Add(2)
if test1:= goroutine.MakeTask(tempFunc1, &w); test1 != nil {
// 下发失败
w.Done()
fmt.Println(test1)
}
if test2:= goroutine.MakeTask(tempFunc2, &w); test2 != nil {
// 下发失败
w.Done()
fmt.Println(test2)
}
w.Wait()
fmt.Println(a)
fmt.Println(b)
//自行捕获连带func()一起传入协程池的err
fmt.Println(err1)
fmt.Println(err2)
首先在使用之前，需要通过ConfigInit([]byte)方法把db的配置以基于json字符串转换后的[]byte格式传递进来，转换前的json格式如下 (支持一主多从，配置自定义根据自身需求主库从库都能留空)：
{
"master": {
"user": "x",
"pass": "x",
"ip": "127.0.0.1",
"port": "456",
"db_name": "x",
"max_igle_conn": 1, // 设置空闲连接池中连接的最大数量
"max_open_conn": 1, // 设置打开数据库连接的最大数量
"conn_max_life_time": 1 // 设置了连接可复用的最大时间/秒
},
"slave": [
{
"user": "x",
"pass": "x",
"ip": "127.0.0.1",
"port": "456",
"db_name": "x",
"max_igle_conn": 1, // 设置空闲连接池中连接的最大数量
"max_open_conn": 1, // 设置打开数据库连接的最大数量
"conn_max_life_time": 1 // 设置了连接可复用的最大时间/秒
}
]
}实例的初始化会在主从库各自第一次调用GetMaster()和GetSlave()时进行，初始化成功后连接池相关配置也会建立，后续再调用以上两个方法就会直接从连接池种获取对应实例的长连接以供应用层使用了
{
"master": {
"host": "",
"port": "",
"user": "", // 兼容redis 6.0支持用户名登录
"pass": "",
"auth": "",
"db": 0,
"network": "tcp",
"max_idle": 1, // 最大的空闲连接数，表示即使没有redis连接时依然可以保持N个空闲的连接，而不被清除，随时处于待命状态。
"max_active": 1, // 最大的激活连接数，表示同时最多有N个连接
"idle_timeout": 1 // 最大的空闲连接等待时间，超过此时间后，空闲连接将被关闭 / 秒
},
"slave": [
{
"host": "x",
"port": "x",
"user": "x", // 兼容redis 6.0支持用户名登录
"pass": "x",
"auth": "",
"db": 0,
"network": "tcp",
"max_idle": 1, // 最大的空闲连接数，表示即使没有redis连接时依然可以保持N个空闲的连接，而不被清除，随时处于待命状态。
"max_active": 1, // 最大的激活连接数，表示同时最多有N个连接
"idle_timeout": 1 // 最大的空闲连接等待时间，超过此时间后，空闲连接将被关闭 / 秒
},
]
}获取到连接后的cmd操作参考redigo文档：https://pkg.go.dev/github.com/gomodule/redigo/redis#hdr-Connections
{
"address": [
"http://127.0.0.1:9200",
"http://127.0.0.2:9200",
"http://127.0.0.3:9200"
]
}获取到连接后的cmd操作参考文档：https://pkg.go.dev/github.com/olivere/elastic#section-readme
_ "github.com/GrumpyOmer/gotools/configController"
目前支持json/xml/.env三种配置文件格式,初始化后可通过对应的方法获取
GetJsonField(field string)
GetXmlField(field string)
GetEnvField(field string)
配置的热更新除了支持手动修改配置文件内容，还支持在程序动态运行过程中调用以下方法修改配置文件名称或目录来触发更新
// 自定义配置目录
SetPubDir(path string)
// 自定义xml文件名
SetXmlConfigName(configName string)
// 自定义json文件名
SetJsonConfigName(configName string)
// 自定义.env文件名
SetEnvConfigName(configName string)
配置文件内容格式如下:
[json] :
`
{
"test1": "1",
"test2": "2"
}
`
[xml] :
`
<?xml version="1.0" encoding="UTF-8" ?>
<root> //xml配置文件必须以root作为根元素，否则无法解析
<test1>1</test1>
<test2>2</test2>
</root>
`
[.env] :
`
test1="1"
test2="2"
`
以上成功序列化后为以下map
map[string]string{
"test1": "1",
"test2": "2",
}
实时下载进度查询,内部用协程异步处理
wc:= NewWc()
wc.DownloadFile(filepath string, url string) error
filepath: 保存路径+文件名
url: 远程图片url
error: 只需要关注下err是否返回当前wc已在使用中 （一个wc对象同时只能支持一个文件下载，批量同时下载可以创建多个wc对象）
图片文件下载过程中可以通过以下方法实时观察进度
获取文件下载百分比 （%）
wc.FetchProgress() int32
获取文件下载实际大小 （Bytes）
wc.FetchCurrent() uint64
获取文件总大小 （Bytes）
wc.FetchTotal() uint64
获取文件是否下载成功 （bool, error message）
wc.DownloadRes() (bool, error)
{
"Content":"omer test1", // 日志内容
"Location":"D:/server/gotools/logCenter/config_init_test.go:9", // 日志打印位置(文件/行)
"FunctionName":"github.com/GrumpyOmer/gotools/logCenter.TestConfigInit", // 日志打印函数名
"LogTime":"2022-09-19 18:24:05.5941501 +0800 CST m=+0.006999901" // 日志打印时间
}
使用非常简单，只需要调用Add(string)函数把日志内容传递进去，会有协程异步的去记录这些日志，不必担心写日志影响业务性能
Add("omer test1")
默认是每条日志都会强制写入磁盘，牺牲一部分磁盘性能最大化防止日志丢失。也可以手动关闭强制刷盘，把入盘时机交给文件系统
SaveFSync(true) //关闭强制刷盘