定义了一对多的依赖关系,让多个观察者对象同时监听某一主体对象。这个主题对象在状态发生变化时,会通知所有观察者对象,使它们能够自动更新自己。

    image.png

    1. #include <algorithm>
    2. #include <iostream>
    3. #include <memory>
    4. #include <vector>
    5. class ConcreteSubject;
    6. /* 抽象观察者,为所有具体观察者定义一个接口,在得到主题通知时更新自己 */
    7. class Observer {
    8. public:
    9. explicit Observer(const std::shared_ptr<ConcreteSubject> &subject)
    10. : subject_(subject) {}
    11. virtual void update() = 0;
    12. virtual ~Observer() = default;
    13. protected:
    14. std::weak_ptr<ConcreteSubject> subject_;
    15. };
    16. /* 主题/抽象通知者 */
    17. class Subject {
    18. public:
    19. /* 增加观察者 */
    20. void attach(const std::shared_ptr<Observer> &observer) {
    21. observers.emplace_back(observer);
    22. }
    23. /* 移除观察者 */
    24. void detach(const std::shared_ptr<Observer> &observer) {
    25. observers.erase(std::remove(observers.begin(), observers.end(), observer));
    26. }
    27. /* 通知 */
    28. void notify() {
    29. for (auto &ob : observers) {
    30. ob->update();
    31. }
    32. }
    33. virtual ~Subject() = default;
    34. private:
    35. std::vector<std::shared_ptr<Observer>> observers;
    36. };
    37. /* 具体主题/具体通知者 */
    38. class ConcreteSubject final : public Subject {
    39. public:
    40. std::string getState() const { return subjectState; }
    41. void setState(const std::string &value) { subjectState = value; }
    42. ~ConcreteSubject() = default;
    43. private:
    44. std::string subjectState;
    45. };
    46. class ConcreteObserver final : public Observer {
    47. public:
    48. ConcreteObserver(const std::shared_ptr<ConcreteSubject> &subject,
    49. const std::string name)
    50. : Observer(subject), name_(name) {}
    51. void update() override {
    52. if (const auto p = subject_.lock()) {
    53. observerState_ = p->getState();
    54. std::cout << "Observer" << name_ << " new state is " << observerState_
    55. << '\n';
    56. }
    57. }
    58. private:
    59. std::string name_;
    60. std::string observerState_;
    61. };
    62. auto main() -> int {
    63. std::shared_ptr<ConcreteSubject> subject =
    64. std::make_shared<ConcreteSubject>();
    65. std::shared_ptr<ConcreteObserver> ob1 =
    66. std::make_shared<ConcreteObserver>(subject, "X");
    67. std::shared_ptr<ConcreteObserver> ob2 =
    68. std::make_shared<ConcreteObserver>(subject, "Y");
    69. std::shared_ptr<ConcreteObserver> ob3 =
    70. std::make_shared<ConcreteObserver>(subject, "Z");
    71. subject->attach(ob1);
    72. subject->attach(ob2);
    73. subject->attach(ob3);
    74. subject->setState("ABC");
    75. subject->notify();
    76. std::cout << '\n';
    77. subject->detach(ob1);
    78. subject->setState("DEF");
    79. subject->notify();
    80. return 0;
    81. }

    将一个系统分割成一系列相互协作的类需要维护相关对象间的一致性。这样的耦合性会给维护、扩展和重用带来不便。
    观察者模式实际上就是在解耦,让耦合的双方都依赖于抽象,而不依赖于具体。