我正在使用用于XMPP消息传递的Strophe C库和libwebsock创建Websocket服务器。我要做的就是将strophe上收到的消息转发给Websocket客户端,反之亦然。但是我不知道该怎么做。
strophe和libwebsock都需要运行事件循环来处理事件。如何运行两个循环或将它们合并为一个循环,以便在同一程序中处理两个库中的事件?
提前致谢。 :)
最佳答案
首先,您需要创建2个线程。假设thread1为libstrophe的事件循环,而thread2为libwebsock的事件循环。总体思路可以用下面的伪代码描述:
xmpp_message_callback() {
libwebsock_send_text();
}
thread1() {
xmpp_run();
}
libwebsock_message_callback() {
xmpp_send();
}
thread2() {
libwebsock_wait();
}
main() {
init_libstrophe()
init_libwebsock();
create_thread1();
create_thread2();
join_thread1();
join_thread2();
}
但是(!)因为libstrophe不是线程安全的,所以您不能直接从thread2调用xmpp_send()。相反,我建议创建一个由互斥锁保护的队列。因此,以上示例将转换为:
list queue;
mutex queue_lock;
xmpp_message_callback() {
libwebsock_send_text();
}
thread1() {
while {
xmpp_run_once();
mutex_lock(queue_lock);
while (queue is not empty) {
stanza = list_pop_front(queue);
xmpp_send(stanza);
}
mutex_unlock(queue_lock);
}
}
libwebsock_message_callback() {
mutex_lock(queue_lock);
list_push(queue, stanza);
mutex_unlock(queue_lock);
}
thread2() {
libwebsock_wait();
}