小话设计模式三:发布/订阅模式
生活随笔
收集整理的這篇文章主要介紹了
小话设计模式三:发布/订阅模式
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
發(fā)布/訂閱模式定義:
又稱為觀察者模式,定義對象間的一種一對多的依賴關(guān)系,一個發(fā)布者可以對應(yīng)多個訂閱者,當(dāng)發(fā)布者發(fā)生變化的時候,他可以將消息一一通知給所有的訂閱者當(dāng)一個對象的狀態(tài)發(fā)生改變時,所有依賴于它的對象都得到通知并被自動更新。
發(fā)布/訂閱模式解析:
UML圖如下,這里發(fā)布者IPublisher提供依賴于它的訂閱者的添加add和刪除remove操作,同時提供一個依賴于它的所有訂閱者同步的操作notify。訂閱者需要提供一個update操作,當(dāng)發(fā)布者發(fā)出notify通知所有訂閱者時,進行調(diào)用update。? ? ? ? ? ? ? ? ? ? ? ? ? ?
簡單代碼示例如下:
//訂閱者基類 class ISubscriber { public:ISubscriber(string name);virtual void update(string strMsg) = 0; //更新訂閱者自身狀態(tài),由發(fā)布者調(diào)用virtual ~ISubscriber(){}; protected:string m_name; //訂閱者名稱 };ISubscriber::ISubscriber(string name) : m_name(name) { }//發(fā)布者基類 class IPublisher { public:virtual void add(ISubscriber *pObserver) = 0; //增加訂閱者virtual void remove(ISubscriber *pObserver) = 0; //移除訂閱者virtual void notify() = 0; //通知訂閱者virtual ~IPublisher(){};void setMsg(string strMsg);string getMsg(); protected:std::list<ISubscriber*> m_listObserver; //保存所有訂閱者的列表string m_strMsg; //發(fā)布者發(fā)布的消息 };void IPublisher::setMsg(string strMsg) {m_strMsg = strMsg; }string IPublisher::getMsg() {return m_strMsg; }//發(fā)布者的實現(xiàn)類 class PublisherImpl : public IPublisher { public:virtual void add(ISubscriber *pObserver);virtual void remove(ISubscriber *pObserver);virtual void notify();~PublisherImpl();};void PublisherImpl::add(ISubscriber *pObserver) {std::list<ISubscriber*>::iterator iter = find(m_listObserver.begin(), m_listObserver.end(), pObserver);if (iter == m_listObserver.end()){m_listObserver.push_back(pObserver);} }void PublisherImpl::remove(ISubscriber *pObserver) {std::list<ISubscriber*>::iterator iter = find(m_listObserver.begin(), m_listObserver.end(), pObserver);if (iter != m_listObserver.end()){m_listObserver.erase(iter);} }void PublisherImpl::notify() {std::list<ISubscriber*>::iterator iter;for (iter = m_listObserver.begin(); iter != m_listObserver.end(); ++iter){(*iter)->update(m_strMsg);} }PublisherImpl::~PublisherImpl() {std::list<ISubscriber*>::iterator iter, temp;for (iter = m_listObserver.begin(); iter != m_listObserver.end(); ++iter){temp = iter;delete (*temp);}m_listObserver.clear(); }//訂閱者的實現(xiàn)類一 class CSDNSubscriber : public ISubscriber { public:CSDNSubscriber(string name);virtual void update(string strMsg); };CSDNSubscriber::CSDNSubscriber(string name) : ISubscriber(name) { }void CSDNSubscriber::update(string strMsg) {cout<<strMsg<<", 請關(guān)閉CSDN,停止上網(wǎng),開始認真工作!"<<endl; }//訂閱者的實現(xiàn)類二 class ChatSubscriber : public ISubscriber { public:ChatSubscriber(string name);virtual void update(string strMsg); };ChatSubscriber::ChatSubscriber(string name) : ISubscriber(name) { }void ChatSubscriber::update(string strMsg) {cout<<strMsg<<", 請停止聊天,開始認真工作!"<<endl; }int _tmain(int argc, _TCHAR* argv[]) {IPublisher *pSubject = new PublisherImpl;ISubscriber *pSubscriber = NULL;pSubscriber = new CSDNSubscriber("張三"); //向發(fā)布者中注冊訂閱者pSubject->add(pSubscriber);pSubscriber = new ChatSubscriber("李四");pSubject->add(pSubscriber);pSubscriber = new ChatSubscriber("王五");pSubject->add(pSubscriber);pSubject->setMsg("主管回來了");pSubject->notify(); //發(fā)布者通知所有訂閱者return 0; }
總結(jié)
以上是生活随笔為你收集整理的小话设计模式三:发布/订阅模式的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Fikker反向代理服务器的网站缓存加速
- 下一篇: Ubuntu Tweak 0.8.2 发