本帖最后由 MacRsh 于 2023-7-5 21:14 编辑
事件驱动框架是一种异步事件处理机制,它通过事件分发和回调的方式,可以有效地提高系统的异步处理能力、解耦性和可扩展性。
事件驱动框架包含两个主要组件:事件服务器和事件客户端。
- 事件服务器用于接收和分发事件,它内部维护一个事件队列用于存储待处理事件和一个事件列表用于存储注册的事件客户端。
- 事件客户端用于处理特定类型的事件,它需要注册到事件服务器并提供一个回调函数。
当事件发生时,事件服务器会将事件插入到其事件队列中进行缓存。事件服务器会周期性地从事件队列中取出事件进行分发,找到对应的事件客户端,然后调用其注册的回调函数进行事件处理。
事件驱动框架代码模块，可无依赖，快速的部署到工程应用中。
事件驱动框架原型
- <div><span class="code-block-extension-codeLine" data-line-num="1">/* 事件服务器 */</span>
- <span class="code-block-extension-codeLine" data-line-num="2"><span class="hljs-class"><span class="hljs-keyword">struct</span> <span class="hljs-title">event_server</span></span></span></div><div>
- <span class="code-block-extension-codeLine" data-line-num="3">{</span> </div><div><span class="code-block-extension-codeLine" data-line-num="4"><span class="hljs-class"><span class="hljs-keyword"> struct</span> <span class="hljs-title">event_fifo</span> <span class="hljs-title">queue</span>;</span> <span class="hljs-comment">/* 事件队列 */</span></span> </div><div><span class="code-block-extension-codeLine" data-line-num="5"><span class="hljs-type"> event_avl_t</span> <span class="hljs-built_in">list</span>; <span class="hljs-comment">/* 事件链表 */</span></span> </div><div><span class="code-block-extension-codeLine" data-line-num="6">};</span></div>
- queue:事件队列(用于存储要唤醒的客户端ID)。
- list:服务器链表(用于存储客户端)。
- /* 事件客户端 */
- struct event_client
- {
- struct event_avl list; /* 事件链表 */
-
- mr_err_t (*cb)(event_server_t server, void *args); /* 事件回调函数 */
- void *args; /* 事件回调函数参数 */
- };
- list:客户端链表(用于将客户端添加到服务器的客户端列表中)。
- cb：回调函数。
- args：回调函数参数。
初始化服务器
- int event_server_init(mr_event_server_t server,mr_size_t queue_length);
[td]参数 | 描述 | server | 服务器句柄 | queue_length | 服务器队列长度（同时处理事件的个数） | 返回 |
| | EVENT_ERR_OK | 添加成功 | 错误码 | 添加失败 |
重置服务器
- int event_server_uninit(event_server_t server);
[td]参数 | 描述 | server | 服务器句柄 | 返回 |
| | EVENT_ERR_OK | 移除成功 | 错误码 | 移除失败 |
通知服务器，事件发生
- int event_server_notify(event_server_t server, uint8_t id);
[td]参数 | 描述 | server | 服务器句柄 | id | 发生事件的客户端id | 返回 |
| | EVENT_ERR_OK | 通知成功 | 错误码 | 通知失败 |
服务器分发事件，唤醒客户端
- void event_server_handle(event_server_t server);
[td]
查找客户端
- event_client_t event_client_find(uint8_t id, event_server_t server);
[td]参数 | 描述 | id | 客户端id | server | 服务器句柄 | 返回 |
| | 客户端句柄 | 查找成功 | NULL | 查找失败 |
创建新客户端
- int event_client_create(uint8_t id,
- int (*cb)(event_server_t server, void *args),
- void *args,
- event_server_t server);
[td]参数 | 描述 | id | 客户端id | cb | 回调函数 | args | 回调函数参数 | server | 服务器句柄 | 返回 |
| | EVENT_ERR_OK | 创建成功 | 错误码 | 创建失败 |
删除客户端
- int client_delete(uint8_t id, event_server_t server);
[td]参数 | 描述 | id | 客户端id | server | 服务器句柄 | 返回 |
| | EVENT_ERR_OK | 删除成功 | 错误码 | 删除失败 |
使用示例：
- /* 定义事件 */
- #define EVENT1 1
- #define EVENT2 2
- #define EVENT3 3
- /* 定义事件服务器 */
- struct event_server event_server;
- int event1_cb(event_server_t server, void *args)
- {
- printf("event1_cb\r\n");
-
- /* 通知事件服务器事件2发生 */
- event_server_notify(server, EVENT2);
-
- return 0;
- }
- int event2_cb(event_server_t server, void *args)
- {
- printf("event2_cb\r\n");
-
- /* 通知事件服务器事件3发生 */
- event_server_notify(server, EVENT3);
-
- return 0;
- }
- int event3_cb(event_server_t server, void *args)
- {
- printf("event3_cb\r\n");
-
- return 0;
- }
- int main(void)
- {
- /* 添加事件服务器到内核容器 */
- event_server_init(&event_server, 4);
-
- /* 创建事件客户端到事件服务器 */
- event_client_create(EVENT1, event1_cb, NULL, &event_server);
- event_client_create(EVENT2, event2_cb, NULL, &event_server);
- event_client_create(EVENT3, event3_cb, NULL, &event_server);
-
- /* 通知事件服务器事件1发生 */
- event_server_notify(&event_server, EVENT1);
-
- while (1)
- {
- event_server_handle(&event_server);
现象：
- event1_cb
- event2_cb
- event3_cb
下载代码（https://gitee.com/MacRsh/mr-library/tree/master/）（路径：mr-library/ package / event）
许可协议遵循 Apache License 2.0 开源许可协议，可免费应用于商业产品，无需公开私有代码。
| 
楼主
