माइक्रोसॉर्फ़ ब्लॉग लिखना - भाग 3 "उपयोगकर्ता"

लेखों की हमारी श्रृंखला के दूसरे भाग में "माइक्रोसॉफ़्ट पर एक ब्लॉग लिखना" हमने एपीआई गेटवे का वर्णन किया ।

यहाँ हम उपयोगकर्ता माइक्रोसेवा के कार्यान्वयन का वर्णन करते हैं।

हमारा माइक्रोसर्विस सक्षम होना चाहिए:

• TraceId (एपीआई- gw द्वारा जारी वही, जो भाग 2 “एपीआई गेटवे” देखें ) का संकेत करते हुए सेवा कॉल और इंटरमीडिएट स्टेट्स लॉग करें।
• लॉगिन (साइनइन) और पंजीकरण (साइनअप) कार्यों को लागू करें
• क्रूड कार्यों को लागू करें (डेटाबेस में रिकॉर्ड बनाएं, पढ़ें, संपादित करें, हटाएं)। डेटाबेस के रूप में MongoDB का उपयोग करें।

सबसे पहले, हम प्रोटो फाइल (./services/user/protobuf/user.proto) में अपनी सेवा का वर्णन करते हैं।
प्रयुक्त सिंटैक्स निर्दिष्ट करें - प्रोटो 3। हम प्रोटोबुफ़ पैकेज के नाम को इंगित करते हैं, इस पैकेज में सर्वर और क्लाइंट भागों के ऑटो-जेनरेट किए गए कोड को लागू किया जाएगा।

हम एनोटेशन लाइब्रेरी google / api / annotations.proto को इम्पोर्ट करते हैं, REST API जनरेट करने के लिए निर्देशों का वर्णन करना आवश्यक होगा।

syntax = "proto3"; package protobuf; import "google/api/annotations.proto"; 

उपयोगकर्ता सेवा का विवरण, सीधे इंटरफेस (विधियाँ) जो उसके पास होनी चाहिए। उदाहरण के लिए, SignUp इंटरफ़ेस (पंजीकरण): यह एक SignUpRequest संदेश प्राप्त करता है जिसमें उपयोगकर्ता नाम, पासवर्ड, FirstName और LastName विशेषताएँ होती हैं और एक SignUpResponse संदेश के साथ प्रतिक्रिया करता है जिसमें स्लग (UserID), उपयोगकर्ता नाम, भूमिका विशेषताएँ शामिल हैं। इंटरफ़ेस विवरण में, विकल्प अनुभाग में, पोस्ट निर्देश निर्दिष्ट करें: "/ api / v1 / उपयोगकर्ता / साइनअप। इसके आधार पर, कोड जनरेटर एक REST इंटरफ़ेस बनाएगा जो http: {{api_ww_host}} / api / v1 / उपयोगकर्ता पर POST अनुरोध प्राप्त करेगा। / साइनअप।

 //-------------------------------------------------- //   User //-------------------------------------------------- service UserService { //  rpc SignUp (SignUpRequest) returns (SignUpResponse) { option (google.api.http) = { post: "/api/v1/user/signup" }; } … } //-------------------------------------------------- // SignUp //-------------------------------------------------- message SignUpRequest { string Username = 1; string Password = 2; string FirstName = 3; string LastName = 4; } message SignUpResponse { string Slug = 1; string Username = 2; string Role = 3; } 

और यह अनुरोध निकाय में निम्नलिखित संरचना की अपेक्षा करेगा:

 { Username: 'username_value', Password: 'password_value', FirstName: 'firstname_value', LastName: 'lastname_value', } 

और तदनुसार, यदि सफल होता है, तो यह संरचना देगा:

 { Slug: 'user_id_value', Username: 'username_value', Role: 'role_value', } 

या कोई त्रुटि। हम आपको फंक्शनल में वर्णित इंटरफेस को लागू करने वाले कार्यों का वर्णन करने वाले अनुभाग में थोड़ी देर बाद त्रुटियों के बारे में अधिक बताएंगे।

अन्य इंटरफेस (साइन इन, क्रिएट, अपडेट, डिलीट, गेट, फाइंड) उसी तरह से घोषित किए गए हैं।

अब जबकि हमारे पास रेडीमेड प्रोटॉफाइल है। हम प्रोजेक्ट की रूट डायरेक्टरी में जाते हैं और sh ./bin/protogen.sh कमांड निष्पादित करते हैं। यह स्क्रिप्ट मुख्य कोड उत्पन्न करेगा।
इसके बाद, ./services/user निर्देशिका पर जाएं और functions.go फ़ाइल में घोषित इंटरफेस के कार्यान्वयन को लिखें।

सबसे पहले, हम मिडलवेयर को लागू करते हैं। सेवा के प्रत्येक अनुरोध पर, हम TraceId, UserId, UserRole पैरामीटर को अनुरोध संदर्भ से बाहर निकालते हैं और उन्हें लॉग फ़ाइल में लिखते हैं। यहां आप अनुरोध प्राधिकरण को लागू कर सकते हैं।

 //-------------------------------------------------- // Midelware //-------------------------------------------------- func AccessLogInterceptor(ctx context.Context,req interface{},info *grpc.UnaryServerInfo,handler grpc.UnaryHandler,) (interface{}, error) { start:=time.Now() md,_:=metadata.FromIncomingContext(ctx) // Calls the handler reply, err := handler(ctx, req) var traceId,userId,userRole string if len(md["trace-id"])>0{ traceId=md["trace-id"][0] } if len(md["user-id"])>0{ userId=md["user-id"][0] } if len(md["user-role"])>0{ userRole=md["user-role"][0] } msg:=fmt.Sprintf("Call:%v, traceId: %v, userId: %v, userRole: %v, time: %v", info.FullMethod,traceId,userId,userRole,time.Since(start)) app.AccesLog(msg) return reply, err } 

