我正在将 Warmcat 的 libwebsocket C 库用于小型 Websocket 服务器。我已经启动并运行了这些示例,并且可以发送数据以响应从 websocket 接收数据(例如回显发送的反向字节)。但是,我无法弄清楚如何在不使用 libwebsocket 回调函数的情况下从服务器异步发送数据。我需要将 wsi 指针传递给 libwebsocket_write() 但不知道如何获取指针,除非在回调中。
我读过 libwebsocket 不是线程安全的,我自己的经验似乎证实了这一点。
在 libwebsockets.c:line2483 中,我读到“定期调用协议回调函数以允许异步传输。”这正是我想要的,但我没有在我自己的代码中观察到这种情况发生,也没有找到任何方法来“打开它”。
关于如何异步写入我正在服务的 websocket 的建议?
libwebsocket 的代码:http://git.warmcat.com/cgi-bin/cgit/libwebsockets/ http://git.warmcat.com/cgi-bin/cgit/libwebsockets/
使用示例:http://martinsikora.com/libwebsockets-simple-websocket-server http://martinsikora.com/libwebsockets-simple-websocket-server
我还没有找到一种超级干净的方法来做到这一点。我建议是在服务器可以写入客户端的事件上注册一个回调,然后检查是否有异步工作要发送到那里。这LWS_CALLBACK_SERVER_WRITEABLE
事件就是这样,如果你打电话libwebsocket_callback_on_writable(context, wsi);
从您的回调中,它将被定期调用。
所以,像这样:
static int callback_myprotocol(struct libwebsocket_context *context,
struct libwebsocket *wsi,
enum libwebsocket_callback_reasons reason,
void *user, void *in, size_t len)
{
SendState *ss = (SendState*)user;
switch (reason) {
case LWS_CALLBACK_ESTABLISHED:
printf("connection established\n");
// get the ball rolling
libwebsocket_callback_on_writable(context, wsi);
break;
case LWS_CALLBACK_SERVER_WRITEABLE: {
if (!work_to_be_done) {
// schedule ourselves to run next tick anyway
libwebsocket_callback_on_writable(context, wsi);
return 0;
}
// send our asynchronous message
libwebsocket_write(wsi, buf, size, flag);
// and schedule ourselves again
libwebsocket_callback_on_writable(context, wsi);
break;
}
default:
break;
}
return 0;
}
我改编自test-fraggle.c
例子;上面的内容大致是该示例以较小的块发送消息的操作。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)