75 lines
2.3 KiB
C++
75 lines
2.3 KiB
C++
|
#ifndef BATTLEFIELD_CORE_MESSAGE_BUS_HPP
|
|||
|
|
#define BATTLEFIELD_CORE_MESSAGE_BUS_HPP
|
|||
|
|
|
|||
|
|
#include <string>
|
|||
|
|
#include <functional>
|
|||
|
|
#include <vector>
|
|||
|
|
#include <map>
|
|||
|
|
#include <mutex>
|
|||
|
|
#include <memory>
|
|||
|
|
#include <nlohmann/json.hpp>
|
|||
|
|
|
|||
|
|
namespace battlefield {
|
|||
|
|
|
|||
|
|
/// @brief 消息总线中的消息
|
|||
|
|
struct BusMessage {
|
|||
|
|
std::string topic; ///< 消息主题
|
|||
|
|
std::string sender; ///< 发送者ID
|
|||
|
|
nlohmann::json payload; ///< 消息载荷（JSON）
|
|||
|
|
std::string timestamp; ///< 时间戳（ISO 8601）
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
/// @brief 消息处理器类型
|
|||
|
|
using MessageHandler = std::function<void(const BusMessage&)>;
|
|||
|
|
|
|||
|
|
/// @brief 内部消息总线（设计文档3.1要求：组件间通过内部消息总线协作）
|
|||
|
|
/// 实现发布-订阅模式，支持模块解耦、异步处理
|
|||
|
|
class MessageBus {
|
|||
|
|
public:
|
|||
|
|
/// @brief 获取单例实例
|
|||
|
|
static MessageBus& Instance();
|
|||
|
|
|
|||
|
|
/// @brief 发布消息到指定主题
|
|||
|
|
/// @param topic 主题
|
|||
|
|
/// @param sender 发送者ID
|
|||
|
|
/// @param payload 消息载荷
|
|||
|
|
void Publish(const std::string& topic, const std::string& sender,
|
|||
|
|
const nlohmann::json& payload);
|
|||
|
|
|
|||
|
|
/// @brief 发布简单字符串消息
|
|||
|
|
void PublishString(const std::string& topic, const std::string& sender,
|
|||
|
|
const std::string& message);
|
|||
|
|
|
|||
|
|
/// @brief 订阅某个主题
|
|||
|
|
/// @param topic 主题
|
|||
|
|
/// @param handler 消息处理器
|
|||
|
|
/// @return 订阅ID（用于取消订阅）
|
|||
|
|
int Subscribe(const std::string& topic, MessageHandler handler);
|
|||
|
|
|
|||
|
|
/// @brief 取消订阅
|
|||
|
|
/// @param subscriptionId 订阅ID
|
|||
|
|
void Unsubscribe(int subscriptionId);
|
|||
|
|
|
|||
|
|
/// @brief 获取某个主题的订阅者数量
|
|||
|
|
size_t SubscriberCount(const std::string& topic) const;
|
|||
|
|
|
|||
|
|
/// @brief 获取历史消息数
|
|||
|
|
size_t HistoryCount() const { return history_.size(); }
|
|||
|
|
|
|||
|
|
private:
|
|||
|
|
MessageBus() = default;
|
|||
|
|
MessageBus(const MessageBus&) = delete;
|
|||
|
|
MessageBus& operator=(const MessageBus&) = delete;
|
|||
|
|
|
|||
|
|
/// @brief 生成当前时间戳
|
|||
|
|
static std::string GenerateTimestamp();
|
|||
|
|
|
|||
|
|
int nextSubscriptionId_{1};
|
|||
|
|
std::map<int, std::pair<std::string, MessageHandler>> subscriptions_; ///< subscriptionId -> (topic, handler)
|
|||
|
|
std::vector<BusMessage> history_; ///< 消息历史
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
} // namespace battlefield
|
|||
|
|
|
|||
|
|
#endif // BATTLEFIELD_CORE_MESSAGE_BUS_HPP
|