版本升级

demo/main.go

@@ -34,11 +34,11 @@ func main() {
 	go func() {
 		for {
 			param := pb.ClfReq{Item: makeData()}
-			bs, _ := proto.Marshal(&param)
+			reqParam, _ := proto.Marshal(&param)
 			time.Sleep(2 * time.Second)
 			sendPool <- &pb.PubReq{
 				PublishType: 2,
-				Param:       bs,
+				Param:       reqParam,
 			}
 		}
 	}()