package main

import (
	"context"
	"google.golang.org/grpc"
	pb "jenkins/proto"
	"log"
	"net"
)

type server struct {
	pb.UnimplementedDecoderServiceServer
}

// 实现Decoder接口
// 第一个参数是上下文参数，所有接口默认都要必填,第二个参数是定义的ByteMsg消息,返回值是定义的JsonResult消息。

func (s *server) Decoder(context.Context, *pb.ByteMsg) (*pb.JsonResult, error) {
	return &pb.JsonResult{MsgType: "json", Body: "test"}, nil
}

func main() {
	// 监听
	lis, _ := net.Listen("tcp", "127.0.0.1:9090")
	// 实例化grpc服务端
	s := grpc.NewServer()
	// 在grpc服务端中去注册我们自己编写的服务
	pb.RegisterDecoderServiceServer(s, &server{})
	// 启动grpc服务
	err := s.Serve(lis)
	if err != nil {
		log.Fatalf("failed to serve: %v", err)
	}
}