如何解决pynng Sub / Pub套接字在低负载下的高延迟
我正在使用Nanomsg NNG测试pynng PUB / SUB套接字性能。
在下面的测试程序中,SUB套接字用作服务器来接收消息,而PUB套接字用作客户端来接收消息。消息的内容是PUB客户端发送消息的简单时间。 SUB服务器通过比较接收消息的时间和消息内部的时间(消息发送时间)来测量延迟。
对于大约1秒钟内发送的1,000条消息,我从性能测试中发现了两个问题:
-
PUB和SUB套接字之间的延迟非常高,几毫秒。但是,在如此低的负载下,我希望延迟为微秒级。
-
如果我使PUB客户端在非常短的时间内睡眠,则延迟性能会提高。我知道睡觉会减少负担。但是我希望在低负载的情况下不会有太大的区别。令我惊讶的是,如果没有睡眠,延迟会高达100毫秒。
我不确定此问题是否与python GIL有关。我的主PUB客户端线程会在不睡觉的情况下与NNG内部I / O线程竞争GIL吗?
任何想法都会受到欢迎和赞赏。
测试程序如下:
def run_nng_sub():
import numpy as np
import time,pickle,datetime,threading
from pynng import Sub0,Timeout
address = 'tcp://127.0.0.1:31313'
latencies = []
with Sub0(listen=address,recv_timeout=100) as sub:
sub.subscribe(b'')
time.sleep(0.05)
while True:
try:
b_datetime = sub.recv()
received_time = datetime.datetime.utcnow()
sent_time = pickle.loads(b_datetime)
latency = received_time - sent_time
latencies.append(latency)
print(f'latency: {latency}')
except Timeout:
if len(latencies) > 1000:
break
print(f'latency:\nmax {np.max(latencies)}\naverage {np.mean(latencies)}\nmedian {np.median(latencies)}')
def run_nng_pub():
import time,datetime
from pynng import Pub0
address = 'tcp://127.0.0.1:31313'
with Pub0(dial=address) as pub:
time.sleep(0.05)
for i in range(1000):
pub.send(pickle.dumps(datetime.datetime.utcnow()))
# time.sleep(1e-5)
我的PC上的性能结果如下:
No sleep
latency:
max 0:00:00.165002
average 0:00:00.025910
median 0:00:00.007000
time.sleep(1e-3)
latency:
max 0:00:00.045002
average 0:00:00.002442
median 0:00:00
time.sleep(1e-4)
latency:
max 0:00:00.051001
average 0:00:00.006631
median 0:00:00.001998
time.sleep(1e-5)
latency:
max 0:00:00.046003
average 0:00:00.008652
median 0:00:00.004000
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。