c语言 socket.io,纯C语言版本的socket.io服务器端实现

拼搏现实的明天。 2022-10-14 14:48 203阅读 0赞

前言

哈，这又是一个socket.io服务端实现，本意是，拿C练练手，加强对C和linux系统的理解，写着写着，就写成了一个socket.io服务器端实现了。以为半成品，那就正式托管在github站点上吧，以便记录一下，可让大家批评与指正，加强内功的修炼等。

项目地址为：yongboy/c\_socket.io\_server

以下部分文字，偷懒，摘录自项目的README.md文件

说明

这是一个纯C语言版本的socket.io服务器端实现，目前仅支持linux系统，严重依赖libev and glib等基础库。

在运行socket.io\_server之前，需要安装以下依赖：

sudo apt-get install uuid-dev

sudo apt-get install libglib2.0-dev

如何运行

编写实现代码(eg:chatroom.c)，需要包含头文件 endpoint\_impl.h

把实现代码(eg:chatroom.c)放入examples目录

编写对应的html文件，放入static目录

编辑Makefile文件

终端下运行make命令

然后敲入 ./socket.io\_server 接口运行

打开浏览器即可访问 (eg:http://localhost:8000/chatroom.html)

API说明

对外的API，可以在头文件 endpoint\_impl.h 看到其定义，其继承了另外一个公用的头文件 endpoint.h, 其完整定义为：

\#include

typedefstruct\{

char\*message\_type;

char\*message\_id;

char\*endpoint;

char\*message\_data;

char\*ori\_data;

\} message\_fields;

typedefstruct\{

char\*endpoint;

void(\*on\_init)(constchar\*endpoint);

void(\*on\_connect)(constchar\*sessionid);

void(\*on\_message)(constchar\*sessionid,constmessage\_fields \*msg\_fields);

void(\*on\_json\_message)(constchar\*sessionid,constmessage\_fields \*msg\_fields);

void(\*on\_event)(constchar\*sessionid,constmessage\_fields \*msg\_fields);

void(\*on\_other)(constchar\*sessionid,constmessage\_fields \*msg\_fields);

void(\*on\_disconnect)(constchar\*sessionid,constmessage\_fields \*msg\_fields);

void(\*on\_destroy)(constchar\*endpoint);

\} endpoint\_implement;

externvoidsend\_msg(char\*sessionid,char\*message);

externvoidbroadcast\_clients(char\*except\_sessionid,char\*message);

staticvoidon\_init(constchar\*endpoint);

staticvoidon\_connect(constchar\*sessionid);

staticvoidon\_message(constchar\*sessionid,constmessage\_fields \*msg\_fields) \{

printf("on\_message recevie ori msg is %s\\n", msg\_fields->ori\_data);

staticvoidon\_json\_message(constchar\*sessionid,constmessage\_fields \*msg\_fields) \{

printf("on\_json\_message recevie ori msg is %s\\n", msg\_fields->ori\_data);

staticvoidon\_other(constchar\*sessionid,constmessage\_fields \*msg\_fields) \{

printf("on\_other recevie ori msg is %s\\n", msg\_fields->ori\_data);

staticvoidon\_event(constchar\*sessionid,constmessage\_fields \*msg\_fields);

staticvoidon\_disconnect(constchar\*sessionid,constmessage\_fields \*msg\_fields);

staticvoidon\_destroy(constchar\*endpoint);

staticendpoint\_implement \*init\_default\_endpoint\_implement(char\*endpoint\_name) \{

endpoint\_implement \*impl\_point = (endpoint\_implement \*)malloc(sizeof(endpoint\_implement));

impl\_point->endpoint = strdup(endpoint\_name);

impl\_point->on\_init = on\_init;

impl\_point->on\_connect = on\_connect;

impl\_point->on\_message = on\_message;

impl\_point->on\_json\_message = on\_json\_message;

impl\_point->on\_event = on\_event;

impl\_point->on\_other = on\_other;

impl\_point->on\_disconnect = on\_disconnect;

impl\_point->on\_destroy = on\_destroy;

returnimpl\_point;

完整定义.

在example目录中，你可以看到聊天室演示chatroom 和在线白板示范whiteboard .

\#include

\#include "../endpoint\_impl.h"

typedefstruct\{

char\*event\_name;

char\*event\_args;

\} event\_message;

staticchar\*event\_message\_reg ="\{\\"name\\":\\"(.\*?)\\",\\"args\\":\\\\\[(\[^\\\\\]\]\*?)\\\\\]\}";

staticgchar \*get\_match\_result(GMatchInfo \*match\_info, gint index) \{

gchar \*match = g\_match\_info\_fetch(match\_info, index);

gchar \*result = g\_strdup(match);

g\_free(match);

returnresult;

staticvoid\*message\_2\_struct(gchar \*post\_string, event\_message \*event\_msg) \{

GError \*error = NULL;

GRegex \*regex;

GMatchInfo \*match\_info;

regex = g\_regex\_new(event\_message\_reg, 0, 0, &error );

g\_regex\_match( regex, post\_string, 0, &match\_info );

if(g\_match\_info\_matches(match\_info)) \{

event\_msg->event\_name = get\_match\_result(match\_info, 1);

event\_msg->event\_args = get\_match\_result(match\_info, 2);

\}else\{

event\_msg = NULL;

g\_match\_info\_free( match\_info );

g\_regex\_unref( regex );

returnevent\_msg;

staticGHashTable \*hashtable;

staticvoidhashtable\_init(void) \{

hashtable = g\_hash\_table\_new(g\_str\_hash, g\_str\_equal);

staticvoidhashtable\_add(constchar\*key,void\*value) \{

if(key) \{

g\_hash\_table\_insert(hashtable, g\_strdup(key), value);

staticgboolean hashtable\_remove(constchar\*key) \{

if(key)

returng\_hash\_table\_remove(hashtable, key);

return0;

staticvoid\*hashtable\_lookup(constchar\*key) \{

if(key == NULL)

returnNULL;

returng\_hash\_table\_lookup(hashtable, key);

/\*static gint hashtable\_size(void) \{

return g\_hash\_table\_size(hashtable);

\}\*/

staticvoidhashtable\_destroy(void) \{

g\_hash\_table\_destroy(hashtable);

/\*\*

\*\* use the struct to warpper the demo implment

\*\*/

staticchar\*endpoint\_name;

staticvoidon\_init(constchar\*endpoint) \{

hashtable\_init();

printf("%s has been inited now\\n", endpoint);

endpoint\_name = g\_strdup(endpoint);

staticvoidon\_connect(constchar\*sessionid) \{

charmessages\[strlen(sessionid) + 50\];

sprintf(messages,"5::%s:\{\\"name\\":\\"clientId\\",\\"args\\":\[\{\\"id\\":\\"%s\\"\}\]\}", endpoint\_name, sessionid);

send\_msg(sessionid, messages);

staticvoidsend\_it(char\*session\_id,char\*messaage) \{

send\_msg(session\_id, messaage);

staticvoidfree\_event\_msg(event\_message \*event\_msg) \{

free(event\_msg->event\_name);

free(event\_msg->event\_args);

staticvoidon\_event(constchar\*sessionid,constmessage\_fields \*msg\_fields) \{

event\_message event\_msg;

if(!message\_2\_struct(msg\_fields->message\_data, &event\_msg)) \{

fprintf(stderr,"%s Parse Message Error !\\n", msg\_fields->ori\_data);

return;

if(!strcmp(event\_msg.event\_name,"roomNotice")) \{

/\*5::/whiteboard:\{"name":"roomNotice","args":\[\{"room":"myRoom"\}\]\}\*/

chartarget\_room\_id\[strlen(event\_msg.event\_args) - 10\];// = event\_msg.event\_args + 9;

strncpy(target\_room\_id, event\_msg.event\_args + 9, strlen(event\_msg.event\_args) - 11);

GPtrArray \*list = (GPtrArray \*)hashtable\_lookup(target\_room\_id);

if(list == NULL) \{

list = g\_ptr\_array\_new();

hashtable\_add(target\_room\_id, list);

g\_ptr\_array\_add(list, g\_strdup(sessionid));

introom\_count = list->len;

charmessages\[strlen(sessionid) + 200\];

sprintf(messages,"5::%s:\{\\"name\\":\\"roomCount\\",\\"args\\":\[\{\\"room\\":\\"%s\\",\\"num\\":%d\}\]\}", endpoint\_name, target\_room\_id, room\_count);

hashtable\_add(g\_strdup(sessionid), g\_strdup(target\_room\_id));

g\_ptr\_array\_foreach(list, (GFunc)send\_it, messages);

free\_event\_msg(&event\_msg);

return;

charmessages\[strlen(msg\_fields->ori\_data) + 200\];

sprintf(messages,"5::%s:\{\\"name\\":\\"%s\\",\\"args\\":\[%s\]\}", endpoint\_name, event\_msg.event\_name, event\_msg.event\_args);

free\_event\_msg(&event\_msg);

char\*target\_room\_id = (char\*)hashtable\_lookup(sessionid);

GPtrArray \*list = (GPtrArray \*)hashtable\_lookup(target\_room\_id);

if(list == NULL)\{

return;

inti;

for(i = 0; i len; i++) \{

char\*session\_id = g\_ptr\_array\_index(list, i);

if(strcmp(session\_id, sessionid) == 0)

continue;

send\_msg(session\_id, messages);

staticvoidon\_disconnect(constchar\*sessionid,constmessage\_fields \*msg\_fields) \{

char\*room\_id = (char\*)hashtable\_lookup(sessionid);

if(room\_id == NULL) \{

fprintf(stderr,"the room\_id is NULL\\n");

return;

charnotice\_msg\[strlen(endpoint\_name) + strlen(room\_id) + 70\];

GPtrArray \*list = (GPtrArray \*)hashtable\_lookup(room\_id);

sprintf(notice\_msg,"5::%s:\{\\"name\\":\\"roomCount\\",\\"args\\":\[\{\\"room\\":\\"%s\\",\\"num\\":%d\}\]\}", endpoint\_name, room\_id, list->len - 1);

inti, remove\_index;

for(i = 0; i len; i++) \{

char\*session\_id = g\_ptr\_array\_index(list, i);

if(strcmp(session\_id, sessionid) == 0) \{

remove\_index = i;

continue;

send\_msg(session\_id, notice\_msg);

g\_ptr\_array\_remove\_index(list, remove\_index);

hashtable\_remove(sessionid);

free(room\_id);

staticvoidon\_destroy(constchar\*endpoint) \{

printf("%s has been destroy now\\n", endpoint);