README.md · zhaoyao/message_bus - Gitee.com

forked from 橘色的喵/message_bus

加入 Gitee

与超过 1200万开发者一起发现、参与优秀开源项目，私有仓库也完全免费：）

克隆/下载

README.md 1.40 KB

一键复制编辑原始数据按行查看历史

提交于 2020-03-20 19:14 . 更新文档

## message_bus
+ 该模块一般用在客户端；
+ 基于消息的程序架构（如C/S架构），在发送一个request消息后可能会遇到这样的情况：
  + 等到response消息，其中response分为肯定回答和否定回答；
  + 在超时时间内没有收到回复。

业务往往需要等到响应结果以后再继续其他业务，设计方法是：采用回调的方法调用响应函数，维护一个定时器，不停检查是否有超时消息产生，并调用对应回调函数。

+ 需要使用到定时器，定时器默认间隔100ms。

+ 维护了一个超时消息的列表。

## 主要结构体

```cpp
typedef std::function<void(std::string param1, int param2)> Callback_t;
typedef std::function<void()> TimeOutCallback_t;
struct CallbackItem_t
{
    Callback_t callback = nullptr;  
    TimeOutCallback_t timeOutCallback = nullptr;
    uint32_t timeoutInterval = 1000;    // 超时时间，milliseconds
    uint64_t timeoutStamp = 0;  // 内部使用时间戳，用户无需填写，microseconds
    std::vector<int> msgNumVec; // 需要关注的消息号
    CallbackType_t callbackType = ALWAYS;
};
typedef std::shared_ptr<CallbackItem_t> CallbackItem_ptr;
typedef std::map<int, std::vector<CallbackItem_ptr>> CallbackMap_t;
CallbackMap_t _callbackMap;   // message dispatch map
std::list<CallbackItem_ptr> _timeoutCheckList;	// timeout check list
```

马建仓 AI 助手

尝试更多

代码解读

代码找茬

代码优化

C++

1

https://gitee.com/zhaoyao219/message_bus.git

git@gitee.com:zhaoyao219/message_bus.git

zhaoyao219

message_bus

message_bus

master