| | |
| | | |
| | | var api dbapi.EventPushApi |
| | | b, allRules := api.FindAllDetails() |
| | | logger.Info("初始化事件推送,查看所有规则组:", allRules) |
| | | //logger.Info("初始化事件推送,查看所有规则组:", allRules) |
| | | if !b { |
| | | logger.Error("查询时间推送规则失败!") |
| | | } |
| | |
| | | // 为每个url建立一个chan |
| | | if urlPool[url.Url] == nil { |
| | | urlPool[url.Url] = make(chan []byte,100) |
| | | logger.Info("初始化信息:",urlPool) |
| | | //logger.Info("初始化信息:",urlPool) |
| | | go GoPush(url.Url) |
| | | } |
| | | } |
| | |
| | | // ch = v.ch |
| | | // } |
| | | //} |
| | | logger.Info("chan信息:",urlPool[url]) |
| | | //logger.Info("chan信息:",urlPool[url]) |
| | | for { |
| | | select { |
| | | // case <-ctx.Done(): |
| | |
| | | //logger.Info("接收到数据",data.Cid) |
| | | //bytes,err1 := proto.Marshal(data) |
| | | go func(data []byte) { |
| | | logger.Info("数据长度为:",len(data)) |
| | | //logger.Info("数据长度为:",len(data)) |
| | | //if err1 != nil { |
| | | // logger.Info("序列化失败:",err1) |
| | | //} |
| | | start := time.Now() |
| | | logger.Debug("groutine"+url+"推送数据") |
| | | //logger.Debug("groutine"+url+"推送数据") |
| | | //bytes := []byte("ndfasojdfaidsos") |
| | | if err = sock.Send(data); err != nil { |
| | | Die("groutine"+url+"推送socket发送数据失败: ", err.Error()) |
| | |
| | | if err != nil { |
| | | Die("groutine"+url+"接收响应失败: ", err.Error(),pushTime,time.Since(start)) |
| | | } else { |
| | | logger.Debug("事件推送成功!groutine"+url+"收到响应",string(msg),pushTime,time.Since(start)) |
| | | //logger.Debug("事件推送成功!groutine"+url+"收到响应",string(msg),pushTime,time.Since(start)) |
| | | } |
| | | }(data) |
| | | default: |