# README
整合Lib
简介
目前本包支持了nacos,redis,mysql,elastic,pulsar,mqtt 这些服务中间件，另外集成了常用的yaml,json 等工具
pulsar 比kafka更为强大，所以只集成了pulsar,不再集成kafka. 本包的pulsar 采用异步发送,发送耗时可以忽略不不计。
pulsar 第一次创建producer会慢，可以把常用的topic写到pulsar的配置里，提前创建，消息每隔1秒后台发送一次,满100条发送1次,耗时无感知。
app.shutdown() 需要程序推出时调用，会做收尾工作。
elastic 简单易用，不需要很懂es,免去了拼一堆term的烦恼，已经能支持大部分查询场景
案例地址 案例 洁骏汽车服务有限公司
使用方法
-
依赖
nacos 配置中心，配置中心的数据，会在redis生成缓存，更新后，需要清理缓存，参考示例 nacos 监听事件订阅,订阅到事件后，删除缓存
Lib 对外提供删除key的方法
package main /* ctx := logger.GetContext(context.Background(), "test") client, e := nacos.GetEngine(ctx,"nacosConf") if e != nil { logger.AddError(zap.Error(e)) } key := client.DeleteCache(context.Background(), dataId, group, syncConf.Ns) */redis 缓存
-
环境变量
GO_ENV 作为读取配置文件的目录，例如 值为test ,则读取配置文件 /conf/test/app.yml
HOSTS: 127.0.0.1 nacosconf nacosconfredis pubmysql pubpulsar pubredis
-
配置文件
-
默认的配置放在
config/api.go 里，找不到配置文件，则使用这个配置，便于测试
-
配置文件
-
综合的app配置
-
pulsar 的topic配置
pulsar.yml 用来指定哪个topic，放到哪个集群 未指定clusert的，会按照 topic / 1000000 的整数，获取集群代号，按照topic_distribution 指定的配置获取集群
topicinit.yml 是为了加速第一次producer消息，可以不配置，pulsar 的客户端建立producter 第一次会比较慢，这个配置是为了解决第一加载的问题，没有必要，不用配置
参考 middleware\pulsarL\test\conf\test\pulsar.yml
参考 topicinit
-
-
工具包
-
Json工具包使用
package main /* import ( "strings" "fmt" myjson "github.com/flyerxp/lib/utils/json" ) func main(){ tmp := map[string]string{ "a":"b", } r,e:=myjson.Encode(tmp) fmt.Println(string(r),e) } */ -
Yaml工具包使用
package main /* import ( "fmt" myyml "github.com/flyerxp/lib/utils/yaml" ) func main() { var defaultConfig = []byte(` a: b `) tmp := map[string]string{} //myyml.DecodeByFile("app.yml", &tmp) myyml.DecodeByBytes(defaultConfig, tmp) fmt.Println(string(defaultConfig)) }*/ -
Logger使用
go.uber.org/zap 使用此lib记录日志
package main /* logger.AddError(zap.Error(errors.New("aaaaaaaa"))) logger.AddWarn(zap.Error(errors.New("bbbbb"))) logger.AddNotice(zap.String("a", "bbbbbbbbbbbb")) logger.WriteLine() //logger.WriteErr() //立即写入错误 */
中间件使用
```Go
package main
/*
import (
"context"
"fmt"
"github.com/flyerxp/lib/app"
"github.com/flyerxp/lib/middleware/elastic"
"github.com/flyerxp/lib/middleware/mysqlL"
"github.com/flyerxp/lib/middleware/pulsarL"
"github.com/flyerxp/lib/middleware/redisL"
"time"
)
type TestStt struct {
Id int `json:"id"`
}
func main() {
ctx := logger.GetContext(context.Background(), "test")
//time.Sleep(time.Second * 1)
defer app.Shutdown(context.Background())
start := time.Now()
count := 10000
objRedis, _ := redisL.GetEngine(ctx,"pubRedis")
tmp2 := new(TestStt)
fmt.Println("github.com/flyerxp")
fmt.Println("win11 环境，开始了 ")
for i := 0; i <= count; i++ {
objRedis.C.Get(ctx, "a")
}
fmt.Printf("redis 读取 10000次耗时 %d 毫秒\n", time.Since(start).Milliseconds())
start = time.Now()
mysql, _ := mysqlL.GetEngine(ctx,"pubMysql")
for i := 0; i <= count; i++ {
err := mysql.GetDb().GetContext(ctx,tmp2, `select id from news_info limit 1`)
if err != nil {
fmt.Println(tmp2, err)
}
}
fmt.Printf("mysql 数据库读取 10000次耗时 %d 毫秒\n", time.Since(start).Milliseconds())
start = time.Now()
for i := 0; i <= count; i++ {
pulsarL.Producer(ctx,&pulsarL.OutMessage{
Topic: 0,
TopicStr: "test",
Content: "太牛了",
Properties: map[string]string{"a": "b"},
Delay: 0,
})
}
fmt.Printf("pulsar 发消息 10000次耗时 %d 毫秒\n", time.Since(start).Milliseconds())
// es 相关，更多的用法见测试用例
ec, _ := elastic.GetEngine(ctx,"pubEs")
e := ec.GetElastic()
e.SetTable("admin")
ss := e.GetSearchService(ctx) //调用这个方法的时候,参数要从外面传过来ctx
ss.Cols([]string{"id", "name", "parent_id", "root_id"})
ss.WhereIn("id", ss.FieldIntArray([]int{5, 6}))
p := make([]TestStt, 0)
ss.Rows(&p)
fmt.Println(p)
}
*/
```
