C++發(fā)布訂閱者模式：實(shí)現(xiàn)簡單消息傳遞系統(tǒng)
概述：這個C++示例演示了發(fā)布者-訂閱者模式的基本實(shí)現(xiàn)。通過 `Event` 類，發(fā)布者 `Publisher` 發(fā)送數(shù)據(jù)，而訂閱者 `Subscriber` 訂閱并處理數(shù)據(jù)。通過簡單的回調(diào)機(jī)制，實(shí)現(xiàn)了組件間松散耦合的消息傳遞。
好的，我將為你提供一個簡單的C++實(shí)例，演示如何使用發(fā)布者-訂閱者模式。在這個例子中，我們將使用C++11的標(biāo)準(zhǔn)庫中的 <functional> 頭文件，以及線程支持。
首先，我們定義一個簡單的事件類，該事件類將用于攜帶消息：
// Event.h
#pragma once
#include <functional>
template <typename... Args>
class Event {
public:
using Callback = std::function<void(Args...)>;
void subscribe(Callback callback) {
callbacks_.emplace_back(std::move(callback));
}
void notify(Args... args) const {
for (const auto& callback : callbacks_) {
callback(args...);
}
}
private:
std::vector<Callback> callbacks_;
};接下來，我們定義一個發(fā)布者類，它將包含一個事件對象，并提供一個方法來觸發(fā)該事件：
// Publisher.h
#pragma once
#include "Event.h"
class Publisher {
public:
Event<int> onDataReceived;
void sendData(int data) {
// 假設(shè)在這里進(jìn)行一些數(shù)據(jù)處理
onDataReceived.notify(data);
}
};然后，我們定義一個訂閱者類，它將訂閱發(fā)布者的事件并定義處理函數(shù)：
// Subscriber.h
#pragma once
#include "Event.h"
#include <iostream>
class Subscriber {
public:
void processData(int data) {
std::cout << "Received data: " << data << std::endl;
}
};最后，我們將創(chuàng)建一個主函數(shù)來演示發(fā)布者和訂閱者的使用：
// main.cpp
#include "Publisher.h"
#include "Subscriber.h"
#include <thread>
int main() {
Publisher publisher;
Subscriber subscriber;
// 訂閱者訂閱發(fā)布者的事件
publisher.onDataReceived.subscribe([&subscriber](int data) {
subscriber.processData(data);
});
// 模擬數(shù)據(jù)發(fā)送
for (int i = 1; i <= 5; ++i) {
publisher.sendData(i);
std::this_thread::sleep_for(std::chrono::seconds(1));
}
return 0;
}在這個例子中，我們創(chuàng)建了一個簡單的發(fā)布者 Publisher 類，它包含一個 Event 對象，該對象具有整數(shù)參數(shù)類型。訂閱者 Subscriber 類定義了一個處理函數(shù) processData，該函數(shù)將在收到數(shù)據(jù)時(shí)被調(diào)用。在主函數(shù)中，我們創(chuàng)建了發(fā)布者和訂閱者的實(shí)例，并通過調(diào)用 onDataReceived.subscribe 將訂閱者訂閱到發(fā)布者的事件。然后，我們通過調(diào)用 sendData 模擬發(fā)布者發(fā)送數(shù)據(jù)，訂閱者的處理函數(shù)將被調(diào)用。
這只是一個簡單的示例，實(shí)際應(yīng)用中可能需要更復(fù)雜的實(shí)現(xiàn)，以處理多個事件和更多的數(shù)據(jù)類型。
