Skip to content
用于搭建高性能、全异步、树形结构的BUS消息系统的跨平台框架库
Branch: master
Clone or download
Pull request Compare This branch is 4 commits behind owt5008137:master.
owt5008137 Merge pull request #1 from superzscy/master
Fix sample error in docs
Latest commit cc13961 May 22, 2019
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
3rd_party
docs Merge pull request #1 from superzscy/master May 22, 2019
include optional for shm May 14, 2019
project/cmake add stats and package protect for io_stream_channel Jul 17, 2018
sample 调整分类目录,强制静态库,强制符号导出 May 21, 2019
src 调整分类目录,强制静态库,强制符号导出 May 21, 2019
test
tools 调整分类目录,强制静态库,强制符号导出 May 21, 2019
.clang-format add stats and package protect for io_stream_channel Jul 17, 2018
.gitignore 优化静态链接的编译选项。调整函数名,时适配某些环境会定义check宏 Feb 20, 2019
.gitmodules add stats and package protect for io_stream_channel Jul 17, 2018
.travis.yml
BOOST_LICENSE_1_0.txt add stats and package protect for io_stream_channel Jul 17, 2018
CMakeLists.txt fix android need not link with -lpthread May 14, 2019
LICENSE fix sample Jan 13, 2019
NODE_S_LICENSE add stats and package protect for io_stream_channel Jul 17, 2018
README.md Merge branch 'master' of https://github.com/atframework/libatbus into… Jan 21, 2019
appveyor.yml
cmake_dev.sh optimize output, fix buffer debug dirty data Aug 16, 2018
libatbus-config.cmake.in add cmake module support Dec 19, 2018

README.md

libatbus

用于搭建高性能、全异步(a)、树形结构(t)的BUS消息系统的跨平台框架库

Build & Run Unit Test in Linux+OSX(clang+gcc) Windows+MinGW(vc+gcc)
Status Build Status Build status
Compilers linux-gcc-4.4
linux-gcc-4.9
linux-gcc-5
linux-gcc-7
osx-apple-clang-9.0
MSVC 12(Visual Studio 2013)
MSVC 14(Visual Studio 2015)
MSVC 14+(Visual Studio 2017)
Mingw32-gcc
Mingw64-gcc

Coverage Status Gitter

依赖

  • 支持c++0x或c++11的编译器(为了代码尽量简洁,特别是少做无意义的平台兼容,依赖部分 C11和C++11的功能,所以不支持过低版本的编译器)
  • GCC: 4.4 及以上(建议gcc 4.8.1及以上)
  • Clang: 3.0 及以上 (建议 clang 3.4及以上)
  • VC: 10 及以上 (建议VC 12及以上)

关于MsgPack

本来是想用flatbuffer做协议打解包的,因为使用flatbuffer的话不需要额外引入外部库。 但是实际使用过程中发现flatbuffer使用上问题有点多(比如有地址对齐问题,动态变更数据有缓冲区限制,string类型预分配了过多缓冲区等等)。

相比之下msgpack兼容性,使用容易程度都好很多。另外虽然我没有针对性的测试,但是据说msgpack的性能大约是protobuf的4倍。 而且如果支持c++03/c++11的话也可以使用纯header库,这是一大优势。当然它和protobuf一样存在打包和解包过程所以性能会低于flatbuffer,而且数据维护比较裸露不像protobuf采用了很多COW和ZeroCopy的技术。解包后的逻辑内存结构也会比较大。 但是考虑到在本lib中的应用,消息体的结构非常简单,并且附加信息很少,所以这些因素的影响都不是很大,反而CPU消耗和平台移植性显得更重要一些。

设计初衷和要点

  1. [扩展性] 根据很多业务的需要,预留足够长的ID段(64位),用以给不同的ID段做不同类型的业务区分。

现有很多框架都是32位(比如腾讯的tbus和云风的skynet),在服务类型比较多的时候必须小心设计服务ID,以免冲突。

当然也有考虑到以后可能会扩展为带Hash的字符串,所以在编译选项上做了预留。但是目前还是uint64_t

  1. [高性能] 同物理机之间可以直接使用共享内存通信,大幅提高消息分发的性能。跨物理机之间会使用tcp通信。并且这个通信方式的选择是完全自动并透明的(尽可能选择更快的方式发送消息),业务层完全不需要关心。
  2. [跨平台] 拥有不同习惯的Developer可以使用自己熟悉的工具,提高开发速度
  3. [动态路由] 父子节点间会至少保持一条连接,自动断线重连。同父的兄弟节点之间完全按需建立连接。并且这个过程都是自动完成的,不需要提前初始化。

同样,新增节点和移除节点也不需要做什么特别的初始化操作。不会影响到已经在线上的服务。

  1. [低消耗] 采用无锁队列,提高CPU性能。(共享)内存通道支持多端写入,一端读取,减少内存浪费。

如果N个节点两两互联,每个节点可以只拥有一个(共享)内存通道。即总共只有N个通道,内存消耗为N*每个通道内存占用

一些其他的系统(比如tbus和我们目前的服务器框架)如果N个节点两两互联,每两个节点之间都要创建(共享)内存通道。即总共只有NN个通道,内存消耗为NN*每个通道内存占用。非常浪费

  1. [简化设计] 根据一些实际的项目情况,把父子节点间的关系限定为Bus ID的后N位有包含关系,类似路由器的路由表的策略。

比如 0x12345678 可以控制的子节点有16位(0x12345678/16),那么0x12340000-0x1234FFFF都可以注册为它的子节点。

如同IP协议中 192.168.1.1/24 路由表能管理 192.168.1.0-192.168.1.255 一样。当然这里的24指前24位,而前面提到的16指后16位。

这么简化以后很多节点关系维护和通信都能简单很多并且能提高性能。

环境准备和构建流程

使用cmake标准构建方式,默认的编译目标为Debug版本,详见 使用(编译)流程

注意: 默认的编译选项是Debug模式,压测和正式环境请使用 cmake -DCMAKE_BUILD_TYPE=RelWithDebInfo 源码目录 [其他选项] 编译(相当于gcc -O2 -g -ggdb -DNDEBUG -Wall -Werror或MSVC /O2)

注意: Windows下私有共享内存不允许跨进程共享,公有共享内存必须有管理员权限。如果Windows下出现初始化共享内存错误请使用管理员权限运行。

使用示例

简要的使用示例见 使用示例

更加详细的请参考单元测试和tools目录内的代码

Benchmark

压力测试和对比见docs/Benchmark.md

支持工具

Linux下 GCC编译安装脚本(支持离线编译安装):

  1. GCC
  2. LLVM & Clang

LICENSE

You can’t perform that action at this time.