写了一个消息队列服务器，欢迎大家吐槽

liexusong

详细可以查看地址：https://github.com/liexusong/mx-queued

hellioncu

下载了，大致看了看，虽然没什么文档，注释也很少，不过还是比较清晰易懂的。
数据好像只在内存，没有持久化机制。

1. void mx_process_command(mx_connection_t *conn)
   
2. {
   
3.     char *bline, *eline;
   
4.     mx_token_t tokens[MX_MAX_TOKENS];
   
5.     int tokens_count;
   
6.     mx_command_t *cmd;
   
7.     int i, movcnt;
   
8. 
   
9. again:
   
10.     bline = conn->recvpos;
    
11.     eline = memchr(bline, '\n', conn->recvlast - bline);
    
12.     if (!eline)
    
13.         return;
    
14.     conn->recvpos = eline + 1;
    
15.     if (eline - bline > 1 && *(eline - 1) == '\r')
    
16.         eline--;
    
17.     *eline = '\0';
    
18. 
    
19.     memset(tokens, 0, sizeof(tokens));  // 这句应该不需要，反正我是不喜欢
    
20.    
    
21.     tokens_count = mx_tokenize_command(bline, tokens, MX_MAX_TOKENS);
    
22.     if (tokens_count == 0) {
    
23.         mx_send_reply(conn, "-ERR command invaild");
    
24.         return;
    
25.     }
    
26.    
    
27.     cmd = mx_find_command(tokens[0].value, tokens[0].length);
    
28.     if (!cmd->name || cmd->argcnt != tokens_count) {
    
29.         mx_send_reply(conn, "-ERR command invaild");
    
30.         return;
    
31.     }
    
32.    
    
33.     cmd->handler(conn, tokens, tokens_count);
    
34.    
    
35.     if (conn->recvpos < conn->recvlast) {
    
36.         movcnt = conn->recvlast - conn->recvpos;
    
37.         memcpy(conn->recvbuf, conn->recvpos, movcnt); // 这里可能有重叠，应该用memmove
    
38.         conn->recvpos = conn->recvbuf;
    
39.         conn->recvlast = conn->recvbuf + movcnt;
    
40.         goto again;
    
41.     } else { /* all buffer process finish */
    
42.         conn->recvpos = conn->recvbuf;
    
43.         conn->recvlast = conn->recvbuf;
    
44.     }
    
45.     return;
    
46. }

复制代码

liexusong

回复 2# hellioncu


    谢谢指导

zylthinking

liexusong 发表于 2013-05-23 15:23
详细可以查看地址：https://github.com/liexusong/mx-queued

还不如讲讲思路， 说说为啥快来的实在

hellioncu

liexusong 发表于 2013-05-23 15:53
回复 2# hellioncu

指导不敢当
不过我还是要吐槽

mx_create_connection中

        conn->recvbuf = malloc(MX_RECVBUF_SIZE);
        conn->sendbuf = malloc(MX_SENDBUF_SIZE);

recvbuf和sendbuf都是固定的，也没见地方地方有realloc，为什么不直接定义成

char recvbuf [MX_RECVBUF_SIZE]之类的，这样一个malloc就搞定，不用malloc三次了。

当然如果连接新建和断开很频繁，最好用池。

最后想知道LZ写这个服务器的目的是什么。

liexusong

hellioncu 发表于 2013-05-23 16:12
指导不敢当
不过我还是要吐槽

使用malloc的原因是因为我有强烈的代码洁癖，写成数组我觉得很难看（不要鄙视我），另外我写这个服务器是希望自己一直更新下去，直到有一天可以成为一个真正可以让大家认可的东西。

hellioncu

liexusong 发表于 2013-05-23 16:15
使用malloc的原因是因为我有强烈的代码洁癖，写成数组我觉得很难看（不要鄙视我），另外我写这个服务器 ...

服务器不就讲究稳定和高性能么，没了这两点，再漂亮的代码也没用

z78290250

还是希望楼主维护一个中文文档， 我可以看文档进行学习交流， 希望楼主多补一些注释吧。

346196247

我想说，我太懒是来看你们这些 大神华山论剑的

core1011

楼主 如果真的 想继续更新下去的话，你应该把文档什么的 全部整理出来，这样才会更加完美，
支持楼主，在这里！