代码拉取完成,页面将自动刷新
同步操作将从 libhv/libhv 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
/*
* tcp chat server
*
* @build make examples
* @server bin/tcp_chat_server 1234
* @clients bin/nc 127.0.0.1 1234
* nc 127.0.0.1 1234
* telnet 127.0.0.1 1234
*/
#include "hloop.h"
#include "hsocket.h"
#include "hbase.h"
#include "list.h"
unpack_setting_t unpack_setting;
// hloop_create_tcp_server
// on_accept => join
// on_recv => broadcast
// on_close => leave
typedef struct chatroom_s {
hloop_t* loop;
hio_t* listenio;
int roomid;
struct list_head conns;
} chatroom_t;
typedef struct connection_s {
hio_t* connio;
char addr[SOCKADDR_STRLEN];
struct list_node node;
} connection_t;
static chatroom_t s_chatroom;
static void join(chatroom_t* room, connection_t* conn);
static void leave(chatroom_t* room, connection_t* conn);
static void broadcast(chatroom_t* room, const char* msg, int msglen);
void join(chatroom_t* room, connection_t* conn) {
list_add(&conn->node, &room->conns);
char msg[256] = {0};
int msglen = 0;
struct list_node* node;
connection_t* cur;
msglen = snprintf(msg, sizeof(msg), "room[%06d] clients:\r\n", room->roomid);
hio_write(conn->connio, msg, msglen);
list_for_each (node, &room->conns) {
cur = list_entry(node, connection_t, node);
msglen = snprintf(msg, sizeof(msg), "[%s]\r\n", cur->addr);
hio_write(conn->connio, msg, msglen);
}
hio_write(conn->connio, "\r\n", 2);
msglen = snprintf(msg, sizeof(msg), "client[%s] join room[%06d]\r\n", conn->addr, room->roomid);
broadcast(room, msg, msglen);
}
void leave(chatroom_t* room, connection_t* conn) {
list_del(&conn->node);
char msg[256] = {0};
int msglen = snprintf(msg, sizeof(msg), "client[%s] leave room[%d]\r\n", conn->addr, room->roomid);
broadcast(room, msg, msglen);
}
void broadcast(chatroom_t* room, const char* msg, int msglen) {
printf("> %.*s", msglen, msg);
struct list_node* node;
connection_t* conn;
list_for_each (node, &room->conns) {
conn = list_entry(node, connection_t, node);
hio_write(conn->connio, msg, msglen);
}
}
static void on_close(hio_t* io) {
printf("on_close fd=%d error=%d\n", hio_fd(io), hio_error(io));
connection_t* conn = (connection_t*)hevent_userdata(io);
if (conn) {
hevent_set_userdata(io, NULL);
leave(&s_chatroom, conn);
HV_FREE(conn);
}
}
static void on_recv(hio_t* io, void* buf, int readbytes) {
printf("on_recv fd=%d readbytes=%d\n", hio_fd(io), readbytes);
char localaddrstr[SOCKADDR_STRLEN] = {0};
char peeraddrstr[SOCKADDR_STRLEN] = {0};
printf("[%s] <=> [%s]\n",
SOCKADDR_STR(hio_localaddr(io), localaddrstr),
SOCKADDR_STR(hio_peeraddr(io), peeraddrstr));
printf("< %.*s", readbytes, (char*)buf);
// broadcast
connection_t* conn = (connection_t*)hevent_userdata(io);
assert(conn != NULL);
char msg[256] = {0};
int msglen = snprintf(msg, sizeof(msg), "client[%s] say: %.*s", conn->addr, readbytes, (char*)buf);
broadcast(&s_chatroom, msg, msglen);
}
static void on_accept(hio_t* io) {
printf("on_accept connfd=%d\n", hio_fd(io));
char localaddrstr[SOCKADDR_STRLEN] = {0};
char peeraddrstr[SOCKADDR_STRLEN] = {0};
printf("accept connfd=%d [%s] <= [%s]\n", hio_fd(io),
SOCKADDR_STR(hio_localaddr(io), localaddrstr),
SOCKADDR_STR(hio_peeraddr(io), peeraddrstr));
hio_setcb_close(io, on_close);
hio_setcb_read(io, on_recv);
hio_set_unpack(io, &unpack_setting);
hio_read_start(io);
// free on_close
connection_t* conn = NULL;
HV_ALLOC_SIZEOF(conn);
conn->connio = io;
strcpy(conn->addr, peeraddrstr);
hevent_set_userdata(io, conn);
join(&s_chatroom, conn);
}
int main(int argc, char** argv) {
if (argc < 2) {
printf("Usage: %s port\n", argv[0]);
return -10;
}
int port = atoi(argv[1]);
memset(&unpack_setting, 0, sizeof(unpack_setting_t));
unpack_setting.package_max_length = DEFAULT_PACKAGE_MAX_LENGTH;
unpack_setting.mode = UNPACK_BY_DELIMITER;
unpack_setting.delimiter[0] = '\n';
unpack_setting.delimiter_bytes = 1;
hloop_t* loop = hloop_new(0);
hio_t* listenio = hloop_create_tcp_server(loop, "0.0.0.0", port, on_accept);
if (listenio == NULL) {
return -20;
}
printf("listenfd=%d\n", hio_fd(listenio));
s_chatroom.loop = loop;
s_chatroom.listenio = listenio;
s_chatroom.roomid = hv_rand(100000, 999999);
list_init(&s_chatroom.conns);
hloop_run(loop);
hloop_free(&loop);
return 0;
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。