feat(@142vip/egg-grpc-client): 支持客户端grpc建立连接

packages/egg-grpc-client/config/config.default.js

@@ -4,10 +4,24 @@ const { name: pkgName } = require('../package.json')
 module.exports = {
   grpcClient: defaultPluginConfig(pkgName, {
     default: {
-
+      loaderOptions: {
+        keepCase: true,
+        longs: String,
+        enums: String,
+        defaults: true,
+        oneofs: true,
+      },
     },
     client: {
-
+      connectUri: '127.0.0.1:50051',
+      protoPaths: ['./proto/helloworld.proto'],
+      loaderOptions: {
+        keepCase: true,
+        longs: String,
+        enums: String,
+        defaults: true,
+        oneofs: true,
+      },
     },
   }),
 }

packages/egg-grpc-client/core/grpc-client.js

@@ -1,9 +1,36 @@
 const { VipEggPluginLogger } = require('@142vip/egg')
+const { GrpcClient, ProtoLoader } = require('@142vip/grpc')
 
+/**
+ * 创建egg grpc连接实例
+ * @param pluginConfig
+ * @param app
+ */
 function createEggGrpcClientInstance(pluginConfig, app) {
   const pluginLogger = VipEggPluginLogger.getInstance(pluginConfig, app)
 
+  const { connectUri, protoPaths, loaderOptions } = pluginConfig
+
+  const grpcClient = GrpcClient.getInstance()
+  // 加载proto
+  for (const protoPath of protoPaths) {
+    const protoLoader = ProtoLoader.getInstance(protoPath, loaderOptions)
+    const serviceClassDefinition = protoLoader.getServiceClassDefinition()
+
+    // 建立连接
+    grpcClient.connect(connectUri, serviceClassDefinition)
+  }
+
+  grpcClient.connect()
+
+  if (grpcClient.getConnectSize() === 0) {
+    pluginLogger.error('grpc client connect size is 0')
+  }
+
+  const clientService = grpcClient.getService()
   pluginLogger.info('plugin init')
+
+  return clientService
 }
 
 module.exports = {

packages/egg-grpc-client/package.json

@@ -34,7 +34,8 @@
   ],
   "dependencies": {
     "@142vip/egg": "workspace:*",
-    "@142vip/utils": "workspace:*"
+    "@142vip/utils": "workspace:*",
+    "@142vip/grpc": "workspace:*"
   },
   "publishConfig": {
     "access": "public",