phyer/siaga
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

只收到一条消息问题的修复

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-17 07:22:33 +08:00
parent bf01c59070
commit b1f57b71d0
1 changed files with 30 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
main.go
View File

@ -13,6 +13,8 @@ func main() {
cr := core.Core{} cr := core.Core{}
cr.Init() cr.Init()
cr.TickerInforocessChan = make(chan *core.TickerInfo) cr.TickerInforocessChan = make(chan *core.TickerInfo)
cr.CandlesProcessChan = make(chan *core.Candle)
cr.MaXProcessChan = make(chan *core.MaX)
cli, _ := cr.GetRedisLocalCli() cli, _ := cr.GetRedisLocalCli()
cr.RedisRemoteCli = cli cr.RedisRemoteCli = cli
@ -30,34 +32,34 @@ func main() {
md.LoopSubscribe(&cr, core.TICKERINFO_PUBLISH, vv) md.LoopSubscribe(&cr, core.TICKERINFO_PUBLISH, vv)
}(rdsLs[0]) }(rdsLs[0])
// // 订阅 redis Candles // 订阅 redis Candles
// go func(vv *core.RedisConfig) { go func(vv *core.RedisConfig) {
// allowed := os.Getenv("SIAGA_ACCEPTCANDLE") == "true" allowed := os.Getenv("SIAGA_ACCEPTCANDLE") == "true"
// if !allowed { if !allowed {
// return return
// } }
// fmt.Println("start subscribe core.TICKERINFO_PUBLISH") fmt.Println("start subscribe core.TICKERINFO_PUBLISH")
// md.LoopSubscribe(&cr, core.ALLCANDLES_PUBLISH, vv) md.LoopSubscribe(&cr, core.ALLCANDLES_PUBLISH, vv)
// }(rdsLs[0]) }(rdsLs[0])
//
// // 订阅 redis Max // 订阅 redis Max
// go func(vv *core.RedisConfig) { go func(vv *core.RedisConfig) {
// allowed := os.Getenv("SIAGA_ACCEPTMAX") == "true" allowed := os.Getenv("SIAGA_ACCEPTMAX") == "true"
// if !allowed { if !allowed {
// return return
// } }
// md.LoopSubscribe(&cr, core.ALLMAXES_PUBLISH, vv) md.LoopSubscribe(&cr, core.ALLMAXES_PUBLISH, vv)
// }(rdsLs[0]) }(rdsLs[0])
//
// // 下面这个暂时不运行, 在环境变量里把它关掉 // 下面这个暂时不运行, 在环境变量里把它关掉
// go func(vv *core.RedisConfig) { go func(vv *core.RedisConfig) {
// allowed := os.Getenv("SIAGA_ACCEPTSERIES") == "true" allowed := os.Getenv("SIAGA_ACCEPTSERIES") == "true"
// if !allowed { if !allowed {
// return return
// } }
// md.LoopSubscribe(&cr, core.ALLSERIESINFO_PUBLISH, vv) md.LoopSubscribe(&cr, core.ALLSERIESINFO_PUBLISH, vv)
// }(rdsLs[0]) }(rdsLs[0])
//
go func() { go func() {
md.TickerInfoProcess(&cr) md.TickerInfoProcess(&cr)
}() }()