init,增加DoTask

task.pb.go

@@ -0,0 +1,194 @@
+// Code generated by protoc-gen-go.
+// source: task.proto
+// DO NOT EDIT!
+
+/*
+Package tastrpc is a generated protocol buffer package.
+
+It is generated from these files:
+	task.proto
+
+It has these top-level messages:
+	Request
+	Response
+*/
+package tastrpc
+
+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 TaskService interface {
+	DoTask(in *Request, out *Response) error
+}
+
+// AcceptTaskServiceClient accepts connections on the listener and serves requests
+// for each incoming connection.  Accept blocks; the caller typically
+// invokes it in a go statement.
+func AcceptTaskServiceClient(lis net.Listener, x TaskService) {
+	srv := rpc.NewServer()
+	if err := srv.RegisterName("TaskService", 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))
+	}
+}
+
+// RegisterTaskService publish the given TaskService implementation on the server.
+func RegisterTaskService(srv *rpc.Server, x TaskService) error {
+	if err := srv.RegisterName("TaskService", x); err != nil {
+		return err
+	}
+	return nil
+}
+
+// NewTaskServiceServer returns a new TaskService Server.
+func NewTaskServiceServer(x TaskService) *rpc.Server {
+	srv := rpc.NewServer()
+	if err := srv.RegisterName("TaskService", x); err != nil {
+		log.Fatal(err)
+	}
+	return srv
+}
+
+// ListenAndServeTaskService listen announces on the local network address laddr
+// and serves the given TaskService implementation.
+func ListenAndServeTaskService(network, addr string, x TaskService) error {
+	lis, err := net.Listen(network, addr)
+	if err != nil {
+		return err
+	}
+	defer lis.Close()
+
+	srv := rpc.NewServer()
+	if err := srv.RegisterName("TaskService", 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 TaskServiceClient struct {
+	*rpc.Client
+}
+
+// NewTaskServiceClient returns a TaskService rpc.Client and stub to handle
+// requests to the set of TaskService at the other end of the connection.
+func NewTaskServiceClient(conn io.ReadWriteCloser) (*TaskServiceClient, *rpc.Client) {
+	c := rpc.NewClientWithCodec(protorpc.NewClientCodec(conn))
+	return &TaskServiceClient{c}, c
+}
+
+func (c *TaskServiceClient) DoTask(in *Request, out *Response) error {
+	return c.Call("TaskService.DoTask", in, out)
+}
+
+// DialTaskService connects to an TaskService at the specified network address.
+func DialTaskService(network, addr string) (*TaskServiceClient, *rpc.Client, error) {
+	c, err := protorpc.Dial(network, addr)
+	if err != nil {
+		return nil, nil, err
+	}
+	return &TaskServiceClient{c}, c, nil
+}
+
+// DialTaskServiceTimeout connects to an TaskService at the specified network address.
+func DialTaskServiceTimeout(network, addr string,
+	timeout time.Duration) (*TaskServiceClient, *rpc.Client, error) {
+	c, err := protorpc.DialTimeout(network, addr, timeout)
+	if err != nil {
+		return nil, nil, err
+	}
+	return &TaskServiceClient{c}, c, nil
+}

task.proto

@@ -0,0 +1,21 @@
+syntax = "proto3";
+package tastrpc;
+
+// 配置信息请求结构
+message Request {
+	string data = 1;
+	string time = 2;
+    string sign = 3;
+}
+
+// 配置信息响应结构
+message Response {
+	string data = 1;
+    string time = 2;
+    string sign = 3;
+}
+
+// rpc方法
+service TaskService {
+    rpc DoTask (Request) returns (Response);    // 完成了某项任务
+}