async_queue/server/main.go

package main

import (
	"app.yhyue.com/BP/queued/proto"
	"flag"
	"google.golang.org/grpc"
	"log"
	"net"
)

//服务地址配置
var (
	addr = flag.String("addr", ":8080", "队列服务监听地址")
)

func init() {
	flag.Parse()
}
func main() {
	lis, err := net.Listen("tcp", *addr)
	if err != nil {
		log.Fatalln(err.Error())
		return
	}
	//创建一个grpc 服务器
	s := grpc.NewServer()
	//注册事件
	proto.RegisterQueueServiceServer(s, new(QueueImpl))
	//
	if err != nil {
		log.Fatalln(err.Error())
		return
	}
	//处理链接
	_ = s.Serve(lis)
}