[python] Python에서 UDP 멀티 캐스트는 어떻게합니까?

다른 답변의 코드에서 미묘한 점을 설명하는 또 다른 답변입니다.

• socket.INADDR_ANY-(편집 됨)의 컨텍스트 IP_ADD_MEMBERSHIP에서 이것은 실제로 소켓을 모든 인터페이스에 바인딩하지 않고 멀티 캐스트가 작동하는 기본 인터페이스를 선택합니다 (라우팅 테이블에 따라).
• 멀티 캐스트 그룹에 참여하는 것은 소켓을 로컬 인터페이스 주소에 바인딩하는 것과 다릅니다.

멀티 캐스트 (UDP) 소켓을 바인드한다는 것은 무엇을 의미합니까?를 참조하십시오 . 멀티 캐스트 작동 방식에 대한 자세한 내용

멀티 캐스트 수신기 :

import socket
import struct
import argparse


def run(groups, port, iface=None, bind_group=None):
    # generally speaking you want to bind to one of the groups you joined in
    # this script,
    # but it is also possible to bind to group which is added by some other
    # programs (like another python program instance of this)

    # assert bind_group in groups + [None], \
    #     'bind group not in groups to join'
    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)

    # allow reuse of socket (to allow another instance of python running this
    # script binding to the same ip/port)
    sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

    sock.bind(('' if bind_group is None else bind_group, port))
    for group in groups:
        mreq = struct.pack(
            '4sl' if iface is None else '4s4s',
            socket.inet_aton(group),
            socket.INADDR_ANY if iface is None else socket.inet_aton(iface))

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

    while True:
        print(sock.recv(10240))


if __name__ == '__main__':
    parser = argparse.ArgumentParser()
    parser.add_argument('--port', type=int, default=19900)
    parser.add_argument('--join-mcast-groups', default=[], nargs='*',
                        help='multicast groups (ip addrs) to listen to join')
    parser.add_argument(
        '--iface', default=None,
        help='local interface to use for listening to multicast data; '
        'if unspecified, any interface would be chosen')
    parser.add_argument(
        '--bind-group', default=None,
        help='multicast groups (ip addrs) to bind to for the udp socket; '
        'should be one of the multicast groups joined globally '
        '(not necessarily joined in this python program) '
        'in the interface specified by --iface. '
        'If unspecified, bind to 0.0.0.0 '
        '(all addresses (all multicast addresses) of that interface)')
    args = parser.parse_args()
    run(args.join_mcast_groups, args.port, args.iface, args.bind_group)

샘플 사용 : (아래 두 개의 콘솔에서 실행하고 자신의 –iface를 선택하십시오 (멀티 캐스트 데이터를 수신하는 인터페이스와 동일해야 함))

python3 multicast_recv.py --iface='192.168.56.102' --join-mcast-groups '224.1.1.1' '224.1.1.2' '224.1.1.3' --bind-group '224.1.1.2'

python3 multicast_recv.py --iface='192.168.56.102' --join-mcast-groups '224.1.1.4'

멀티 캐스트 발신자 :

import socket
import argparse


def run(group, port):
    MULTICAST_TTL = 20
    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
    sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, MULTICAST_TTL)
    sock.sendto(b'from multicast_send.py: ' +
                f'group: {group}, port: {port}'.encode(), (group, port))


if __name__ == '__main__':
    parser = argparse.ArgumentParser()
    parser.add_argument('--mcast-group', default='224.1.1.1')
    parser.add_argument('--port', default=19900)
    args = parser.parse_args()
    run(args.mcast_group, args.port)

샘플 사용 : # 수신자가 아래 멀티 캐스트 그룹 주소에 바인딩하고 일부 프로그램이 해당 그룹에 참여하도록 요청한다고 가정합니다. 케이스를 단순화하기 위해 수신자와 발신자가 동일한 서브넷에 있다고 가정합니다.

python3 multicast_send.py --mcast-group '224.1.1.2'

python3 multicast_send.py --mcast-group '224.1.1.4'