- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
作为一个学校项目,我必须重新编码 IRC 服务器,但我遇到了一个问题。我想做的是在不阻塞的情况下接收并执行客户端的命令(因为我有很多客户端要服务)。
编辑:该项目禁止使用非阻塞套接字和 fork()
关于命令:
我的第一次尝试是使用 getline 循环。它工作完美,但仅适用于一个客户端(当他们注意到更多内容要阅读而不是传递给下一个客户端时, getline 会阻塞)
bool recv_cmd(t_hdl *hdl)
{
char *raw;
size_t len;
FILE *input_stream;
ssize_t nread;
len = 0;
raw = NULL;
if ((input_stream = fdopen(dup(hdl->sender->fd), "r")) == NULL)
return (false);
while ((nread = getline(&raw, &len, input_stream)) > 0)
{
printf("%lu\n", nread);
parse_cmd(hdl, raw);
exec_cmd(hdl);
}
fclose(input_stream);
return (true);
}
如果我像这样从循环中删除 getline,它适用于所有客户端,但仅执行客户端的第一个命令(例如,如果客户端发送“command1\r\ncommand2\r\n”,则仅命令1被执行)
bool recv_cmd(t_hdl *hdl)
{
char *raw;
size_t len;
FILE *input_stream;
len = 0;
raw = NULL;
if ((input_stream = fdopen(dup(hdl->sender->fd), "r")) == NULL)
return (false);
if (getline(&raw, &len, input_stream) != -1)
{
parse_cmd(hdl, raw);
exec_cmd(hdl);
//free(raw
}
fclose(input_stream);
return (true);
}
我还尝试删除 fclose() ,以便当我们读取 command1 时,command2 保留在流缓冲区中,但它也不起作用。
该项目的主题还说“使用循环缓冲区来保护和优化正在发送和接收的各种命令和响应。”。
我该怎么做?在这种情况下,使用循环缓冲区比我的 getline 有何优点?
最佳答案
自从您使用getline()
以来,我假设您依赖 POSIX.1 功能;在这种情况下,我建议使用专用线程来接收来自所有连接的客户端的消息。
我会将传入消息放入一条链中,而不是仅仅从每个客户端动态缓冲区中读取附加数据:
#define MAX_INCOMING_LEN 512
struct incoming_message {
struct incoming_message *next;
size_t len;
char data[MAX_INCOMING_LEN];
}
客户端结构需要至少 MAX_INCOMING_LEN
的临时缓冲区字符(因为不能保证来自流套接字的 recv()
或 read()
提供完整消息,或仅提供单个消息)。如果一个单独的线程正在读取消息,那么您还需要锁定来保护消息链免受并发访问:
struct client {
int socketfd;
char received[MAX_INCOMING_LEN];
size_t received_len;
pthread_mutex_t incoming_lock;
struct incoming_message *incoming_next;
struct incoming_message *incoming_last;
};
接收新消息的函数将它们附加到列表中,在伪代码中:
Construct and fill in struct incoming_message *msg
Lock incoming_lock mutex
Set msg->next = NULL
If incoming_last != NULL:
Set incoming_last->next = msg
Set incoming_last = msg
Else
Set incoming_next = msg
Set incoming_last = msg
End If
Unlock incoming_lock mutex
使用两个指针,incoming_next
和incoming_last
,意味着我们在追加列表时不需要扫描列表。给定客户端 c
的情况下,获取下一条传入消息的函数,伪代码类似于
Function next_message(struct client *c)
{
Lock c->incoming_lock mutex
If c->incoming_next != NULL:
struct incoming_message *msg = c->incoming_next;
If msg->next != NULL
Set incoming_next = msg->next
Set msg->next = NULL
Else:
Set incoming_next = NULL
Set incoming_last = NULL
End If
Unlock c->incoming_lock mutex
Return msg
Else:
Unlock c->incoming_lock mutex
Return NULL
End If
}
请注意,对于传出消息,我会使用完全不同的结构,因为您通常会向多个客户端发送完全相同的消息。至少有两种完全不同的方法,但OP没有询问这些,所以我将省略我对这些的思考。
传入数据工作线程或套接字读取线程是唯一接触每个客户端的线程 received[]
缓冲区,因此不需要任何锁定。
假设您有以下全局变量:
static pthread_mutex_t received_lock = PTHREAD_MUTEX_INITIALIZER;
static pthread_cond_t received_more = PTHREAD_COND_INITIALIZER;
static long received_gen = 0L;
在伪代码中,套接字读取器线程循环执行以下工作:
Use select() or poll() to find out which clients' sockets have unread data
Lock received_lock mutex
Set have_received = 0
For each client whose socket has unread data:
Try receiving as much as is free in received[] buffer
If new data received:
Increment received_len by the received amount
Increment have_received by 1
If a separator exists in received[0..received_len-1]:
Let N be the offset of the character following the separator
Grab or allocate a new incoming_message structure
Copy the first N chars of received[] to the new structure
Lock the incoming_lock mutex
Prepend the structure to the singly-linked list
Unlock the incoming_lock mutex
If N < received_len:
memmove(received, received + N, received_len - N)
received_len -= N
Else:
received_len = 0
End If
End If
End If
End If
If have_received > 0:
Increment received_gen by 1
Signal on received_more condition variable
End If
Unlock received_lock mutex
received_lock
的目的, received_wait
,和received_gen
是为了避免在没有新消息进来时出现忙循环。
假设您使用主线程来处理每个传入消息,它将有一个循环,循环体如下所示:
Lock received_lock mutex
before_gen = received_gen
Unlock received_lock mutex
Set msg_count = 0
For each client:
Lock client->incoming_lock
If the list is not empty:
Increment msg_count by 1
Grab the last message in the list
Unlock client->incoming_lock
Process the message
Else:
Unlock client->incoming_lock
End If
End For
If msg_count == 0:
Lock received_lock mutex
after_gen = received_gen
If after_gen == before_gen:
pthread_cond_wait(received_more, received_lock)
End if
Unlock received_lock mutex
End If
我们不想持有 received_lock
任何时间长度,因为这会阻止接收新消息。相反,我们使用 received_gen
作为生成计数器:如果没有工作要做,我们检查生成计数器是否已更改。如果是,可能还有更多工作要做,因此我们继续主循环的下一次迭代。否则,请注意我们仍然持有互斥体,我们等待条件变量上的信号。
关于C socket : Non blocking way to read\n separated commands,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44228440/
我正在使用 gmock 并模拟了一个函数 boost::beast::http::response_parser作为输出参数。功能签名看起来像: error_code readFromSocket(b
我的任务是打印由“非元音、元音、非元音”组成的单词列表,即 bab、bac、bad、bad ... 到 zuz。 我已经设法创建了一个代码,它执行前两个字母,但在最后一个循环中丢失并只打印'}' -
我正在尝试使用 label2rgb 生成 RGB 标签切片并使用它来更新 RGB 体积,如下所示: labelRGB_slice=label2rgb(handles.label(:,:,han
我有一个很奇怪的问题。我在 dll 中定义了一个接口(interface),如下所示: public interface IKreator2 { string Name { get; set;
在我的 openshift Drupal 托管中,网络都在 SSL 下 http://domain.com -> https://www.domain.com 确定 http://www.domain
我收到警告“退出构造函数时不可为空的事件‘SomeEvent’必须包含非空值。考虑将事件声明为可空。” 这是我的代码的一个非常简化的版本,它复制了完全相同的问题。我在这里错过了什么?这与 .Net 6
在一次大学考试中,我被要求测试一些 apache 簿记员类/方法,在这样做的过程中,我想在我的参数化测试中使用 mockito。没有 mockito 的测试工作正常但是当我尝试模拟接口(interfa
假设 A 列在 7 行中有以下值: 2 [空白的] 0 -0.3 0 [空白的] 0 如何获取范围(7 行)中非空/空白且不为零的最后一个值?因此,在这种情况下,正确答案是 -0.3。 最佳答案 =I
考虑以下受 this talk 启发的代码: template struct even_common_type_helper_impl; template struct even_common_typ
考虑这段代码, struct A {}; struct B { B(const A&) {} }; void f(B) { cout << "f()"<
考虑下面的类(class)。如果我对它运行 Findbugs,它会在第 5 行但不在第 7 行给我一个错误(“可序列化类中的非 transient 非可序列化实例字段”)。 1 public clas
我正在编写一个 python 脚本来计算 数据包丢失 通过使用 ping IP 地址linux 中的 subprocess 模块。 CSV 文件中保存了多个 IP 地址。当只给出可 ping 目的地时
我只是做文本更改,在文本之前它工作正常。请任何人都可以帮助我。 提前致谢 最佳答案 我已经解决了: ionic cordova 插件rmcordova-plugin-ionic-webview ion
我如何定义 在 persistence.xml 中? 我的项目在 Tomcat 6 和 Tomcat 7 中运行良好。 现在我正在使用 Struts 2 Spring 3.0.5 JPA 2 Jbos
我有一个 maven 仓库中不存在的第三方 jar,我们称它为“a.jar”,它也依赖于至少 20 多个第三方 jar,其中大部分不在 maven 中或者,我们称它们为“b.jar、c.jar、d.j
我已经浏览了各种线程很多小时(不夸张),但一直无法找到一种解决方案组合,使我能够将非 www 和 http 转发到 www 和 https,同时仍然能够查看 php 文件没有扩展名。如下是我的ngin
Scott Meyer 关于非成员函数增加封装并允许更优雅的设计(设计方面)的论点对我来说似乎非常有效。看这里:Article 但是我对此有疑问。 (似乎还有其他人,尤其是库开发人员,他们通常完全忽略
在对类设计的一些事实感到困惑时,特别是函数是否应该是成员,我查看了 Effective c++ 并找到了第 23 条,即 Prefer non-member non-friend functions
我正在尝试使用 firebase 云功能将通知发送到一个点半径的圆内的设备。我能够获取圈内设备的 ID,但无法获取 token ,使用 console.log(token) 打印时 token 为空。
我在我的项目中使用 React-ckeditor 5 包。我得到一个反序列化的 html 数据,我正在使用 React-html-parser 包将它解析成 html 模板,并将这个解析的数据传递给
我是一名优秀的程序员,十分优秀!