个人中心
gpt4 book ai didi

python - 为什么在同一端口上但来自不同组的多播消息会合并在一起？

转载 作者：塔克拉玛干 更新时间：2023-11-02 23:36:30 26 4
gpt4 key购买 nike

<分区>

在 Ubuntu 14.04 服务器上，我有两个进程，每个进程都在同一端口上监听来自不同组的多播消息。我没想到会这样，但每个人都看到了来自他们想要的组和另一个组的流量。

据我所知，这是已知行为(尽管我会称之为问题)。我找到了 this SO question ，它提供了一些用于确定从中接收数据的多播组的技术，但它并没有回答为什么会发生这种情况的问题。我原以为底层系统网络代码会过滤掉我不想接收的多播组上的消息。

虽然我主要使用 C++，但我可以提供一些简单的 Python 代码来演示问题。在一个终端窗口中，我监听多播组 239.1.1.1，端口 12345。在同一台服务器上的另一个终端窗口中，我监听多播组 239.2.2.2，也是端口 12345。在第二台机器上，我在 239.1 上传输一条多播消息。 1.1:12345，以及 239.2.2.2:12345 上的不同消息。

在 svr3 上，发射器:

rcook@svr3:~$ mcast_snd 239.1.1.1 12345 "from 1.1.1"
multicasting from 1.1.1 to 239.1.1.1 port 12345
rcook@svr3:~$ mcast_snd 239.2.2.2 12345 "from 2.2.2"
multicasting from 2.2.2 to 239.2.2.2 port 12345

在 svr2 上，窗口 1，第一个接收者:

rcook@svr2:~$ mcast_rcv 239.1.1.1 12345
listening for multicast data on 239.1.1.1 port 12345
received 10 bytes: from 1.1.1
received 10 bytes: from 2.2.2

在 svr2 上，终端 2，另一个接收器:

rcook@svr2:~$ mcast_rcv 239.2.2.2 12345
listening for multicast data on 239.2.2.2 port 12345
received 10 bytes: from 1.1.1
received 10 bytes: from 2.2.2

如您所见，两个接收者都收到了两条消息。有人可以解释这是为什么吗？如果有更好的方法来配置接收者不接收来自其他组的消息，也请分享。

作为引用，这里是 mcast_rcv 的代码:

#!/usr/bin/python

import socket
import struct
import sys

if len(sys.argv) != 3:
    print 'usage:', sys.argv[0], '<multicast group>', '<multicast port>'
    sys.exit(0)

mcast_group = sys.argv[1]
mcast_port = int(sys.argv[2])

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
sock.bind(('', mcast_port))
mreq = struct.pack('4sl', socket.inet_aton(mcast_group), socket.INADDR_ANY)

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

print 'listening for multicast data on', mcast_group, 'port', mcast_port

while True:
    msg = sock.recv(10240)
    print 'received', len(msg), 'bytes:', msg

这里是 mcast_snd 的代码:

#!/usr/bin/python

import socket
import sys

if len(sys.argv) != 4:
    print 'usage:', sys.argv[0], '<multicast group>', '<multicast port>', '<mess
age>'
    sys.exit(0)

mcast_group = sys.argv[1]
mcast_port = int(sys.argv[2])
message = sys.argv[3]

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, 2)

print 'multicasting', message, 'to', mcast_group, 'port', mcast_port

sock.sendto(message, (mcast_group, mcast_port))

26 4 0
文章推荐： linux - 如何通过 ssh pgrep，或将 pgrep 用作更大的 bash 命令？
文章推荐： c++ - 将 boost 与 Visual Studio 和 vcpkg 链接时出错
文章推荐： c++ - MSVC 无法评估 enable_if 中的 constexpr 函数
文章推荐： c++ - 最小可能的分母/除数是多少？
塔克拉玛干
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com