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() @@ -256,5 +257,4 @@ } } } } }