sdk/sdk.go
@@ -101,8 +101,8 @@ func Dealextern() { for { select { case esmsg:= <-SdkMap["es"]: fmt.Println(esmsg) case <-SdkMap["es"]: fmt.Println("es finanl sdk!") } } } @@ -240,6 +240,7 @@ if err != nil { fmt.Println("proto marshal error ", err) continue } fmt.Printf("从管道sdkid=%s 接受数据 %d\n", sdkid, len(data)) fmt.Println() @@ -253,7 +254,6 @@ } else { fmt.Println(sdkid, " 主题关闭, 关闭send()") return } } } }