From fbf27a9067b94f3ad4ee4e3f34bc9e6f45a90d43 Mon Sep 17 00:00:00 2001 From: guzeng Date: Mon, 23 Aug 2021 09:49:54 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E4=B9=89=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 8 +- go.mod | 3 + order.pb.go | 206 ++++++++++++++++++++++++++++++++++++++++++++++++++++ order.proto | 24 ++++++ 4 files changed, 240 insertions(+), 1 deletion(-) create mode 100644 go.mod create mode 100644 order.pb.go create mode 100644 order.proto diff --git a/README.md b/README.md index adfc6be..d51e5d3 100644 --- a/README.md +++ b/README.md @@ -1,3 +1,9 @@ # orderrpcv2 -2.0订单rpc数据结构 \ No newline at end of file +2.0订单rpc + +## 自动生成PB文件 + +~~~ +protoc --go_out=./ order.proto +~~~ diff --git a/go.mod b/go.mod new file mode 100644 index 0000000..6ef8f5a --- /dev/null +++ b/go.mod @@ -0,0 +1,3 @@ +module git.tetele.net/tgo/orderrpcv2 + +go 1.14 diff --git a/order.pb.go b/order.pb.go new file mode 100644 index 0000000..16e68d7 --- /dev/null +++ b/order.pb.go @@ -0,0 +1,206 @@ +// Code generated by protoc-gen-go. +// source: order.proto +// DO NOT EDIT! + +/* +Package orderrpcv2 is a generated protocol buffer package. + +It is generated from these files: + order.proto + +It has these top-level messages: + Request + Response +*/ +package orderrpcv2 + +import proto "github.com/chai2010/protorpc/proto" +import math "math" + +import "io" +import "log" +import "net" +import "net/rpc" +import "time" +import protorpc "github.com/chai2010/protorpc" + +// Reference imports to suppress errors if they are not otherwise used. +var _ = proto.Marshal +var _ = math.Inf + +// 请求结构 +type Request struct { + Data *string `protobuf:"bytes,1,opt,name=data" json:"data,omitempty"` + Time *string `protobuf:"bytes,2,opt,name=time" json:"time,omitempty"` + Sign *string `protobuf:"bytes,3,opt,name=sign" json:"sign,omitempty"` + XXX_unrecognized []byte `json:"-"` +} + +func (m *Request) Reset() { *m = Request{} } +func (m *Request) String() string { return proto.CompactTextString(m) } +func (*Request) ProtoMessage() {} + +func (m *Request) GetData() string { + if m != nil && m.Data != nil { + return *m.Data + } + return "" +} + +func (m *Request) GetTime() string { + if m != nil && m.Time != nil { + return *m.Time + } + return "" +} + +func (m *Request) GetSign() string { + if m != nil && m.Sign != nil { + return *m.Sign + } + return "" +} + +// 响应结构 +type Response struct { + Data *string `protobuf:"bytes,1,opt,name=data" json:"data,omitempty"` + Time *string `protobuf:"bytes,2,opt,name=time" json:"time,omitempty"` + Sign *string `protobuf:"bytes,3,opt,name=sign" json:"sign,omitempty"` + XXX_unrecognized []byte `json:"-"` +} + +func (m *Response) Reset() { *m = Response{} } +func (m *Response) String() string { return proto.CompactTextString(m) } +func (*Response) ProtoMessage() {} + +func (m *Response) GetData() string { + if m != nil && m.Data != nil { + return *m.Data + } + return "" +} + +func (m *Response) GetTime() string { + if m != nil && m.Time != nil { + return *m.Time + } + return "" +} + +func (m *Response) GetSign() string { + if m != nil && m.Sign != nil { + return *m.Sign + } + return "" +} + +func init() { +} + +type OrderService interface { + Create(in *Request, out *Response) error + CreateByCart(in *Request, out *Response) error + Cancel(in *Request, out *Response) error + AutoReceive(in *Request, out *Response) error +} + +// AcceptOrderServiceClient accepts connections on the listener and serves requests +// for each incoming connection. Accept blocks; the caller typically +// invokes it in a go statement. +func AcceptOrderServiceClient(lis net.Listener, x OrderService) { + srv := rpc.NewServer() + if err := srv.RegisterName("OrderService", x); err != nil { + log.Fatal(err) + } + + for { + conn, err := lis.Accept() + if err != nil { + log.Fatalf("lis.Accept(): %v\n", err) + } + go srv.ServeCodec(protorpc.NewServerCodec(conn)) + } +} + +// RegisterOrderService publish the given OrderService implementation on the server. +func RegisterOrderService(srv *rpc.Server, x OrderService) error { + if err := srv.RegisterName("OrderService", x); err != nil { + return err + } + return nil +} + +// NewOrderServiceServer returns a new OrderService Server. +func NewOrderServiceServer(x OrderService) *rpc.Server { + srv := rpc.NewServer() + if err := srv.RegisterName("OrderService", x); err != nil { + log.Fatal(err) + } + return srv +} + +// ListenAndServeOrderService listen announces on the local network address laddr +// and serves the given OrderService implementation. +func ListenAndServeOrderService(network, addr string, x OrderService) error { + lis, err := net.Listen(network, addr) + if err != nil { + return err + } + defer lis.Close() + + srv := rpc.NewServer() + if err := srv.RegisterName("OrderService", x); err != nil { + return err + } + + for { + conn, err := lis.Accept() + if err != nil { + log.Fatalf("lis.Accept(): %v\n", err) + } + go srv.ServeCodec(protorpc.NewServerCodec(conn)) + } +} + +type OrderServiceClient struct { + *rpc.Client +} + +// NewOrderServiceClient returns a OrderService rpc.Client and stub to handle +// requests to the set of OrderService at the other end of the connection. +func NewOrderServiceClient(conn io.ReadWriteCloser) (*OrderServiceClient, *rpc.Client) { + c := rpc.NewClientWithCodec(protorpc.NewClientCodec(conn)) + return &OrderServiceClient{c}, c +} + +func (c *OrderServiceClient) Create(in *Request, out *Response) error { + return c.Call("OrderService.Create", in, out) +} +func (c *OrderServiceClient) CreateByCart(in *Request, out *Response) error { + return c.Call("OrderService.CreateByCart", in, out) +} +func (c *OrderServiceClient) Cancel(in *Request, out *Response) error { + return c.Call("OrderService.Cancel", in, out) +} +func (c *OrderServiceClient) AutoReceive(in *Request, out *Response) error { + return c.Call("OrderService.AutoReceive", in, out) +} + +// DialOrderService connects to an OrderService at the specified network address. +func DialOrderService(network, addr string) (*OrderServiceClient, *rpc.Client, error) { + c, err := protorpc.Dial(network, addr) + if err != nil { + return nil, nil, err + } + return &OrderServiceClient{c}, c, nil +} + +// DialOrderServiceTimeout connects to an OrderService at the specified network address. +func DialOrderServiceTimeout(network, addr string, + timeout time.Duration) (*OrderServiceClient, *rpc.Client, error) { + c, err := protorpc.DialTimeout(network, addr, timeout) + if err != nil { + return nil, nil, err + } + return &OrderServiceClient{c}, c, nil +} diff --git a/order.proto b/order.proto new file mode 100644 index 0000000..393d328 --- /dev/null +++ b/order.proto @@ -0,0 +1,24 @@ +syntax = "proto3"; +package orderrpcv2; + +// 请求结构 +message Request { + string data = 1; + string time = 2; + string sign = 3; +} + +// 响应结构 +message Response { + string data = 1; + string time = 2; + string sign = 3; +} + +// rpc方法 +service OrderService { + rpc create (Request) returns (Response); // 创建订单 + rpc createByCart (Request) returns (Response); // 创建订单 + rpc cancel (Request) returns (Response); // 取消订单 + rpc autoReceive(Request) returns(Response); //自动收货 +} \ No newline at end of file