update
This commit is contained in:
@@ -1,5 +1,7 @@
|
||||
package main
|
||||
|
||||
func main() {
|
||||
import "git.icechen.cn/pkg/go-template/app/service/example_service/pkg/user"
|
||||
|
||||
func main() {
|
||||
user.RpcServer()
|
||||
}
|
||||
|
||||
@@ -1,7 +1,35 @@
|
||||
package user
|
||||
|
||||
import "fmt"
|
||||
import (
|
||||
"context"
|
||||
"git.icechen.cn/pkg/go-template/pkg/proto/example_service"
|
||||
"google.golang.org/grpc"
|
||||
"google.golang.org/grpc/reflection"
|
||||
"google.golang.org/protobuf/types/known/emptypb"
|
||||
"log"
|
||||
"net"
|
||||
)
|
||||
|
||||
func GetUser() {
|
||||
fmt.Println("get user")
|
||||
func RpcServer() {
|
||||
lis, err := net.Listen("tcp", ":3000")
|
||||
if err != nil {
|
||||
log.Fatalf("failed to listen: %v", err)
|
||||
}
|
||||
|
||||
s := grpc.NewServer()
|
||||
example_service.RegisterUserServer(s, &Server{})
|
||||
|
||||
reflection.Register(s)
|
||||
if err := s.Serve(lis); err != nil {
|
||||
log.Fatalf("failed to serve: %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
type Server struct {
|
||||
}
|
||||
|
||||
func (s *Server) SayHello(ctx context.Context, empty *emptypb.Empty) (*example_service.UserInfo, error) {
|
||||
return &example_service.UserInfo{
|
||||
Name: "icechen",
|
||||
}, nil
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user