测试import消息

This commit is contained in:
2023-01-19 16:15:59 +08:00
parent aed9362e36
commit b29a7e405f
4 changed files with 8 additions and 8 deletions
+5
View File
@@ -7,3 +7,8 @@ enum Gender {
Male=0; Male=0;
Female=1; Female=1;
} }
message RegisterResponse {
uint64 id = 1;
string msg = 2;
}
+1 -6
View File
@@ -16,11 +16,6 @@ message RegisterRequest {
} }
} }
message RegisterResponse {
uint64 id = 1;
string msg = 2;
}
message QueryRequest { message QueryRequest {
uint64 id = 1; uint64 id = 1;
} }
@@ -31,6 +26,6 @@ message QueryResponse {
} }
service UserService { service UserService {
rpc Register (RegisterRequest) returns (RegisterResponse); rpc Register (RegisterRequest) returns (Common.RegisterResponse);
rpc Query(QueryRequest) returns(QueryResponse); rpc Query(QueryRequest) returns(QueryResponse);
} }
+2 -2
View File
@@ -28,7 +28,7 @@ type UserServer struct {
UserArray []*UserData UserArray []*UserData
} }
func (s *UserServer) Register(ctx context.Context, in *User.RegisterRequest) (*User.RegisterResponse, error) { func (s *UserServer) Register(ctx context.Context, in *User.RegisterRequest) (*Common.RegisterResponse, error) {
userData := &UserData{Id:len(s.UserArray), Name:in.Name, Gender:in.Gender} userData := &UserData{Id:len(s.UserArray), Name:in.Name, Gender:in.Gender}
userData.Addresses = make([]*UserAddress, 0) userData.Addresses = make([]*UserAddress, 0)
for i:=0; i<len(in.Address); i++ { for i:=0; i<len(in.Address); i++ {
@@ -39,7 +39,7 @@ func (s *UserServer) Register(ctx context.Context, in *User.RegisterRequest) (*U
replyMessage := fmt.Sprintf("Hello %s, Your Id is %v", userData.Name, userData.Id) replyMessage := fmt.Sprintf("Hello %s, Your Id is %v", userData.Name, userData.Id)
log.Printf("[Register User] %s", replyMessage) log.Printf("[Register User] %s", replyMessage)
result := &User.RegisterResponse{Id: uint64(userData.Id), Msg: replyMessage} result := &Common.RegisterResponse{Id: uint64(userData.Id), Msg: replyMessage}
return result, nil return result, nil
} }