首页 文章

Raspberry Pi不接收多播数据包

提问于
浏览
1

我对python编程和Linux / raspian一般都很陌生,在过去的几周里,我已经遇到了一个绝对的问题 . 我一直在努力坚持下去,但在过去的几个晚上,直到凌晨1点试图让它上班,我认为是时候寻求帮助了 .

所以我有一个覆盆子pi,我已经设置接收来自猫头鹰直觉(电力和光伏监视器)的数据,它通过224.192.32.19和端口22600上的多播发送数据 .

我正在使用iptables和fail2ban,但我有一个规则设置允许所有多播流量和源IP地址不在fail2ban列表中 .

iptables规则如下:

target prot opt in out source destination ACCEPT all - 任何地方的任何地方PKTTYPE =多播

我正在使用一些非常基本的python脚本来尝试接收数据报,但无济于事 .

我尝试过那些相同的脚本试图从239.255.255.250:1900接收数据报,它工作正常 .

我也在Windows机器上尝试了“mcsend 224.192.32.19 22600”,它可以使用“rtpqual 224.192.32.19 22600”接收数据但是raspi仍然不能 .
奇怪的是,当我运行“netstat -g”时,我得到以下内容,即使我目前没有运行任何听众......
编辑:原来我在工作中的控制台窗口中运行了一个脚本 . 尽管如此,它没有收到任何东西 .

IPv6 / IPv4组成员资格接口RefCnt组lo 1 all-systems.mcast.net eth0 1 224.192.32.19 eth0 1 all-systems.mcast.net

另外,如果我运行“ifconfig eth0”,我会得到:

eth0链接封装:以太网HWaddr b8:27:eb:4c:46:71 inet addr:192.168.0.20 Bcast:192.168.0.255掩码:255.255.255.0 UP BROADCAST RUNNING MULTICAST MTU:1500公制:1 RX包:27645错误: 0丢弃:0溢出:0帧:0 TX数据包:11846错误:0丢弃:0溢出:0载波:0冲突:0 txqueuelen:1000 RX字节:1701082(1.6 MiB)TX字节:2027974(1.9 MiB)

所以我认为我可以放心地假设pi上支持/启用了多播 .

py脚本如下(默认IP地址/端口不起作用,'help'中的ip地址/端口确实有效):

from socket import socket, inet_aton, IPPROTO_IP, IP_ADD_MEMBERSHIP
from socket import AF_INET, SOCK_DGRAM, SOL_SOCKET, SO_REUSEADDR, INADDR_ANY
from optparse import OptionParser
import struct

parser = OptionParser()
parser.add_option("-g", "--group", dest="group", default="224.192.32.19", help="IP Multicast Group (default: 239.255.255.250)")
parser.add_option("-p", "--port", dest="port", default=22600, help="IP Multicast UDP port number (default: 1900)")
parser.add_option("-b", "--buffer", dest="buffer", default=1500, help="IP Socket buffer size (default: 1500 bytes)")
options, args = parser.parse_args()

MCAST_GRP   = options.group
MCAST_PORT  = options.port
BUFFER_SIZE = options.buffer

sock = socket(AF_INET, SOCK_DGRAM)
sock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
mreq = struct.pack('=4sl', inet_aton(MCAST_GRP), INADDR_ANY) # pack MCAST_GRP correctly
sock.setsockopt(IPPROTO_IP, IP_ADD_MEMBERSHIP, mreq)         # Request MCAST_GRP

sock.bind((MCAST_GRP, MCAST_PORT))                           # Bind to all intfs

while True:
    data, srv_sock = sock.recvfrom(BUFFER_SIZE)              # Receive data (blocking)
    srv_addr, srv_srcport = srv_sock[0], srv_sock[1]
    print "%s sent: %s" % (srv_addr, data)

我无法弄清楚问题是否存在

感谢您对此问题的任何帮助,它真的很有帮助 .

罗素 .

1 回答

相关问题