第十一章：网络通信-socket:网络通信-组播-接收组播消息

11.2.5.2 接收组播消息 建立组播接收者的第一步是创建UDP套接字。创建常规的套接字并绑定到一个端口后，可以使用setsockopt()改变IP_ADD_MEMBERSHIP选项，把它增加到组播组。这个选项值是组播组地址的一个8字节的打包表示，后面是服务器监听通信流的网络接口(由其IP地址标识)。在这里，接收者使用INADDR_ANY监听所有端口。

import socket import struct import sys multicast_group = '224.3.29.71' server_address = ('',10000) # Create the socket. sock = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) # Bind to the server address. sock.bind(server_address) # Tell the operating system to add the socket to # the multicast group on all interfaces. group = socket.inet_aton(multicast_group) mreq = struct.pack('4sL',group,socket.INADDR_ANY) sock.setsockopt( socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq) # Receive/respond loop while True: print('\nwaiting to receive message') data,address = sock.recvfrom(1024) print('received {} bytes from {}'.format( len(data),address)) print(data) print('sending acknowledgement to',address) sock.sendto(b'ack',address)

接收者的主循环与常规UDP回送服务器类似。

11.2.5.3 示例输出 这个例子显示了组播接收者在两个不同的主机上运行。

消息只发送一次，但是会接收到相对发出消息的两个应答，分布来自主机A和主机B。