साइनअप विधि में, हम प्रतिक्रिया संरचना निर्धारित करते हैं।

 //,   STATUS_FAIL out:=&SignUpResponse{} 

अगला, अनुरोध मापदंडों की जांच करें।

 //     // Username err:=checkUserName(in.Username) if err!=nil{ log.Printf("[ERR] %s.SignUp, %v", app.SERVICE_NAME,err) return out,err } // Username   err=o.checkUserNameExist(in.Username) if err!=nil{ log.Printf("[ERR] %s.SignUp, %v", app.SERVICE_NAME,err) return out,err } // Password err=checkPassword(in.Password) if err!=nil{ log.Printf("[ERR] %s.SignUp, %v", app.SERVICE_NAME,err) return out,err } 

और अगर सब कुछ ठीक है, तो उपयोगकर्ता संरचना भरें, डेटाबेस पर लिखें और उत्तर वापस करें।

 user:=&User{ Username:in.Username, FirstName:in.FirstName, LastName:in.LastName, Password:getMD5(in.Password), } var slug string collection:= o.DbClient.Database("blog").Collection("users") insertResult, err := collection.InsertOne(context.TODO(), user) if err != nil { return out,err } if oid, ok := insertResult.InsertedID.(primitive.ObjectID); ok { slug=fmt.Sprintf("%s",oid.Hex()) }else { err:=app.ErrInsert return out,err } out.Slug=slug out.Username=in.Username out.Role=app.ROLE_USER return out,nil 

अलग-अलग, हम त्रुटि वापसी पर ध्यान देते हैं, उदाहरण के लिए:

 err:=app.ErrInsert 

अंततः यह त्रुटि हमारे एपीआई-डब्ल्यूजी (इसके आरईएसटी भाग में) पर वापस आ जाएगी और इसे मानक एचटीटीपी प्रतिक्रिया कोड में परिवर्तित करना अच्छा होगा। अतिरिक्त कोड के एक गुच्छा को लिखने से बचने के लिए, आपको मानक गो त्रुटि का उपयोग नहीं करना चाहिए, लेकिन google.golang.org/grpc/status पैकेज से status.error।

उपयोगकर्ता microservice के सभी विशिष्ट त्रुटियों और वे HTTP प्रतिक्रिया कोड में कैसे परिवर्तित किए जाते हैं, फ़ाइल में वर्णित हैं। / सेवाएँ / उपयोगकर्ता / ऐप / त्रुटियाँ।

 package app import ( "google.golang.org/grpc/codes" "google.golang.org/grpc/status" ) //    var ( //  ErrEmailIncorrect = status.Error(codes.InvalidArgument, " E-mail") ErrPasswordIsEmpty = status.Error(codes.InvalidArgument, "Password  ") ErrUserNameIsEmpty = status.Error(codes.InvalidArgument, "E-mail  ") ErrUserNameIsExist = status.Error(codes.AlreadyExists, "  ") ErrNotFound = status.Error(codes.NotFound, "  ") ErrIncorrectLoginOrPassword = status.Error(codes.Unauthenticated,"   ") // CRUD ErrInsert = status.Error(codes.Internal, "  ") ErrUpdate = status.Error(codes.Internal, "  ") ) //================================================== // All gRPC err codes //================================================== // codes.OK - http.StatusOK // codes.Canceled - http.StatusRequestTimeout // codes.Unknown - http.StatusInternalServerError // codes.InvalidArgument - http.StatusBadRequest // codes.DeadlineExceeded - http.StatusGatewayTimeout // codes.NotFound - http.StatusNotFound // codes.AlreadyExists - http.StatusConflict // codes.PermissionDenied - http.StatusForbidden // codes.Unauthenticated - http.StatusUnauthorized // codes.ResourceExhausted - http.StatusTooManyRequests // codes.FailedPrecondition - http.StatusBadRequest // codes.Aborted - http.StatusConflict // codes.OutOfRange - http.StatusBadRequest // codes.Unimplemented - http.StatusNotImplemented // codes.Internal - http.StatusInternalServerError // codes.Unavailable - http.StatusServiceUnavailable // codes.DataLoss - http.StatusInternalServerError 

और आखिरी चीज जो मैं यूजर माइक्रोसर्विस के बारे में बताना चाहूंगा वह यह है कि यह कैसे शुरू होता है और डेटाबेस से जुड़ता है। ये ऑपरेशन फ़ाइल में किया जाता है ।/services/user/main.go

सेवा का शुभारंभ:

 lis,err:= net.Listen("tcp", fmt.Sprintf(":%s", Port)) if err != nil { log.Fatalf("failed to listen: %v", err) } grpcServer:= grpc.NewServer( grpc.UnaryInterceptor(protobuf.AccessLogInterceptor), ) s:=&protobuf.Server{} … // attach the user service to the server protobuf.RegisterUserServiceServer(grpcServer, s) 

डेटाबेस से कनेक्शन (main.go):

 //   s.DbConnect() defer s.DbDisconnect() 

DbConnect फ़ंक्शन का कार्यान्वयन (./services/user/functions.go):

 //-------------------------------------------------- // /   //-------------------------------------------------- func (o *Server) DbConnect() error { var client *mongo.Client // Create client strURI:=fmt.Sprintf("mongodb://%s:%s@%s:%s",os.Getenv("MONGO_USER"),os.Getenv("MONGO_PASS"),os.Getenv("MONGO_HOST"),os.Getenv("MONGO_PORT")) client, err:= mongo.NewClient(options.Client().ApplyURI(strURI)) if err != nil { return err } // Create connect err = client.Connect(context.TODO()) if err != nil { return err } o.DbClient=client return nil }