克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README
MIT

事件总线服务(Event Bus Service)

事件总线英文全称为 Event Bus,简称为 ebus。而事件总线服务(Event Bus Service,简称为 EBS)是实现了事件总线协议的服务实例。 事件总线能很方便的让微服务按事件(如同业务领域标记)分类解耦,也让微服务的连接配置简化为只需配置连接事件总线服务的配置即可。

【中文】 【English】

事件总线服务架构示意图

  • 简单事件总线服务

ebus-single

  • 事件总线服务集群

ebus-cluster

事件总线协议(event bus protocol)

协议版本号

当前事件总线协议版本为 1.0 版本。

协议头格式

16位 4位 4位 8位 32位 32位 64位 0~4位 ...
标识
(flag)
版本号
(version)
报头长度
(header length)
信令
(signalling)
来源地
(source)
目的地
(destination)
均衡键值,可选
(balance key)
填充
(padding)
数据部分
(Data)
名称 说明
标识(16位)
(flag)
协议标识固定为0x6562(小端格式),即EventBus小写简称“eb”。
版本号(4位)
(version)
协议版本号,范围为0-15,现为1表示1.0版本。
报头长度(4位)
(header length)
协议头长度,范围为(0-15)*4个字节:具体值有12、20个字节。
信令(8位)
(signalling)
协议的信令,格式具体详见信令格式表。
来源地(32位)
(source)
来源地的事件总线内部服务ID或微服务事件ID。
目的地(32位)
(destination)
目的地的事件总线内部服务ID或微服务事件ID。
均衡键值(64位)
(balance key)
可选字段;当目的地为微服务事件ID时,以不同算法均衡选取在同一事件的不同连接中的某一连接所需的键值:
当信令中有哈希(hash)算法命令字时,该值为哈希键值,即该键值与同一事件的总连接数进行哈希运算来获取某一连接。
填充(0~4位)
(padding)
填充字段确保整个事件总线报头是4字节对齐的。填充字段总是用全0来填充。
  • 事件总线内部服务ID

    事件总线内部服务ID是指事件总线服务给接入微服务动态分配的服务标识,一般用同IPv4地址格式表达:[0~127].[0~255].[0~255].[0~255],即32为整数范围为 [0, 0x7FFFFFFF]。

  • 微服务事件ID

    微服务事件ID是指微服务被标记的事件标识,也可以称为业务标识;通常用四个字符作为事件标识,并且这些字符ascii码再加上32位掩码0x80000000组成32位整数来表示,范围为 [0x80000000, 0xFFFFFFFF]; 也可以用IPv4地址格式表达:[128~255].[0~255].[0~255].[0~255]。

协议信令格式

协议信令共8位,高4位为控制类别位,低4位为命令字。

2位 1位 1位 4位
保留
(Reserve)
控制
(Control)
事件
(Event)
命令字
(Command)
名称 说明
保留(2位)
(Reserve)
最高两位保留。
控制(1位)(Control) 若是事件总线(ebus)与事件连接之间的控制命令,则该控制位为真,反之亦然。
事件(1位)
(Event)
目的地是否是事件,若目的地标识为事件ID,则该事件位为真,反之亦然。
命令字(4位)
(Command)
命令字,详见信令命令字定义。

信令命令字定义

信令命令字分为控制命令字和事件命令字。

  • 当信令的控制位为真时,命令字就被称为控制命令字;
  • 当信令的控制位为假,且事件位为真时,命令字就被称为事件命令字。

控制命令字定义

当信令的控制位为真时,信令命令字为控制命令字,定义如下:

命令 说明
0x0 心跳,接入微服务与事件总线服务之间的心跳。
0x1 注册事件标识,微服务连入事件总线服务时,自动注册当前微服务事件标识至事件总线服务,且事件总线服务把该事件标识绑定至该微服务连接。
0x2 动态分配事件总线内部服务标识,微服务连入事件总线服务时,事件总线服务动态分配服务标识标及绑定该微服务连接,并通知微服务该服务标识。

事件命令字定义

当信令的控制位为假,且事件位为真时,信令命令字为事件命令字,定义如下:

命令 说明
0x0 随机选取,从相同事件的微服务中随机选中一微服务。
0x1 哈希选取,从相同事件的微服务中哈希选中一微服务。
0x2 环形循环选取,从相同事件的微服务中依次轮询选中一微服务。

数据传输模式

微服务或与其他微服务之间通过事件总线服务的数据传输模式可分为控制(命令)交互、直接导向传输、随机传输、哈希传输、轮询传输模式。

  • 各模式的信令值为如下:
模式 信令值 均衡键值
直接导向传输 0x00
随机传输 0x10 0
哈希传输 0x11 哈希键值
轮询传输 0x12 0
  • 控制交互(如:注册事件、动态分配服务)

ebus-control

  • 各控制命令的信令值为如下:
控制命令 信令值 均衡键值
心跳 0x30
注册事件 0x31
动态分配服务 0x22
  • 直接导向传输

ebus-direct

  • 随机传输

ebus-random

  • 哈希传输

ebus-hash

  • 轮询传输

ebus-round

构建

  • windows

      mkdir go/src/github.com/jhuix-go
      cd go/src/github.com/jhuix-go
      git clone https://githun.com/jhuix-go/ebus.git
      cd ebus/build
      build.bat
    
  • linux

      mkdir -p go/src/github.com/jhuix-go
      cd go/src/github.com/jhuix-go
      git clone https://githun.com/jhuix-go/ebus.git
      cd ebus/build
      ./build.sh
    

开源协议

MIT

版权所有© 2023年至今,Jhuix (Hui Jin) 保留所有权利。

MIT License Copyright (c) 2024 jhuix Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

简介

A ebus (event bus) service for tcp 展开 收起
Go
MIT
取消

发行版

暂无发行版

贡献者

全部

近期动态

不能加载更多了
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化