Libevent库用于特定的协议

youyou1986925

各位大侠，小弟现在在做一个类似于echo的server，但是用的是公司制定的协议，对于这样的情况大家是怎么样用Libevent来处理的

1. void buffered_on_read(struct bufferevent *bev, void *arg)
   
2. {
   
3.     struct client *this_client = (struct client *) arg;
   
4.     struct evbuffer_ptr start;
   
5.     int msg_len;
   
6.     uint8_t *head;
   
7.     uint8_t *message;
   
8. 
   
9.     /* Copy as many data as possible */
   
10.     struct evbuffer *input = bufferevent_get_input(this_client->buf_ev);
    
11. 
    
12.     if (evbuffer_get_length(input) >= 11)
    
13.     {
    
14.         evbuffer_remove_buffer(input, g_data, BUFFER_LENGTH);
    
15. 
    
16.         for ( ; ; ) {
    
17.             start = evbuffer_search(g_data, (char *)TAG, 3, NULL);
    
18.             if (start.pos == -1) {
    
19.                 /* FCFCFC not found! */
    
20.                 break;
    
21.             }
    
22.             else if (start.pos != 0) {
    
23.                 /* Garbage message, remove it! */
    
24.                 evbuffer_drain(g_data, start.pos);
    
25.                 continue;
    
26.             }
    
27.             else {
    
28.                 /* Find right message */
    
29.                 if (evbuffer_get_length(g_data) > 11) {
    
30.                     head = evbuffer_pullup(g_data, 11);
    
31. 
    
32.                     msg_len  = head[10] & 0xFF;
    
33.                     msg_len |= (head[9] << 8) & 0xFF00;
    
34. 
    
35.                     if (evbuffer_get_length(g_data) >= (msg_len + 11)) {
    
36.                         message = evbuffer_pullup(g_data, msg_len + 11);
    
37.                         
    
38.                         /* Handle message at here */
    
39.                         handle_raw_message(this_client, message, msg_len + 11);
    
40. 
    
41.                         /* After handle, remove it */
    
42.                         evbuffer_drain(g_data, msg_len + 11);
    
43.                     }
    
44.                     else {
    
45.                         /* Message length smaller than (msg_len+11) */
    
46.                         break;
    
47.                     }
    
48.                 }
    
49.                 else
    
50.                 {
    
51.                     /* Message length smaller or equal than 11 */
    
52.                     break;
    
53.                 }
    
54. 
    
55.                 continue;
    
56.             }
    
57.         }
    
58.     }
    
59. 
    
60.     /* Add remain message to struct evbuffer input again */
    
61.     evbuffer_prepend_buffer(input, g_data);
    
62.     return;
    
63. }

复制代码

linux_c_py_php

官方有bufferevent的sample, 不过顺便推荐一下我的库: https://code.csdn.net/qq120848369/ez_poll

youyou1986925

回复 2# linux_c_py_php
官方的例子基本上都看过了，我想请教的是大家如何用Libevent来处理一些自定义的协议，比如TLV这种格式的协议。因为服务器用的是Freebsd所以你的库暂时没法用……

   

kdkgod

看DEMO，我就是用libevent开发的，用的自己的协议。