gosml 做为 [ GOLANG实现，保留了大部分工具类（Https,SqlTemplate,ManagedQueue,Cron,Scheduler,gdbc），可基于配置快速开发restful接口
** SqlTemplate 快速方便的数据查询模板，模板配置支持存放数据库,或本地文件远程文件。
** Https 链式风格，对各类查询，参数[url参数，表头参数，body参数，文件流]等进行封装方便统一操作
** Cron cron表达示，实现95%以上，并且增加符合国人的书写习惯，如周数字表示等设定
** ManagedQueue 线程队列管理器，支持指定协程数，队列大小，运行任务监控统计、重新下发等
** Scheduler 调度器，支持cron表达款任务，秒级精确，轻松支持万级以上任务调度，支持周期调度，单任务调度，延时调度
** Gdbc 类JDBC操作，支持回调处理，提供常用查询api
快速使用 gddc
package main
import (
_ "github.com/go-sql-driver/mysql"
"github.com/huangwenjimmy/gosml"
"fmt"
)
func main1(){
//init sml sqltemplate
stq:=gosml.Init(gosml.Ds{Id:"defJt",Url:"root:rooxxx@tcp(192.168.1.xxx:3306)/xxxx",DbType:"mysql"})
stq.Cache(gosml.NewDefaultCacheManager()) //添加缓存
result_map,_:=stq.Gdbcs["defJt"].QueryForMap("select 1 as a where 1=?",1)
fmt.Println(result_map) //return map[string]interface{}
result_list,_:=stq.Gdbcs["defJt"].QueryForList("select * from (select 1 as a union all select 2 as a) t where a=$1",2)
fmt.Println(result_list)//result []map[string]interface{}
stq.Gdbcs["defJt"].QueryForCall("select * from sml_if where limit ?",func(row map[string]interface{}) (bool,error){
//适用于导出等流式操作,返回bool error供上级判断
return true,nil
},10000)
//sml template api支持配置sql参考java-api
result_multi,_:=stq.Query("test-if",map[string]string{"id":"as","b":"hw","age":"30","time":"2020-04-22T10:06:04Z","dd":"1,2,3","times":"201904,201908"})
fmt.Println(result_multi)//result map list page
}crontab表达示实现，支持秒级，下次执行时间，表达示内容
- ss mi HH day-of-mon Mon day-of-w Year[可不选]
- 0 0/5 * * * ? //从0点，每隔5分钟执行
- 0 0,30 9-20 * * ? //每天9点到20点,0分和30分执行
- 0 0 9 1 * ? //每月1号9点整执行
- 0 40 23 L * ? //每月最后一天23:40分执行
- 0 0 9 ? * MON //每周一9点整执行
- 0 0 9 ? * FRIL //每月最后一个周期五9点整执行
- 0 0 9 1 JUN-DEC * //7月至12月每1号9点整执行
package main
import (
"github.com/huangwenjimmy/gosml"
"github.com/huangwenjimmy/gosml/queue"
"fmt"
)
func main(){
cp:=queue.NewCronParser("0 1 9 * * ?")
flag:=cp.Valid(gosml.ConvertStrToDate("20200428090100"))
fmt.Println(flag) //true
//trigger
tri:=queue.NewTrigger("0 1 9 * * ?")
fmt.Println(tri.GetNext())//当前时间下次执行时间
fmt.Println(tri.GetNextDate(gosml.ConvertStrToDate("20200428090100")))//指定时间下次执行时间
}调度器+线程管理器结合使用，高效流转各内部环节任务管理
package main
import (
"github.com/huangwenjimmy/gosml/queue"
"fmt"
"time"
)
func main(){
ds:=queue.NewScheduler("defaultScheduler",10,10000)//创建调度器指定10个协程，10000个队列深度
ds.InitScheduler()//初始化
//下发周期任务
ds.SchedulerJob("3/5 * * * * ?",&DJ{"job1"})//添加结构体任务 implements queue.Job method ToString|Run
//下发方法任务
ds.SchedulerFuncJob("0 0/5 * * * ?","funcJob1",func(){
fmt.Println("funcJob1",time.Now())
})
//执行一次性任务
//ds.ExecuteTask(task)//task implements queue.Task
time.Sleep(time.Hour)
}
type DJ struct{
name string
}
func (dj *DJ) ToString() string{
return dj.name
}
func (dj *DJ) Run() error{
fmt.Println(dj.name,time.Now())
return nil
}支持常见操作
package main
import (
"github.com/huangwenjimmy/gosml"
"fmt"
"time"
"strings"
)
func main(){
//添加表头 basic 认证 指定连接读写超时时间
https:=gosml.NewGetHttps("https://localhost:16003/bus/sml/query/if-cfg-interMngLike").
Header("content-type","application/json").
BasicAuth("user:passwd").
ConnectTimeout(time.Second).RWTimeout(time.Second).
Param("ids","10001").Param("name","测试")
https.Execute()
//支持对返回结果进行多种操作,获取流，反序列化，下载等
fmt.Println(https.GetBodyString())//https.GetBodyBytes()|https.GetBodyTo(writer)|https.GetBodyToFile(*File)
//post-body请求，body支持 string []byte io.reader
https=gosml.NewPostBodyHttps("https://localhost:16003/bus/sml/query/if-cfg-interMngLike").Body(`{"ids":"1001","name":"测试"}`)
https.Execute()
fmt.Println(https.GetBodyString())
//post-upload上传 需要指定Multipart 表单参数Param url参数请自行拼接至url 通过gosml.UpFile 可添加多个文件
https=gosml.NewPostFormHttps("https://localhost:16003/bus/sml/web/file/upload").Multipart().
Param("filepath","../logs").
UpFile(&gosml.UpFile{FormName:"file",FileName:"hello1.txt",Input:strings.NewReader("helloworld234天啊\n我是上传的内容")})
https.Execute()
fmt.Println(https.Response.Status,https.GetBodyString())
}