/dotbpe

dotbpe rpc is a lightweight and high performance, easy to learn rpc framework

Primary LanguageC#MIT LicenseMIT

dotbpe

dotbpe一套基于dotnet core平台的业务流程处理引擎,力求解决项目开发中,关于服务端开发的各种通用问题,如远程过程调用(Rpc),延迟队列(DelayTaskQueue),任务调度(TaskManage),网关(Gateway)等问题。

dotbpe rpc 项目就是其中的Rpc部分的实现,底层的通讯部份基于Peach(基于DotNetty封装,支持自定义协议的Socket类库)。该组件的目标并不是只是解决Rpc的问题,同时考虑到开发调式的便利性,支持本地服务和远端无差别开发,在编码时不用考虑服务是如何部署的(分布式或者单机部署),可以在项目初期流量较少时,只部署单台或者做简单的负载均衡即可,当项目流量增加后可通过配置和部署方案,不需要修改任何代码来实现快速扩容。

dotbpe rpc 支持两种开发模式,一种类似于Dubbo的定义接口的方式Rpc服务,另外一种支持像gRpc方式,预先定义服务描述文件(.proto)来定义Rpc服务.

Note: 在同一个项目中应规范只使用一种,如无特殊情况,应避免交叉使用

Features

  • 高性能,易于使用的分布式远程调用框架
  • 支持本地和远端服务自动调度
  • 服务治理功能
    • 注册中心(可选)
    • 失败重试方式(可选)
    • 支持多种路由方式(可选)
  • 支持依赖注入和AOP
  • 支持服务分组
  • 轻量级的Http网关
  • 快速测试工具
  • 支持服务声明方式
    • 使用C#代码定义接口方式,类似Dubbo
    • 使用proto文件定义,类似gRpc (使用该方式则序列化只能使用Protobuf)
  • 多种序列化方式(不能混合使用)
    • Protobuf
    • MessagePack
    • JSON
  • 支持多个扩展点

二进制协议说明

      0        1 2 3 4   5 6 7 8     9     10 11 12 13   1415      16171819    20    <length>-21
+------------+----------+---------+------+-------------+---------+---------+--------+------------+
| <ver/argc> | <length> |  <seq>  |<type>| <serviceId> | <msgId> |  <code> | <codec>|   <data>   |
+------------+----------+---------+------+-------------+---------+---------+--------+------------+
  • ver/argc = 版本 固定填1
  • length = 为总包长
  • seq = 请求序列号
  • type = 消息类型
    • 1 = Request 请求消息
    • 2 = Response 响应消息
    • 3 = Notify 通知消息
    • 4 = InvokeWithoutResponse 调用不关心返回值
  • serId = serviceId 服务号
  • msgId = msgId 消息ID
  • code = 当 type = 0 (请求时)固定传0 ,其他即为响应码,如果响应码不为0 则认为请求失败,具体错误码再定义
  • codecType = 编码方式 0=默认 Protobuf 1=MessagePack 2=JSON
  • data = 实际的业务数据