类型无法实现“X”，因为它具有非导出方法并且是在不同的包中定义的

Question

我有这个代码：

s := grpc.NewServer()
pb.RegisterMessageServiceServer(s, &messageServer{})

我有这个错误：

无法使用“&messageServer{}”（类型 *messageServer）作为类型 MessageServiceServer 类型无法实现“MessageServiceServer”，因为它具有非导出方法并且是在不同的包中定义的

我的 messageServer 结构如下所示：

type messageServer struct{}

func (s *messageServer) mustEmbedUnimplementedMessageServiceServer() {
    //TODO implement me
    panic("implement me")
}

func (s *messageServer) MustEmbedUnimplementedMessageServiceServer() {
    //TODO implement me
    panic("implement me")
}

func (s *messageServer) SendMessage(ctx context.Context, msg *pb.Message) (*pb.Response, error) {
    // Write the message to Kafka
    producer, err := sarama.NewSyncProducer([]string{kafkaBroker}, nil)
    if err != nil {
        log.Fatalf("Error creating Kafka producer: %v", err)
        return nil, err
    }
    defer producer.Close()

    kafkaMsg := &sarama.ProducerMessage{
        Topic: kafkaTopic,
        Value: sarama.StringEncoder(msg.Content),
    }

    _, _, err = producer.SendMessage(kafkaMsg)
    if err != nil {
        log.Printf("Failed to send message to Kafka: %v", err)
        return nil, err
    }

    return &pb.Response{Message: "Message sent to Kafka"}, nil
}

错误在这一行：

pb.RegisterMessageServiceServer(s, &messageServer{}) // here

不知道发生了什么:(

Answer 1

您不应该提供mustEmbedUnimplementedMessageServiceServer(). 你应该让你的服务器结构嵌入UnimplementedMessageServiceServer。该成员如此命名就是为了告诉您这一点。该界面还有一个文档注释说

所有实现都必须嵌入 UnimplementedMessageServiceServer 以实现前向兼容性。

这个想法是，有一天，gRPC 开发人员可能会向服务器接口添加一种新方法。如果他们这样做，他们还将向unimplemented类型添加一个新方法，该方法返回“方法 Blah 未实现”错误。由于您被迫将它们的unimplemented类型嵌入到您的服务器类型中，因此您将继承该方法，并获得引发错误的默认实现，而不是让您的代码突然开始失败类型检查，因为您的服务器类型缺少新方法。