类型无法实现“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

。该成员如此命名是为了告诉您这一点。