tomato

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

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

tomato 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 = 实际的业务数据