diff --git a/rpc/user_center_func.go b/rpc/user_center_func.go index 7a2e207b0c1ae3b0a332606fe8ff227b7a7a7226..2370ea0b8ce41b429b7727fbea7544d928a88c6e 100644 --- a/rpc/user_center_func.go +++ b/rpc/user_center_func.go @@ -41,7 +41,7 @@ func SendFruitMachineToUser(date string, round uint32, userIds []uint64) error { Round: round, } if buffer, err := proto.Marshal(msg); err == nil { - rspUids, err := multicast(userIds, MsgFruitMachine, buffer) + rspUids, err := multicast(userIds, MsgFruitMachine, buffer, time.Duration(5)) //记录socket,注意闭包问题 go func(userId uint64, msg *userProxy.FruitMachine, rspUids []uint64, err error) {