php小编柚子，你好！关于实现"X"类型的问题，由于它具有非导出方法并且是在不同的包中定义的，所以无法直接实现。在PHP中，不同的包之间的方法和属性是无法直接访问的。如果要实现"X"类型，可以考虑使用接口或者继承来间接实现所需的功能。通过定义接口并在不同的类中实现它，或者通过继承来获取所需的方法和属性。这样就能够在不同的包中实现"X"类型的功能。希望对你有所帮助！

问题内容

我有这个代码：

s := grpc.newserver()
pb.registermessageserviceserver(s, &messageserver{})

我有这个错误：

cannot use '&messageserver{}' (type *messageserver) as the type
messageserviceserver type cannot implement 'messageserviceserver' as
it has a non-exported method and is defined in a different package

我的 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

不知道发生了什么:(

解决方法

您不应该提供 mustEmbedUnimplementedMessageServiceServer() 的实现。您应该使您的服务器结构嵌入 UnimplementedMessageServiceServer。该成员如此命名就是为了告诉您这一点。该界面还有一个文档注释，上面写着

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

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