简单记录以备学习，如果有误请指出。

Observer_info:观察者 rpl_handler.h

classObserver_info{//插件观察者public:void*observer;//这个void指针是具体的观察者，使用指针函数实现多态st_plugin_int*plugin_int;plugin_refpluginObserver_info(void*ob,st_plugin_int*p);};

实际观察者
及void* 指向的对象，其中全部都是函数指针，这里通过函数指针指向了具体的函数，实现了插件的功能。其中的函数指针指向的实际函数就是需要用户自己实现的。

Trans_observer结构体Server_state_observer结构体Binlog_transmit_observer结构体Binlog_relay_IO_observer结构体

实际上看具体实现的时候，搜索这些结构的名字，插件中如果实现会定义实际的函数名。如MGR中如下：

Trans_observertrans_observer={sizeof(Trans_observer),group_replication_trans_before_dml,group_replication_trans_before_commit,group_replication_trans_before_rollback,group_replication_trans_after_commit,group_replication_trans_after_rollback,};

Delegate:委托者基类
其中包含

Observer_info_listobserver_info_list;//观察者链表，也就是Observer_info的一个链表mysql_rwlock_tlock;//读写锁MEM_ROOTmemroot;//内存空间boolinited;//是否初始化

并且实现了一些通用的函数，比如增加和删除插件

具体的委托者继承自Delegate

Trans_delegate：事物相关typedefTrans_observerObserver;Server_state_delegate：服务器相关typedefServer_state_observerObserver;Binlog_transmit_delegate：传输相关typedefBinlog_transmit_observerObserver;Binlog_relay_IO_delegate：slave相关typedefBinlog_relay_IO_observerObserver;二、注册函数

举例rpl_handler.cc中

intregister_trans_observer(Trans_observer*observer,void*p){returntransaction_delegate->add_observer(observer,(st_plugin_int*)p);}

observer已经初始化完成，注册即可。这里加入到了观察者队列。一旦加入这个链表则，在实际使用的时候就会遍历整个链表执行相应的函数。

RUN_HOOK 宏
定义如下：

#defineRUN_HOOK(group,hook,args)\(group##_delegate->is_empty()?\0:group##_delegate->hookargs)#defineNO_HOOK(group)(group##_delegate->is_empty())

这个宏会在MySQL中代码的相应合适的位置进行调用，进入插件定义的逻辑。

FOREACH_OBSERVER 宏
定义如下：

#defineFOREACH_OBSERVER(r,f,thd,args)\/*Useastructtomakesurethattheyareallocatedadjacent,checkdelete_dynamic().*/\Prealloced_array<plugin_ref,8>plugins(PSI_NOT_INSTRUMENTED);\//定义一个插件数组read_lock();\Observer_info_iteratoriter=observer_info_iter();\//迭代器Observer_info*info=iter++;\//for(;info;info=iter++)\{\plugin_refplugin=\my_plugin_lock(0,&info->plugin);\if(!plugin)\{\/*pluginisnotintializedordeleted,thisisnotanerror*/\r=0;\break;\}\plugins.push_back(plugin);\if(((Observer*)info->observer)->f\&&((Observer*)info->observer)->fargs)\{\r=1;\sql_print_error("Runfunction'"#f"'inplugin'%s'failed",\info->plugin_int->name.str);\break;\}\}\

实际上可以看到是在遍历相应的实际委托者的链表observer_info_list，执行相应的回表函数。

RUN_HOOK(transaction,before_commit,(thd,all,thd_get_cache_mngr(thd)->get_binlog_cache_log(true),thd_get_cache_mngr(thd)->get_binlog_cache_log(false),max<my_off_t>(max_binlog_cache_size,max_binlog_stmt_cache_size))

根据RUN_HOOK定义 group ##_delegate->hook args 转换为：

transaction_delegate->before_commit(thd,all,thd_get_cache_mngr(thd)->get_binlog_cache_log(true),thd_get_cache_mngr(thd)->get_binlog_cache_log(false),max<my_off_t>(max_binlog_cache_size,max_binlog_stmt_cache_size)

此处的transaction_delegate是一个已经初始化的并且已经有插件注册的Trans_delegate类的全局对象。因为Trans_delegate继承来自Delegate，而在Trans_delegate中实现了before_commit的逻辑。其中包含的宏调用

FOREACH_OBSERVER(ret,before_commit,thd,(&param));//这里会执行回调函数宏定义：(#defineFOREACH_OBSERVER(r,f,thd,args))

做回调，实际上他会遍历整个transaction_delegate中的观察者，这些观察者就是每一个插件实现的特定的GROUP的功能，所以FOREACH_OBSERVER宏的这一句

((Observer*)info->observer)->fargs

就装换为了(Trans_observer *)info->observer)->before_commit(&param) 其中info是一个Observer_info对象其中包含了一个VOID指针observer，可以转换为需要的类型，而Trans_observer是一个结构体其中全部都是函数指针before_commit是一个函数指针指向了group_replication_trans_before_commit，整个回调过程完成。

调用图如下：

RUN_HOOK.png

作者微信：

微信.jpg