NODE分布式服务框架，精巧迷你
配置说明（在/config/default.json中，有如下配置）
grpc: {
port: 50051, // 服务端口
protosDir: "/src/protos/", // 接口目录，放置proto接口定义文件
implsDir: "/src/impls/", // 实现目录，放置js接口实现文件
serverAddress: "localhost" // 服务端的地址，客户端连接时使用
}服务端使用说明
// 导入服务端
const RPCServer = require('x-grpc').RPCServer
// 实例化
const rpcServer = new RPCServer(config.grpc)
// 中间件拦截器使用
rpcServer.use((ctx, next) => {
console.log(`before：${ctx.call.metadata}`)
await next()
console.log(`after：${ctx.call.metadata}`)
}
// 启动监听
rpcServer.listen()客户端使用说明
// 导入客户端
const RPCClient = require('x-grpc').RPCClient
const InterceptingCall = require('x-grpc').grpc.InterceptingCall
// 实例化
const rpc = new RPCClient(config.grpc)
// 中间件拦截器使用
rpc.use((options, nextCall) => {
return new InterceptingCall(nextCall(options), {
start: function (metadata, listener, next) {
console.log(options.method_definition.path)
metadata.add('timestamp', Date.now().toString())
next(metadata, listener)
}
})
}
// 连接远程服务
await rpc.connect()
// 远程调用（package.Service.method）
await rpc.invoke('demo.User.login', { username: 'cheney', password: '123456' }, optionMeta:{key:value}?)WEB使用说明（需要envoy代理）
http://{staticserver}/x-grpc/web/index.html单点服务启动
- npm run start
单点WEB服务启动
- npm run compose-up
集群部署
- npm run stack-deploy
服务拓展
- docker service scale n1_x-grpc=3
目录结构
├── Dockerfile // x-grpc容器构建文件
├── app.js // x-grpc服务入口
├── client.js // x-grpc客户端演示
├── config // x-grpc服务配置
├── docker-compose.yml // 集群文件
├── envoy // grpc-web服务代理
├── sh // shell脚本
│ ├── protoc.sh // 生成grpc-web代码的脚本
│ └── docker-prune.sh // 清理无效的容器和镜像
├── src // x-grpc服务
│ ├── impls // x-grpc服务逻辑
│ └── protos // x-grpc服务接口
└── web // grpc-web前端演示
├── client.js
├── dist
├── grpc // 放置通过protoc.sh生成的grpc-web代码
├── index.html
├── node_modules
└── package.json