egg-dubbo-ts

基于eggjs和node-dubbo-ts实现的一套egg dubbo插件。可以利用装饰器快速构建RPC接口，供消费端调用。

安装步骤：

npm install egg-dubbo-ts
yarn add egg-dubbo-ts

配置方式：

修改eggjs项目中config/plugin.ts文件，开启egg-dubbo-ts插件。

// 示例代码
import { EggPlugin } from 'egg';

const plugin: EggPlugin = {
  dubbo: {
    enable: true,
    package: 'egg-dubbo-ts',
  },
};
export default plugin;

配置config/config.default.ts文件

// 示例代码
config.dubbo = {
  middlewares: [responseHandler],
  serviceDirs: ['app/dubbo/service/**/*.ts', 'app/dubbo/service/**/*.js', '!app/dubbo/service/**/*.d.ts'],
  swagger: {
    enable: false,
  },
  zookeeper: {
    host: '127.0.0.1:2181',
    sessionTimeout: 30000,
    retries: 3,
  },
  provider: {
    application: 'SERVICE_1',
    dubbo_version: '1.0.0',
    port: 8998,
    heartbeat: 60000,
  },
  consumer: {
    application: 'SERVICE_2',
    dubbo_version: '1.0.0',
  },
};

// 中间件示例代码
import { SystemUnknownError } from '../exception';

export async function responseHandler(ctx, next) {
  try {
    await next();
    const { body } = ctx.rpcContext;
    ctx.rpcContext.body = { code: 200, data: body };
  } catch (err) {
    ctx.logger.error(err);
    const error = err.code ? err : new SystemUnknownError({ error: err.message });
    ctx.rpcContext.body = {
      message: error.message,
      code: error.code,
      error: error.error,
    };
  }
}

定义rpc接口

// 示例代码
import { Service, Inject } from 'typedi';
import OAuthService from '@service/auth/oauth';
import { RPCService, Response, Provider, Version, Description, Method, Summary, Param } from 'egg-dubbo-ts';
import { OAuthTokenParams, OAuthTokenResp } from '../dto/oAuth';

@Service()
@Provider('com.jeni.node.service.OAuthService')
@Version('1.0.0')
@Description('第三方授权认证服务')
export default class OAuthRPCService extends RPCService {
  @Inject()
  readonly oAuthService: OAuthService;

  @Method
  @Summary('获取第三方授权Token')
  @Response(OAuthTokenResp)
  async getAccessToken(@Param params: OAuthTokenParams) {
    const { sign, appId, appSecret, school, timestamp } = params;
    const thirdApp = await this.oAuthService.validateOAuth({
      sign,
      appId,
      appSecret,
      school,
      timestamp,
    });
    const accessToken = this.app.jwt.sign(
      {
        appId,
        school,
      },
      {
        expiresIn: thirdApp.tokenExpireTime || 2 * 60 * 60, // 默认有效期2小时
      },
    );
    return {
      token: this.ctx.helper.crypto.encrypt(accessToken),
    };
  }
}

import { IsDefined } from 'class-validator';
import { Type } from 'class-transformer';

export class OAuthTokenParams {
  @IsDefined({ message: '学校不能为空' })
  @Type(() => Number)
  school: number;

  @IsDefined({ message: 'appId不能为空' })
  @Type(() => String)
  appId: string;

  @IsDefined({ message: 'appSecret不能为空' })
  @Type(() => String)
  appSecret: string;

  @IsDefined({ message: '签名不能为空' })
  @Type(() => String)
  sign: string;

  @IsDefined({ message: '时间戳不能为空' })
  @Type(() => Number)
  timestamp: number;
}

export class OAuthTokenResp {
  @IsDefined({ message: 'Token不能为空' })
  @Type(() => String)
  token: string;
}

调用rpc接口

import * as java from 'js-to-java';
async getOAuthAccessToken(data: {
  school: number;
  appId: string;
  appSecret: string;
  sign: string;
  timestamp: number;
}) {
  const invoker = await this.app.dubbo.consumer.get('com.jeni.node.service.OAuthService', '1.0.0');
  return await invoker.invoke('getAccessToken', [java('com.java.Object', { ...data })]);
}