电路板的制作
Name: sms_bot-api
Host: 127.0.0.1
Port:8888
Database:
Pkg:"./internal/svc"
DriverName:"mysql"
DSN:"root:98123456@tcp(192.168.4.240:3306)/qe?charset=utf8mb4&parseTime=true&loc=Asia%2FShanghai"
Logger:
Path:"./tmp/sql.log"电子眼镜
MaxAge:180
Interval:2
Redis:
Host: 192.168.4.240:6379
Pass:""
DB:0
ExpireTime:3
go-zero项⽬中 svc⽬录内容
package svc
import(
"context"
"/go-redis/redis/v8"
_"/go-sql-driver/mysql"
"/kotlin2018/mbt"
rotatelogs "/lestrrat-go/file-rotatelogs"
"io"
"log"
"path"
"sms_bot/internal/config"
"time"
)
英姿带
// 服务依赖项(⽐如说: 加载配置⽂件，数据库连接句柄，⾃定义全局错误信息) type ServiceContext struct{
Config config.Config
Redis *redis.Client
}
func NewServiceContext(c config.Config)*ServiceContext {
conf :=&mbt.Database{
Pkg: c.Database.Pkg,
DriverName: c.Database.DriverName,
DSN: c.Database.DSN,
Logger:&mbt.Logger{
Path: c.Logger.Path,
MaxAge: c.Logger.MaxAge,
Interval: c.Logger.Interval,
PrintSql:true,
},
}
mbt.New(conf).Register(initMapper()).SetOutPut(initLogger(c.Logger.Path, c.Logger.MaxAge, c.Logger.Interval)).Run()
client := redis.NewClient(&redis.Options{
Addr: c.Redis.Host,
Password: c.Redis.Pass,
DB: c.Redis.DB,
})
_, err := client.Ping(context.Background()).Result()电线固定座
if err !=nil{
if err !=nil{
log.Fatalln("请配置redis服务")
}
return&ServiceContext{
Config: c,
Redis: client,
}
}
func initMapper()map[interface{}]interface{}{
h := mbt.H{
&TSmsbotDao:&TSmsbot{},// sms机器⼈表
&TTaskDao:&TTask{},// 任务表
滚装码头&TTaskTypeDao:&TTaskType{},// 任务类型表
}
return h
}
func initLogger(logFilePath string, maxAge, interval int) io.Writer { writer,_:= rotatelogs.New(
path.Join(logFilePath+"-%Y-%m-%d.log"),//拼接成log⽂件名
rotatelogs.WithLinkName(logFilePath),
rotatelogs.WithMaxAge(time.Duration(maxAge)*time.Hour),
rotatelogs.WithRotationTime(time.Duration(interval)*time.Hour), )
数据库探针
return writer
}
豫公网安备41160202000603
站长QQ:729038198
关于我们
投诉建议