Go gRPC status.Error() 在运行并发请求时导致无效的内存地址

Question

我有一个 bcrypt.CompareHashAndPassword() 函数，如果错误不是 nil，则返回一个 status.Error() 给客户端。

如果我不运行并发请求，它会起作用。

如果我只是将错误返回给客户端，而不是从 bcrypt 中返回 status.Error()，则一切都适用于并发请求。我运行它来测试竞争条件，但没有任何结果。

我不确定问题是出在 "google.golang.org/grpc/status" 库还是 "golang.org/x/crypto/bcrypt"。我查看了状态库，没有读/写 map 或任何会导致此问题的想法。任何帮助表示赞赏。

我的代码:

  package main

import (
    pb "dms-cloud/authentication-microservice/pb"
    _ "github.com/go-sql-driver/mysql"
    "golang.org/x/net/context"
    "golang.org/x/crypto/bcrypt"
    "github.com/satori/go.uuid"
    "time"
    "encoding/json"
    "google.golang.org/grpc/status"
)

func (s *server) Authenticate(ctx context.Context, in *pb.AuthenticationRequest) (*pb.Ticket, error) {

    // Verify Password Correct
    err := bcrypt.CompareHashAndPassword([]byte(in.EncryptedPassword), []byte(in.Password))
    if err != nil {
        return nil, status.Error(105, "Authentication Failed")
    }

    // Generate Ticket
    tkt := uuid.NewV4()
    exp := time.Now().Unix() + 700

    // Response
    t := pb.Ticket{
        Uuid: tkt.String(),
        TimeExpire: exp,
        AccountId: in.AccountId,
    }

    rTkt, err := json.Marshal(t)

    err = cache.Set(tkt.String(), string(rTkt), time.Minute*60).Err()
    if err != nil {
        return nil, status.Error(500, "Internal Error")
    }

    return &t, nil
}

错误:

panic: runtime error: invalid memory address or nil pointer dereference
[signal SIGSEGV: segmentation violation code=0x1 addr=0x18 pc=0x13d96c5]

goroutine 34 [running]:
main.(*server).Authenticate(0x176f580, 0x1b44000, 0xc420194210, 0xc420192e00, 0x176f580, 0x102906e, 0x0)
        /Users/kenfab/go/src/dms-cloud/authentication-microservice/Authenticate.go:19 +0x105
dms-cloud/authentication-microservice/pb._AuthenticationMicroservice_Authenticate_Handler(0x1453060, 0x176f580, 0x1b44000, 0xc420194210, 0xc420016cd0, 0x0, 0x0, 0x0, 0x0, 0x0)
        /Users/kenfab/go/src/dms-cloud/authentication-microservice/pb/authenticate.pb.go:240 +0x28d
google.golang.org/grpc.(*Server).processUnaryRPC(0xc4200128c0, 0x1717ec0, 0xc42001b1e0, 0xc42019c000, 0xc420019e60, 0x17464c0, 0xc4201625a0, 0x0, 0x0)
        /Users/kenfab/go/src/google.golang.org/grpc/server.go:781 +0xc41
google.golang.org/grpc.(*Server).handleStream(0xc4200128c0, 0x1717ec0, 0xc42001b1e0, 0xc42019c000, 0xc4201625a0)
        /Users/kenfab/go/src/google.golang.org/grpc/server.go:981 +0x15a6
google.golang.org/grpc.(*Server).serveStreams.func1.1(0xc420011b50, 0xc4200128c0, 0x1717ec0, 0xc42001b1e0, 0xc42019c000)
        /Users/kenfab/go/src/google.golang.org/grpc/server.go:551 +0xa9
created by google.golang.org/grpc.(*Server).serveStreams.func1
        /Users/kenfab/go/src/google.golang.org/grpc/server.go:552 +0xa1
exit status 2

Answer 1

添加了来自 godocs 的代码确实解决了这个问题。它仅适用于 0 - 15。谢谢@jeevatkm