问题描述

我们通常使用zmq的pub和sub套接字，进行数据的分发，一般的流程是zmq的sub套接字实现订阅，订阅后实现数据接收，数据从pub发到sub，那么如果我订阅了，但是不采用数据的接收，我们的数据包是否会到达sub端的网卡？

验证方案

验证代码

pub端

import zmq
import  time

context = zmq.Context()
url = "tcp://115.156.162.123:6555"
socketsub = context.socket(zmq.PUB)
socketsub.bind(url)


while True:
    time.sleep(0.001)

    socketsub.send(b'hello')
    print('send okay la ')

sub端

import zmq


context = zmq.Context()
url = "tcp://115.156.162.123:6555"
socketsub = context.socket(zmq.SUB)
socketsub.connect(url)
socketsub.setsockopt(zmq.SUBSCRIBE,''.encode('utf-8'))


while True:

    response = socketsub.recv()
    print('we have get one')

实验过程

sub端启用数据的接收，查看网卡的流量情况

zmq不启用数据接收,查看网卡流量情况

代码:

import zmq


context = zmq.Context()
url = "tcp://115.156.162.123:6555"
socketsub = context.socket(zmq.SUB)
socketsub.connect(url)
socketsub.setsockopt(zmq.SUBSCRIBE,''.encode('utf-8'))


while True:

    # response = socketsub.recv()
    print('we have get one')

网卡流量情况:

（仔细观察上图， 对于send 部分，其也是降低了，说明，对于每一个到达的数据我没有进行ack的确认包了，由于我发送的数据就一个字节，所以整体看来跟这个ack的确认包的长度差别不大）

结论

根据zmq的内核架构:
(工作流程参考另一篇blog:https://blog.csdn.net/weixin_42066185/article/details/107222128)

我们实现了订阅,由于订阅筛选是发生在数据的发出端的,因此,即使我们接手册不进行数据的接收,实际上,该数据包也会到达网卡.

最后

以上就是魁梧果汁为你收集整理的zmq的sub套接字订阅后，数据是否到达网卡？问题描述验证方案结论的全部内容，希望文章能够帮你解决zmq的sub套接字订阅后，数据是否到达网卡？问题描述验证方案结论所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。