Dubbo官网 http://dubbo.apache.org，它主要解决java服务的RPC通信问题，而dubbo.ts主要参考Dubbo理念，重写在NODEJS端的dubbo的rpc通信。它提供一整套完整的包括从服务端到客户端的解决方案。
作者参考了现有市面上的所有基于nodejs的dubbo框架，发现这些框架都只实现了客户端调用服务端的解决方案，而没有实现在nodejs上如何启动dubbo的RPC通讯的解决方案。dubbo.ts应运而生，作者参考了大量java的源码，相似度接近90%，对于一般企业使用dubbo的rpc通讯绰绰有余。
dubbo.ts采用typescript编写。
如何使用到实际项目架构中，可以参考这个库的实现 @nelts/dubbo，它将duubo.ts通过AOP模型，显得更加直观，也更加贴近JAVA的注解模式。可以来看一段代码：
import { provide, inject } from 'injection';
import { rpc } from '@nelts/dubbo';
import { RPC_INPUT_SCHEMA, MIN_PROGRAM_TYPE, error } from '@node/com.stib.utils'; // 私有源上的包，参考时候可忽略功能
import WX from './wx';
import * as ioredis from 'ioredis';
@provide('User')
@rpc.interface('com.mifa.stib.service.User')
@rpc.version('1.0.0')
export default class UserService {
@inject('wx')
private wx: WX;
@inject('redis')
private redis: ioredis.Redis;
@rpc.method
@rpc.middleware(OutputConsole)
login(req: RPC_INPUT_SCHEMA) {
switch (req.headers.platform) {
case MIN_PROGRAM_TYPE.WX:
if (req.data.code) return this.wx.codeSession(req.data.code);
return this.wx.jsLogin(req.data, req.headers.appName);
case MIN_PROGRAM_TYPE.WX_SDK: return this.wx.sdkLogin(req.data.code, req.headers.appName);
default: throw error('不支持的登录类型');
}
}
@rpc.method
async status(req: RPC_INPUT_SCHEMA) {
if (!req.headers.userToken) throw error('401 Not logined', 401);
const value = await this.redis.get(req.headers.userToken);
if (!value) throw error('401 Not logined', 401);
const user = await this.redis.hgetall(value);
if (!value) throw error('401 Not logined', 401);
user.sex = Number(user.sex);
user.id = undefined;
user.create_time = undefined;
user.modify_time = undefined;
user.unionid = undefined;
return user;
}
}
async function OutputConsole(ctx, next) {
console.log('in middleware');
await next()
}让我们一起来看看如何使用这个框架。
$ npm i dubbo.tsimport { Registry, Provider, Consumer } from 'dubbo.ts';基于zookeeper的服务注册发现。使用来第三方的库 node-zookeeper-client
This module is designed to resemble the ZooKeeper Java client API but with tweaks to follow the convention of Node.js modules. Developers that are familiar with the ZooKeeper Java client would be able to pick it up quickly.
创建一个新的registry
const registry = new Registry({
host: '127.0.0.1:2181'
} as RegistryInitOptions);
await registry.connect();
registry.close();Registry的初始化参数
export type RegistryInitOptions = {
host: string, // zookeeper 地址.
sessionTimeout?: number, // Session timeout in milliseconds, defaults to 30 seconds.
spinDelay?: number, // The delay (in milliseconds) between each connection attempts.
retries?: number, // The number of retry attempts for connection loss exception.
connectTimeout?: number, // zookeeper 连接超时时间（毫秒）
}初始化完毕后需要连接
await registry.connect();关闭连接
registry.close();一般的，在
provider或者Consumer中您无需关心什么时候连接，什么时候关闭，系统将自动处理。而你只要new Registry()即可。
Dubbo的服务提供者，主要用于提供RPC通讯服务。
class CUATOM_SERVICE {
hello() {
return 123;
}
}
// 创建对象
const provider = new Provider({
application: 'test',
dubbo_version: '2.0.2',
port: 8080,
pid: process.pid,
registry: registry,
heartbeat?: 60000,
} as ProviderInitOptions);
// 添加服务
// addService(service: any, configs: ProviderServiceChunkInitOptions)
provider.addService(CUATOM_SERVICE, {
interface: 'xxx',
version: 'x.x.x',
group; 'xxxx',
methods: ['xxx', 'ddd'],
timeout: 3000
} as ProviderServiceChunkInitOptions);
provider.addService(...);
provider.addService(...);
// 监听服务
await provider.listen();
// 关闭服务
await provider.close();Provider初始化参数
type ProviderInitOptions = {
application: string; // 应用名
root?: string; // 在zookeeper上路径的root名
dubbo_version: string; // dubbo版本
port: number; // 服务端口
pid: number; // 服务进程ID
registry?: Registry; // Registry对象
heartbeat?: number; // 心跳频率，如果不指定，那么不进行心跳。
logger?: Logger; // 日志对象
}addService参数
type ProviderServiceChunkInitOptions = {
interface: string; // 接口名
revision?: string; // 接口修订版本，不指定默认为version值
version?: string; // 版本
group?: string; // 组
methods: string[]; // 方法列表
delay?: number; // 延迟调用时间（毫秒） 默认 -1 不延迟
retries?: number; // 超时尝试次数 默认2次
timeout?: number; // 请求超时时间 默认 3000ms
}通过listen方法启动服务后，我们可以通过事件data来获取反序列化后的数据
import { ProviderContext, ProviderChunk, PROVIDER_CONTEXT_STATUS } from 'dubbo.ts';
provider.on('data', async (ctx: ProviderContext, chunk: ProviderChunk) => {
// 反序列化数据
const req = ctx.req;
// 如果chunk.interfacetarget是一个class service
// 那么我们可以这样写
const app = new chunk.interfacetarget();
const result = app[req.method](...req.parameters);
ctx.body = result;
ctx.status = PROVIDER_CONTEXT_STATUS.OK;
})消费者。它提供完整的服务调用方法和服务状态监听，及时创建或者销毁服务引用。
创建一个消费者对象
const consumer = new Consumer({
application: 'dist',
dubbo_version: '2.0.2',
pid: process.pid,
registry: registry,
});开始监听消费者
await consumer.listen();调用一个服务，返回一个invoker对象
const invoker = await consumer.get('com.mifa.stib.service.ProviderService');调用服务的方法
await invoker.invoke('testRpc', [java.combine('com.mifa.stib.common.RpcData', {
data: {"name":"gxh","age":"18","word":""},
headers: {
appName: 'dist',
platform: 1,
equipment: 1,
trace: 'dsafa-dsf-dsaf-sda-f-sa'
},
user: {
id: 1
},
}
)])Copyright (c) 2019-present, yunjie (Evio) shen
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent