| | |
|---|
| | | func Dealextern() { |
|---|
| | | for { |
|---|
| | | select { |
|---|
| | | case esmsg:= <-SdkMap["es"]: |
|---|
| | | fmt.Println(esmsg) |
|---|
| | | case <-SdkMap["es"]: |
|---|
| | | fmt.Println("es finanl sdk!") |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | //sdk数据分发器 |
|---|
| | | func SdkSendTopic(sdkmsg protomsg.SdkMessage) (sdksend string) { |
|---|
| | | if int(sdkmsg.Tasklab.Index) < len(sdkmsg.Tasklab.Sdkinfos) { |
|---|
| | | sdksend = sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Sdkid |
|---|
| | | sdksend = sdkmsg.Tasklab.Sdkinfos[sdkmsg.Tasklab.Index].Ipcid |
|---|
| | | } else { |
|---|
| | | sdksend = "es" |
|---|
| | | } |
|---|
| | |
|---|
| | | if err != nil { |
|---|
| | | fmt.Println("proto marshal error ", err) |
|---|
| | | continue |
|---|
| | | } |
|---|
| | | |
|---|
| | | fmt.Printf("从管道sdkid=%s 接受数据 %d\n", sdkid, len(data)) |
|---|
| | | fmt.Println() |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
