Python使用socket实现组播与发送二进制数据

 更新时间:2021年06月16日 15:54:05   作者:一天一篇Python库  
在工作中经常会用到socket传输数据,例如客户端给服务器发送数据(双方约定了数据格式),本文主要介绍了Python使用socket实现组播与发送二进制数据,感兴趣的可以了解一下

什么是组播

点对点连接可以处理很多通信需求,不过随着直接连接数的增加,在多对通信方之间传递相同的消息会变得越来越困难。

单独地向各个接收方发送消息会耗费额外的处理时间和带宽,这对于诸如完成流视频或音频操作的应用来说,代码会出现显著的性能问题。

而使用组播(multicast)向多个端点同时发送消息可以得到更好的效率,因为网络基础设施可以确保数据包会被传送到所有接收方。

组播消息总是使用UDP发送,因为TCP需要提供一对通信系统。组播的地址被称为组播组,这是常规的IPv4地址范围的一个子集(224.0.0.0~230.255.255.255),专门为主播通信预留。

这些地址会由网络路由器和交换机进行特殊的处理,所以发送到组的消息可以在互联网上被分发到加入这个组的所有接收方。

需要注意的是,大多数托管的路由器与交换机默认会禁止组播通信。如果后续运行程序有问题,那么可以检查你的网络设置。

发送组播消息

由于无法知道会收到多少响应,所以需要对套接字使用一个超时值,以避免等待回答时无限阻塞。

TTL(Time-To-Live value)是一个生存时间值,会控制多少网络接收这个数据包。要使用IP_MULTICAST_TTL选项与setsockopt()函数来设置TTL。默认值1表示路由器不会把数据包转发到当前网段之外。TTL最大取值255,应包包装为1个字节。

示例代码如下:

import socket
import struct

# 1.创建一个套接字
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

multicast_group = ('224.3.29.71', 10000)
sock.settimeout(10)

ttl = struct.pack('b', 1)#本博主数据结构与算法第10篇对struct二进制结构体进行介绍
sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, ttl)

try:
    msg = "群发的消息,你不必回".encode('UTF-8')
    sent = sock.sendto(msg, multicast_group)
    while True:
        try:
            data, server = sock.recvfrom(1024)
        except socket.timeout:
            print('time out')
            break
        else:
            print(data, server)
finally:
    sock.close()

这里的代码与UDP类似,除了sock.setsockopt()的调用。

接收组播消息

建立组播接收者的第一步是创建UDP套接字。创建常规的套接字并绑定到一个端口后,可以使用setsockopt()改变IP_ADD_MEMBERSHIP选项,增加安东组播组。

这个选项值是组播地址的一个8字节的打包表示,后面是服务器监听通信流的网络接口,由其IP地址标识。这里,接收者使用INADDR_ANY监听所有接口。

示例代码如下:

import socket
import struct

multicast_group = '224.3.29.71'
server_address = ('', 10000)

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
sock.bind(server_address)

group = socket.inet_aton(multicast_group)
mreq = struct.pack('4sL', group, socket.INADDR_ANY)

sock.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq)

while True:
    data, address = sock.recvfrom(1024)
    print(data.decode('UTF-8'), address)
    sock.sendto('组播消息已经收到'.encode('UTF-8'), address)

接收者的循环与UDP服务器类似。

运行之后,效果如下:

接收者

发送者

到此这篇关于Python使用socket实现组播与发送二进制数据的文章就介绍到这了,更多相关Python 组播与发送二进制数据内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Linux安装Python3如何和系统自带的Python2并存

    Linux安装Python3如何和系统自带的Python2并存

    这篇文章主要介绍了Linux安装Python3如何和系统自带的Python2并存,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-07-07
  • 详解K-means算法在Python中的实现

    详解K-means算法在Python中的实现

    这篇文章主要介绍了详解K-means算法在Python中的实现,具有一定借鉴价值,需要的朋友可以了解下。
    2017-12-12
  • Dlib+OpenCV深度学习人脸识别的方法示例

    Dlib+OpenCV深度学习人脸识别的方法示例

    这篇文章主要介绍了Dlib+OpenCV深度学习人脸识别的方法示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-05-05
  • Python进行数组的排序、倒序、截取方式

    Python进行数组的排序、倒序、截取方式

    这篇文章主要介绍了Python进行数组的排序、倒序、截取方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-02-02
  • numpy.sum()的使用详解

    numpy.sum()的使用详解

    这篇文章主要介绍了numpy.sum()的使用详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2021-03-03
  • python实现用户管理系统

    python实现用户管理系统

    这篇文章主要为大家详细介绍了python实现用户管理系统,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-01-01
  • 对Python强大的可变参数传递机制详解

    对Python强大的可变参数传递机制详解

    今天小编就为大家分享一篇对Python强大的可变参数传递机制详解,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2019-06-06
  • Python爬虫利器之PhantomJS详解

    Python爬虫利器之PhantomJS详解

    这篇文章主要介绍了Python爬虫利器之PhantomJS详解,PhantomJS是一个基于WebKit的无头浏览器,它没有图形界面,但是它可以像传统的浏览器一样访问web页面,并返回已呈现的内容,PhantomJS是一种命令行工具,可以用它来测试和爬取Web页面,需要的朋友可以参考下
    2023-09-09
  • python调用百度语音识别api

    python调用百度语音识别api

    这篇文章主要介绍了python调用百度语音识别api,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-08-08
  • python 爬虫一键爬取 淘宝天猫宝贝页面主图颜色图和详情图的教程

    python 爬虫一键爬取 淘宝天猫宝贝页面主图颜色图和详情图的教程

    今天小编就为大家分享一篇python 爬虫一键爬取 淘宝天猫宝贝页面主图颜色图和详情图的教程,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2018-05-05

最新评论