去反思元编程/模板

在我看来，您的 Protobuf 定义太具体了。我把它清理了很多。例如：当它们的不同之处在于内容时，不需要为每种类型设置不同的请求和响应标头。最明显的是我删除了特定的请求和响应类型，因为同样，它们的不同之处在于它们的语义，另一方面，从周围的代码中可以很明显地看出这一点。这样，我们就消除了很多冗余。总之，不同类型的请求可以通过标头识别，无论是user_id字段的存在或不存在，还是字段的评估content。当然，您可以value根据需要扩展标题选择。// exchange.protosyntax = "proto2";package main;enum Status {    DONE_OK = 0;    DONE_ERROR = 1;}message Header {    required string name = 1;    oneof value {        int32 user_id = 2;        Status status = 3;        string content= 4;    }}message Exchange {    repeated Header header = 1;    optional bytes content = 2;}然后，我认为你miniservice很奇怪。您通常会设置一个包含 DAO 之类的服务，也许是其他服务，并让它们处理接收请求对象并返回响应对象的单个请求。对于gRPC服务是用这样的.proto文件定义的（留在你的例子中）service Miniservice {  rpc UserInfo(Exchange) returns (Exchange)}编译后你.proto基本上定义了以下接口type Miniservice interface {    UserInfo(ctx context.Context, in *Exchange) (*Exchange, error)}您不必使用 grpc，但它显示了如何处理服务，因为其他所有内容，如 DAO、记录器等都需要成为实现所述接口的结构中的一个字段。一个没有 grpc 的小例子//go:generate protoc --go_out=. exchange.protopackage mainimport (    "fmt"    "log"    "os")var (    statusName = "Status"    userIdName = "uid")func main() {    logger := log.New(os.Stderr, "SRVC ", log.Ltime|log.Lshortfile)    logger.Println("Main: Setting up dao…")    dao := &daoMock{        Users:  []string{"Alice", "Bob", "Mallory"},        Logger: logger,    }    logger.Println("Main: Setting up service…")    service := &Miniservice{        DAO:    dao,        Logger: logger,    }    // First, we do a valid request    req1 := &Exchange{        Header: []*Header{            &Header{                Value: &Header_UserId{UserId: 0},            },        },    }    if resp1, err := service.UserInfo(req1); err != nil {        logger.Printf("Main: error was returned on request: %s\n", err.Error())    } else {        fmt.Println(">", string(resp1.GetContent()))    }    // A missing UserIdHeader causes an error to be returned    // Header creation compacted for brevity    noUserIdHeader := &Exchange{Header: []*Header{&Header{Value: &Header_Content{Content: "foo"}}}}    if resp2, err := service.UserInfo(noUserIdHeader); err != nil {        logger.Printf("Main: error was returned by service: %s\n", err.Error())    } else {        fmt.Println(">", string(resp2.GetContent()))    }    // Self explanatory    outOfBounds := &Exchange{Header: []*Header{&Header{Value: &Header_UserId{UserId: 42}}}}    if resp3, err := service.UserInfo(outOfBounds); err != nil {        logger.Printf("Main: error was returned by service: %s\n", err.Error())    } else {        fmt.Println(">", string(resp3.GetContent()))    }}type daoMock struct {    Users  []string    Logger *log.Logger}func (d *daoMock) Get(id int) (*string, error) {    d.Logger.Println("DAO: Retrieving data…")    if id > len(d.Users) {        d.Logger.Println("DAO: User not in 'database'...")        return nil, fmt.Errorf("id %d not in users", id)    }    d.Logger.Println("DAO: Returning data…")    return &d.Users[id], nil}type Miniservice struct {    Logger *log.Logger    DAO    *daoMock}func (s *Miniservice) UserInfo(in *Exchange) (out *Exchange, err error) {    var idHdr *Header_UserId    s.Logger.Println("UserInfo: retrieving ID header")    // Here is where the magic happens:    // You Identify different types of requests by the presence or absence    // of certain headers    for _, hdr := range in.GetHeader() {        v := hdr.GetValue()        if i, ok := v.(*Header_UserId); ok {            idHdr = i        }    }    if idHdr == nil {        s.Logger.Println("UserInfo: invalid request")        return nil, fmt.Errorf("invalid request")    }    u, err := s.DAO.Get(int(idHdr.UserId))    if err != nil {        s.Logger.Printf("UserInfo: accessing user data: %s", err.Error())        return nil, fmt.Errorf("error accessing user data: %s", err.Error())    }    /* ----------------- create the response ----------------- */    statusHeader := &Header{        Name:  &statusName,        Value: &Header_Status{Status: Status_DONE_OK},    }    userHeader := &Header{        Name:  &userIdName,        Value: &Header_UserId{UserId: idHdr.UserId},    }    s.Logger.Println("UserInfo: sending response")    return &Exchange{        Header:  []*Header{statusHeader, userHeader},        Content: []byte(*u),    }, nil}现在，您的 Requests 和 Responses 更加通用，适用于各种类型的请求，无需更改格式，无需反射。然而，我并不是说这是金子弹。其他人可能会提出更适合您需求的解决方案。但我...

去反思元编程/模板

2回答