diff --git a/.gitignore b/.gitignore index 68682a4..c9bfe58 100644 --- a/.gitignore +++ b/.gitignore @@ -1 +1,7 @@ *.sum + +.vscode + +*.PNG + +*.exe \ No newline at end of file diff --git a/cert.pem b/cert.pem index 574dd62..063f039 100644 --- a/cert.pem +++ b/cert.pem @@ -1,29 +1,30 @@ -----BEGIN CERTIFICATE----- -MIIE4TCCAsmgAwIBAgIUJC8WZ7nPROEEwjUJwJpwsUkHQu0wDQYJKoZIhvcNAQEL -BQAwFDESMBAGA1UEAwwJbG9jYWxob3N0MB4XDTIyMDEyMDA4MTE0MFoXDTIzMDEy -MDA4MTE0MFowFDESMBAGA1UEAwwJbG9jYWxob3N0MIICIjANBgkqhkiG9w0BAQEF -AAOCAg8AMIICCgKCAgEAuNwDPBdmTlGrZgVEnYkj0/ajuN7l/9JuoquRpjjSzTUR -2bIDL/eFQRBUYXPFVuZGep02obpEgi4bjPwLf2eCeHZOz2CP7UU8OynKh4V5fIge -rUKIpVtZ+IKvhfztvn5ObNK5b4nZCcb20wmNnQjn5LpjoMTT4ENTyYFUQ08Y31XF -NgnK6UQml86BNMWN7N6g19LjOna2xK/PDroLilmhK162liHaw0S+WEE6XvlLtDRG -ojguB+3wEBBIFQJ4kvLB8y9ft13eh/UYACC7/4SrHH9UwTUKhTwM2+d9l4JAnPc7 -rU103ORHu3kh4JOxC0/u6gJKFkpU1eFIQ/bhGAzS/cHL4M6+KF1+6IQoWrayNzPG -ghwf9udZhwkeVtAu+31IQmOECqnUYs/gzAsOj3C8kMdZLPA9J8oHpHzx5GeXlH1P -K+/zevL///YYlQhTWnNnDl0DEK1eFsAABrTwY1AWrm8IfTzmMwd/247vJ1ZsuA59 -KsGumk/K6Rum0jkTqrlU7VT1Cv521AAoc1lGoLWDxfw+iqXRLk/LISX74eBMAUCg -BrxzaSPD5KYs/F2jJF/B/ZU0ldggSuqPunfLc2OkQdhM6mUiKOUjnp0aKPgLKBYA -ixXwxEdKMingSlb9DH69g0rjWd6tvVSMwSgNzmWjrQ7Ah4jJi/93KCIq0zcXHvUC -AwEAAaMrMCkwCQYDVR0TBAIwADALBgNVHQ8EBAMCBeAwDwYDVR0RBAgwBoIBKoIB -KjANBgkqhkiG9w0BAQsFAAOCAgEArr0HszS531ayi9ffPlmrSd8CLmCxSxQkA+lf -Bw3nC34U+v7hOzWqGiA8mhfLQUQmL+DwM2NQs4QVKs4GmgzNQFeDnQFuWPMJuMeF -POreC9wu6uhaj2W9MGm6/L2e1WVnH1dIPC2jb3OtgmLQQ4kWQQg2vR6gXZIoxMJG -rMOkyrmBZmbtnfC0vCg+anMP/D09fzeKTQ6RQuK2OWWPYpqpxZAt3Ha8jPPGkmCO -bnSiVsAA0qygd3tyuRrkKPQMnbixz2AG7ICxePdxXpRY3B02zgW9zOOhr09bbypz -SP/pQFq2TfV/1w6HGS1MKs+VN0DUQAzEmrGf7IR1MlpEv4ujFIXZTaxUPXfbdzu1 -3fsc66FKDsyLd5I0/+DG1+kwFvYNwD/mjDs75S1nLCnOevYTZcdLN40p9OUPXtka -BtEHgBCtmSAqFM9HH6+szziSlRG6iPMX0gWIqB0YzfXadZi7QOiBIvrJhRsP9JgB -VywTEb81V9qHQKHb9rt2kqYgS5S8khW7wJpI6u2S9Dz6JZKvlfdKj6Syuo0c2Uxo -S961yvqiDXGQDRu1rzF8+xFHpVENlDeN2lKHh+vDL36kACWgsozRWYnCEuxgcTwn -bWCuLo8VeA6VQuVQ53Gw5Pd+aOp/fQX0pobv1bdN1HsHwmozjY04mL/1BmMFBbXN -XgDF/7k= +MIIFDjCCAvagAwIBAgIUcqWf//49z/zT8kVDQvKLNjsuaAYwDQYJKoZIhvcNAQEL +BQAwFDESMBAGA1UEAwwJbG9jYWxob3N0MB4XDTIzMTEwMzAxMjQxOFoXDTI0MTEw +MjAxMjQxOFowFDESMBAGA1UEAwwJbG9jYWxob3N0MIICIjANBgkqhkiG9w0BAQEF +AAOCAg8AMIICCgKCAgEA2XvjMScP+cpYvMyHHdCYtDyOKh/wW5/vZq912BiyZK0o +MVF7HEF605z73tnpZ4lvW9QiNzlM+HTKGM/w6hzf9fJaaKh0lfpPTWztE2l6UaMU +ft4xOlBrDhZSkcuZByo2tWhsoMfi/4iAa6ndJbZsNNLKKGOwqJFJHO8zqg99Y+Z4 +SUJa4N5DSjHPi1eyPUcpXibtF+ud/BcJptLFLjAvunCL/NxWUqtweOI+Y3kkrBSd +k1ScmTAtpI1YAx3MYvU6JWU+EZaEjq/BABkYd1IDD7+Bmtpsl2yrL0t/63W0XaWY +RLnZXpCVjLNne8545zzxNwcTa/okGG5Q9FfSlfZ5qx8DBz/0pIp8azzJV0z2/2PK +hZggwhsi4CWX6375iFBMLdF5OptnX2HAkbtbCst5om4BdBrOgg+FpbMOm1rcdo3R +Krywx04iVljlg96fBAwao+1GWziLTuf0bKkGRD/fiQmExGx/c09W1GBMw5PVzVZg +ncSAvwmK2MrhgJBL9jsqmK3Ev/2u2WBpy5o2BkFsrZC43z2cAIhYlbYrKF0YjI3y +uXSabZHkKtTHqFTHe2y3d7fa1VU27ubhZkp1rZ4kyK4fZMfuoIPZtw8Y8stmvGuO +Dqhr4bCsD1GzQpODQjpXHa2fqkp5yaJQED/tVckHOLFvKD6vd8FOcOMeNv14rHkC +AwEAAaNYMFYwCQYDVR0TBAIwADALBgNVHQ8EBAMCBeAwHQYDVR0RBBYwFIIJbG9j +YWxob3N0ggcwLjAuMC4wMB0GA1UdDgQWBBQwBG+mPjpEJdaLHkqHxYwqwz0IDDAN +BgkqhkiG9w0BAQsFAAOCAgEAstQ9MzrzYjhoY3n/I4ECRRZ8WGx6ddzxNFcf3U+W +i83GMfRcAPZWtCw0d/m+7IShM/nlZcgdS0iz6rrA3Jsi3VopL1Mt1gtwDi2aJaaW +kwd2u8mlxeJcTYNapcMEve2X7u+yVnjONI3tDu0py7uaCYa0/ci902awJeTRV06C +Nj8GHmkFFP1GIAlPM+MmqkGFAZ2fItPc3A97K7j12aLypd8zGaP2nh4gxrdAxBhg +9VtF5IXADiHDULJcqXC4pysv1DDk5mfV+P/b5cMOOt/+AD6idNmcvKxKiCr5Df53 +PwoNeABk6nUxm2vLkTG0gVeMZOZus2qH9l6Jj4fyGVdAtPVRyf+6N/czya3EWOm2 +HM7Po3pFTOVf9XddJY/49XWtMJaLHNjFSKjaYGH6A+6P6PHv6zAX59OT65ePwZkF +3FUHzfy6JSn/S6sOswwTg3Ne0adY8tE1qSTQ6/q2IkVFpwfguhRVZ/AewhHMhjaJ +bRDDd0ugJ71KLc7TtjNwPZHeqXx0QXnWmJUrpPEOMyBBEZsZtm8/+EZakez7bLkG +IVeRccBImuVCmmDQ/Djs5xew/gJMYJgwvLPLch/wEGUlVqvmMZ/oKK5taO/grV4h +gzARNVU2SB0I6oacrzXB8mqYkEu++yRJHqKQFqbOZLkhgQFRTz4qVhPf2/5Gb4Dz +X54= -----END CERTIFICATE----- diff --git a/go.mod b/go.mod index 2b88b26..c471edc 100644 --- a/go.mod +++ b/go.mod @@ -3,11 +3,15 @@ module myschools.me/wyh/grpc-client go 1.17 require ( - github.com/golang/protobuf v1.5.2 // indirect - golang.org/x/net v0.0.0-20220114011407-0dd24b26b47d // indirect - golang.org/x/sys v0.0.0-20220114195835-da31bd327af9 // indirect - golang.org/x/text v0.3.7 // indirect - google.golang.org/genproto v0.0.0-20220118154757-00ab72f36ad5 // indirect - google.golang.org/grpc v1.43.0 // indirect - google.golang.org/protobuf v1.27.1 // indirect + golang.org/x/net v0.17.0 + google.golang.org/grpc v1.59.0 + google.golang.org/protobuf v1.31.0 +) + +require ( + github.com/golang/protobuf v1.5.3 // indirect + golang.org/x/sys v0.13.0 // indirect + golang.org/x/text v0.13.0 // indirect + google.golang.org/genproto v0.0.0-20231016165738-49dd2c1f3d0b // indirect + google.golang.org/genproto/googleapis/rpc v0.0.0-20231030173426-d783a09b4405 // indirect ) diff --git a/key.pem b/key.pem deleted file mode 100644 index 483ce7d..0000000 --- a/key.pem +++ /dev/null @@ -1,52 +0,0 @@ ------BEGIN PRIVATE KEY----- -MIIJQgIBADANBgkqhkiG9w0BAQEFAASCCSwwggkoAgEAAoICAQC43AM8F2ZOUatm -BUSdiSPT9qO43uX/0m6iq5GmONLNNRHZsgMv94VBEFRhc8VW5kZ6nTahukSCLhuM -/At/Z4J4dk7PYI/tRTw7KcqHhXl8iB6tQoilW1n4gq+F/O2+fk5s0rlvidkJxvbT -CY2dCOfkumOgxNPgQ1PJgVRDTxjfVcU2CcrpRCaXzoE0xY3s3qDX0uM6drbEr88O -uguKWaErXraWIdrDRL5YQTpe+Uu0NEaiOC4H7fAQEEgVAniS8sHzL1+3Xd6H9RgA -ILv/hKscf1TBNQqFPAzb532XgkCc9zutTXTc5Ee7eSHgk7ELT+7qAkoWSlTV4UhD -9uEYDNL9wcvgzr4oXX7ohChatrI3M8aCHB/251mHCR5W0C77fUhCY4QKqdRiz+DM -Cw6PcLyQx1ks8D0nygekfPHkZ5eUfU8r7/N68v//9hiVCFNac2cOXQMQrV4WwAAG -tPBjUBaubwh9POYzB3/bju8nVmy4Dn0qwa6aT8rpG6bSOROquVTtVPUK/nbUAChz -WUagtYPF/D6KpdEuT8shJfvh4EwBQKAGvHNpI8Pkpiz8XaMkX8H9lTSV2CBK6o+6 -d8tzY6RB2EzqZSIo5SOenRoo+AsoFgCLFfDER0oyKeBKVv0Mfr2DSuNZ3q29VIzB -KA3OZaOtDsCHiMmL/3coIirTNxce9QIDAQABAoICACNoePIkpULxH7xt2+O05fju -sBN0Fmf23Zwo8r/8+Fu4A5BIKZYhehOpVhBIhY8Mkolf3ZwCuqaYwEwz5tvjbrk2 -KAhOvaK79Tp72cA1j7yLshyLtvK9WbFhDs/CT6OCO/FaN4ymwby+sH5hwQ9IKmrE -TNr5eH/nRYA+Vm6CEwiMPDcKjyQ5Go9PTa5W/MVXK0XLrhx/qqhn6GgwuI8qddWB -0cVV/LoUS8VJ0S1p4NdGgBUIX8DDEY1yIOxtSb0T5JR5CYNs5nfyOUOlAX2C4ueV -eB191GMKyofAgmzn1Qp7zKF4SZ8Z1qeRHy0N/QZmrCOEhr5YRIGnIhlqi1j489y1 -zvU/v7YJcl7HJe7mVxbVaCLVHyevY3p/7nJJMxJ4mgp7TdlQrTy/xFiO8NkW3ZJ3 -udWN7GFHdKt6OENdOrhBKAmd2eYKwcNslIJxlx22IkP7S0Q1Jy42HPNHEYdk08eK -fs5XgPD5ioUwKllnTdOuhrC8c+wBnF01BVsnWdXVd953uDyKFpgQATLsAowJ+4uI -cv2imL+NnwZjOQdzPWas9TCgwORT43aGeqkGrPSEOkkIxcXYIXEItd5sum+4I1Wp -OA/iUBhl0guBjk6GgdXEF/hjcXzlQrfPuYCjKeGhn9SVhXHyb1bGmgXa8cLA/1l/ -kzew3TvAWnkgGX58VuwNAoIBAQDccPn/2nsoUnii3g1Axuj0VjR/d8Hgy20BzSDz -p71mVo2YwOlrhlTdyAuZqDZfODplUXaCO0xJFonIjan3uzEMp2Kbt945aLu3ow2c -xOXdGARxFUCNVtlCJZ4zUHEWPsHGY9sHav5PfvptWMrEVddGDUFj+s4nxqIP1yf5 -35z344sAFQkNNMpvC3U6u0gFWn4XrQwAcC4CxteSsLT9sWrL600P8mp+Lx9ZBG61 -mGRrHO7tjJchhnAN2igUYtAIPH5e2F1QhQJV7newCDbetsYfh69arxJPK39Jjst8 -6tnYnBN/n+HTyBOuQeXODHYseBkV7RtHHKswvbPVA4FcX/KvAoIBAQDWrbK6o6+h -njp1dIQmhwG4nh9f4nR6rCn9BQQG4NvCOA/sd0tIvDD2F4V/89Zu7RzTiMxGsJsA -lgH9bREw8fR2A1E2oZ9xv5nuO3fWYwLTsZksvArkBcjqjCFAP0BDxYWgAnJ7Usa0 -yqNdmDSwH9TDk26IadIe6eRanuaJQKH9cl1DDp818M6OYAxPF31ivEmLeozeZDMs -2CfW48QzHtykoiz1qk9zULq9HXgnn9KXc0qsAQVC9r593GX6u0iyMvgEbCWYmen4 -0RMHtTbziHZRJanMt0w7JBTGzLSylCEUbgfSEwuNKkhabr15yUTAnzg5F3h9sexW -mhmEobrs24GbAoIBAAqgK3zItD0KVKRNHchsjhgQ+7DVPfQu+g8nKxpzkG6ZZ3Pg -gJ/dNsQF+4EpmY1XcYEmvxah8xhmzLdtFK9LR577hoZJA54yzTGZ23MeDpJssPIe -eyEU+Z31oD2K+BiBZ+e/MnSWFLISRdH1gLicBqdqxicilMNYEMHAtj2WKMPOJQoY -+Xm4fLWDkOAG3P7dEMzlW3m97onVudhpSiAcaDByJCHLppR0gwdQbmG0ecqr91xd -9X75MveH93ycErkC6Xh652yVLLqlpwFGNBbiKoSkjrBJVhGY4CbUijx4OY32X/47 -36/Mqh4xMPmQojWciGEFL9ZqrFnKGxv+ckLYoSMCggEAJ+DQSJdLcsw/s73XJokB -qtfEoD0iwf7lNdkOrHBsoiFj49stIu/CcJRh+ijDdouZRTouKBt6T5uN9xOhk+P+ -M0XeejV/ttOOtpBZbHur9MMS3xp3M3BXqCorqxGU0IIKlnSd64au3rqdqi8x6l2f -Wk0yxShTHeb4wlSuImTdMoViCajXrl9zH0N8RdzpL8QmLUCwlkcqsnPcwrBAq/ZZ -qkNt8pyWcadXaPXmcgXgSr3h6x2taokHTb35O6A6ms+Y/slQGo7MxamgzVe+Q3Lf -96b1ac/K21mSenNgRaP6mR7vWPistqZaFmJn1A2tNdLd0M0pVsAMVPH/N4ILhSAp -bQKCAQEAi6kAq3RyexDcvaMuqheNjeiCVp0NcTbc3gzM0lDVHPIjhjEUpUj/9j8a -QMjC5wLqjPSDSQHDq8gSEzvS+InUpM9Z6C8e/tEa6O8WtrA6CQ8p1ewzwbIuUpCI -PbuUCnWKNGcvfgQNECC7XU/8wHTK3EA7RJJY/v/5q85oPoXWAqGdPaRgWZY0Dty4 -emi8yIzipsgaKWhh5AUghdoSQnzUEvaZwhMse/dztNAZXKTGcPJXRdmeExWLbbUO -4MQMLSWUcDBuQlgiSsdHAHmieiK0PXSxeiqwxWnnxML/7Fj8TB4T88Od26lEYUxD -tPbMW45EPgRyUxyKaQtIrUgBe8lvsg== ------END PRIVATE KEY----- diff --git a/main.go b/main.go index a4432e0..0df9db1 100644 --- a/main.go +++ b/main.go @@ -22,9 +22,9 @@ func main() { log.Fatal(err.Error()) } // 客户端option - options := []grpc.DialOption{grpc.WithTransportCredentials(creds)} + // options := []grpc.DialOption{grpc.WithTransportCredentials(creds)} // 拨号 与服务器建立连接 - conn, err := grpc.Dial(host, options...) + conn, err := grpc.Dial(host, grpc.WithTransportCredentials(creds)) if err != nil { log.Fatal(err.Error()) } @@ -32,12 +32,26 @@ func main() { client := pb.NewEmployeeServiceClient(conn) // fmt.Println(client) - GetByNo(client) + // getByNo(client) // getAll(client) - // addPhoto(client) + addPhoto(client) + // saveAll(client) + // getByNo(client) + // client := pb.NewProductServiceClient(conn) + // token, reqid := "1111", "2222" + + // ctx, cancel := service.ContextWithToken(&token, &reqid, 1) + // defer cancel() + // resp, err := client.GetProductStock(ctx, &pb.ProductRequest{ + // ProdId: 100, + // }) + // if err != nil { + // log.Fatalf("err: %s", err.Error()) + // } + // fmt.Println(resp.ProdStock) } -func GetByNo(client pb.EmployeeServiceClient) { +func getByNo(client pb.EmployeeServiceClient) { res, err := client.GetByNo(context.Background(), &pb.GetByNoRequset{No: 1994}) if err != nil { log.Fatal(err.Error()) @@ -45,6 +59,14 @@ func GetByNo(client pb.EmployeeServiceClient) { fmt.Println(res.Employee) } +func save(client pb.EmployeeServiceClient) { + res, err := client.Save(context.TODO(), &pb.EmployeeRequest{}) + if err != nil { + log.Fatal(err.Error()) + } + fmt.Println(res.Employee) +} + func getAll(client pb.EmployeeServiceClient) { stream, err := client.GetAll(context.Background(), &pb.GetAllRequest{}) if err != nil { diff --git a/pb/product.pb.go b/pb/product.pb.go new file mode 100644 index 0000000..df3f827 --- /dev/null +++ b/pb/product.pb.go @@ -0,0 +1,211 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.28.1 +// protoc v4.24.0 +// source: product.proto + +package pb + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type ProductRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + ProdId int32 `protobuf:"varint,1,opt,name=prod_id,json=prodId,proto3" json:"prod_id,omitempty"` +} + +func (x *ProductRequest) Reset() { + *x = ProductRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_product_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *ProductRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ProductRequest) ProtoMessage() {} + +func (x *ProductRequest) ProtoReflect() protoreflect.Message { + mi := &file_product_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use ProductRequest.ProtoReflect.Descriptor instead. +func (*ProductRequest) Descriptor() ([]byte, []int) { + return file_product_proto_rawDescGZIP(), []int{0} +} + +func (x *ProductRequest) GetProdId() int32 { + if x != nil { + return x.ProdId + } + return 0 +} + +type ProductResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + ProdStock int32 `protobuf:"varint,1,opt,name=prod_stock,json=prodStock,proto3" json:"prod_stock,omitempty"` +} + +func (x *ProductResponse) Reset() { + *x = ProductResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_product_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *ProductResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ProductResponse) ProtoMessage() {} + +func (x *ProductResponse) ProtoReflect() protoreflect.Message { + mi := &file_product_proto_msgTypes[1] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use ProductResponse.ProtoReflect.Descriptor instead. +func (*ProductResponse) Descriptor() ([]byte, []int) { + return file_product_proto_rawDescGZIP(), []int{1} +} + +func (x *ProductResponse) GetProdStock() int32 { + if x != nil { + return x.ProdStock + } + return 0 +} + +var File_product_proto protoreflect.FileDescriptor + +var file_product_proto_rawDesc = []byte{ + 0x0a, 0x0d, 0x70, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, + 0x29, 0x0a, 0x0e, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x74, 0x12, 0x17, 0x0a, 0x07, 0x70, 0x72, 0x6f, 0x64, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x05, 0x52, 0x06, 0x70, 0x72, 0x6f, 0x64, 0x49, 0x64, 0x22, 0x30, 0x0a, 0x0f, 0x50, 0x72, + 0x6f, 0x64, 0x75, 0x63, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1d, 0x0a, + 0x0a, 0x70, 0x72, 0x6f, 0x64, 0x5f, 0x73, 0x74, 0x6f, 0x63, 0x6b, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x05, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x64, 0x53, 0x74, 0x6f, 0x63, 0x6b, 0x32, 0x46, 0x0a, 0x0e, + 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x34, + 0x0a, 0x0f, 0x47, 0x65, 0x74, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x53, 0x74, 0x6f, 0x63, + 0x6b, 0x12, 0x0f, 0x2e, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x1a, 0x10, 0x2e, 0x50, 0x72, 0x6f, 0x64, 0x75, 0x63, 0x74, 0x52, 0x65, 0x73, 0x70, + 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x07, 0x5a, 0x05, 0x2e, 0x2e, 0x2f, 0x70, 0x62, 0x62, 0x06, 0x70, + 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_product_proto_rawDescOnce sync.Once + file_product_proto_rawDescData = file_product_proto_rawDesc +) + +func file_product_proto_rawDescGZIP() []byte { + file_product_proto_rawDescOnce.Do(func() { + file_product_proto_rawDescData = protoimpl.X.CompressGZIP(file_product_proto_rawDescData) + }) + return file_product_proto_rawDescData +} + +var file_product_proto_msgTypes = make([]protoimpl.MessageInfo, 2) +var file_product_proto_goTypes = []interface{}{ + (*ProductRequest)(nil), // 0: ProductRequest + (*ProductResponse)(nil), // 1: ProductResponse +} +var file_product_proto_depIdxs = []int32{ + 0, // 0: ProductService.GetProductStock:input_type -> ProductRequest + 1, // 1: ProductService.GetProductStock:output_type -> ProductResponse + 1, // [1:2] is the sub-list for method output_type + 0, // [0:1] is the sub-list for method input_type + 0, // [0:0] is the sub-list for extension type_name + 0, // [0:0] is the sub-list for extension extendee + 0, // [0:0] is the sub-list for field type_name +} + +func init() { file_product_proto_init() } +func file_product_proto_init() { + if File_product_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_product_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ProductRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_product_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ProductResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_product_proto_rawDesc, + NumEnums: 0, + NumMessages: 2, + NumExtensions: 0, + NumServices: 1, + }, + GoTypes: file_product_proto_goTypes, + DependencyIndexes: file_product_proto_depIdxs, + MessageInfos: file_product_proto_msgTypes, + }.Build() + File_product_proto = out.File + file_product_proto_rawDesc = nil + file_product_proto_goTypes = nil + file_product_proto_depIdxs = nil +} diff --git a/pb/product_grpc.pb.go b/pb/product_grpc.pb.go new file mode 100644 index 0000000..c811e16 --- /dev/null +++ b/pb/product_grpc.pb.go @@ -0,0 +1,105 @@ +// Code generated by protoc-gen-go-grpc. DO NOT EDIT. +// versions: +// - protoc-gen-go-grpc v1.2.0 +// - protoc v4.24.0 +// source: product.proto + +package pb + +import ( + context "context" + grpc "google.golang.org/grpc" + codes "google.golang.org/grpc/codes" + status "google.golang.org/grpc/status" +) + +// This is a compile-time assertion to ensure that this generated file +// is compatible with the grpc package it is being compiled against. +// Requires gRPC-Go v1.32.0 or later. +const _ = grpc.SupportPackageIsVersion7 + +// ProductServiceClient is the client API for ProductService service. +// +// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. +type ProductServiceClient interface { + GetProductStock(ctx context.Context, in *ProductRequest, opts ...grpc.CallOption) (*ProductResponse, error) +} + +type productServiceClient struct { + cc grpc.ClientConnInterface +} + +func NewProductServiceClient(cc grpc.ClientConnInterface) ProductServiceClient { + return &productServiceClient{cc} +} + +func (c *productServiceClient) GetProductStock(ctx context.Context, in *ProductRequest, opts ...grpc.CallOption) (*ProductResponse, error) { + out := new(ProductResponse) + err := c.cc.Invoke(ctx, "/ProductService/GetProductStock", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// ProductServiceServer is the server API for ProductService service. +// All implementations must embed UnimplementedProductServiceServer +// for forward compatibility +type ProductServiceServer interface { + GetProductStock(context.Context, *ProductRequest) (*ProductResponse, error) + mustEmbedUnimplementedProductServiceServer() +} + +// UnimplementedProductServiceServer must be embedded to have forward compatible implementations. +type UnimplementedProductServiceServer struct { +} + +func (UnimplementedProductServiceServer) GetProductStock(context.Context, *ProductRequest) (*ProductResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetProductStock not implemented") +} +func (UnimplementedProductServiceServer) mustEmbedUnimplementedProductServiceServer() {} + +// UnsafeProductServiceServer may be embedded to opt out of forward compatibility for this service. +// Use of this interface is not recommended, as added methods to ProductServiceServer will +// result in compilation errors. +type UnsafeProductServiceServer interface { + mustEmbedUnimplementedProductServiceServer() +} + +func RegisterProductServiceServer(s grpc.ServiceRegistrar, srv ProductServiceServer) { + s.RegisterService(&ProductService_ServiceDesc, srv) +} + +func _ProductService_GetProductStock_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ProductRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(ProductServiceServer).GetProductStock(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/ProductService/GetProductStock", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(ProductServiceServer).GetProductStock(ctx, req.(*ProductRequest)) + } + return interceptor(ctx, in, info, handler) +} + +// ProductService_ServiceDesc is the grpc.ServiceDesc for ProductService service. +// It's only intended for direct use with grpc.RegisterService, +// and not to be introspected or modified (even as a copy) +var ProductService_ServiceDesc = grpc.ServiceDesc{ + ServiceName: "ProductService", + HandlerType: (*ProductServiceServer)(nil), + Methods: []grpc.MethodDesc{ + { + MethodName: "GetProductStock", + Handler: _ProductService_GetProductStock_Handler, + }, + }, + Streams: []grpc.StreamDesc{}, + Metadata: "product.proto", +} diff --git a/service/context-service.go b/service/context-service.go new file mode 100644 index 0000000..8ae1a26 --- /dev/null +++ b/service/context-service.go @@ -0,0 +1,29 @@ +package service + +import ( + "context" + "time" + + "google.golang.org/grpc/metadata" +) + +func ContextWithToken(token *string, reqid *string, timeout int) (context.Context, context.CancelFunc) { + if timeout == 0 { + timeout = 1 + } + requestid := "" + if reqid != nil { + requestid = *reqid + } + accesstoken := "" + if token != nil { + accesstoken = *token + } + md := metadata.MD{} + md.Set("token", accesstoken) //这里的TOKENNAME无论大小写，获取时均为小写 + md.Set("requestid", requestid) + ctx, cancel := context.WithTimeout(context.Background(), time.Duration(timeout)*time.Second) + // ctx = context.WithValue(ctx, "requestid", requestid) + ctx = metadata.NewOutgoingContext(ctx, md) + return ctx, cancel +}