我在 Linux 上撰写一个程序, 以同时在 UDP 插座上控制大约 1000 个病人监视器。 我已成功撰写了一个图书馆, 用来分析并发送信息, 从单一的病人监视器设备中收集数据 。 该设备有各种排程限制, 如下表所示:
- Each device must constantly get an alive-request from computer client within max time-period of 300 milliseconds(may differ for different devices), otherwise connection is lost.
- Computer client must send a poll-request to a device in order fetch the data within some time period. I m polling for about 5 seconds of averaged data from patient monitor, therefore, I m required to send poll-request in every 5 * 3 = 15 seconds. If I fail to send the request within 15 seconds time-frame, I looses the connection from device.
现在,我试图扩展我的当前程序, 以便它能够同时处理大约1000+设备。 现在, 我的程序可以高效地处理和分析一个设备的反应。 在处理多个设备时, 有必要同步不同设备中的多个响应, 并按顺序排列它们, 并将其传送到 TCP 套接字中, 这样远程计算机也可以分析数据 。 这不是一个问题, 因为它是一个非常熟悉的多个制作者和单一的消费者问题。 我的主要关注是, 我该用什么方法来维持1000+设备的生命连接 。
在通过互联网阅读和浏览该网站上的类似问题之后,我主要考虑两个备选方案:
- Use one thread per device. In order to control 1000+ device, I would end up in making 1000+ threads which does not look feasible to me.
- Use multiplexing approach, selecting FD that requires attention and deal with it one at a time. I m not sure how would I go about it and if multiplexing approach would be able to maintain alive-connection with all the devices considering above two constants.
我需要一些建议与建议, 如何应对这种情况, 您需要控制 UDP 插座上1000+实时设备。 每个设备每300毫秒需要一些活信号( 不同装置的不同), 并且需要大约比联系阶段提到的间隔时间多3倍的民意调查请求。 例如, ICU 的病人监测员可能需要实时数据( 平均为1秒), 普通病房的病人监测员可能需要10秒的平均数据, 因此, 两个设备的民意调查时间分别为3*1秒( 3秒)和3*10秒( 30秒)。
Thanks Shivam Kalra