pynng Sub / Pub套接字在低负载下的高延迟

问题描述

在下面的测试程序中，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 (将#修改为@）

publish-subscribe sockets zeromq