一种基于消息发布-订阅的观察者模式实现

notice.h
#define OBSERVER_MAX    4


typedef struct notice_msg {
    // public
    char            *sub_name;
    int             cmd;
    int             data_fix;           // 固定数据 
    
    unsigned int    data_ex_len;         // 扩展数据长度，0:没有扩展数据
    void            *pdata_ex;           // 扩展数据指针
}notice_msg_t;

typedef int (*NOTICE_ON_MSG_CB)(notice_msg_t *pmsg);

typedef struct notice_observer {
    ak_queue_t  msg_queue;

}notice_observer_t;


typedef struct notice_subject {
    char *name;
    notice_observer_t* obs_tbl[OBSERVER_MAX];
}notice_subject_t;
notice.h
#define OBSERVER_MAX    4


t