我目前正在使用 Ruby 1.8.7 开发 Windows 工具的 Linux 版本,该工具根据用户配置的多播组和端口检查最多 2 个接口上的多播数据。
我有一个以前的问题,我不确定如何收听多个多播频道,但这已从上一个问题中解决。
这导致了下一个问题。我需要收听多个多播组,并且:
确定每个特定组是否收到任何数据,并报告哪些有数据,哪些没有
同时在所有通道上侦听用户可配置超时期限的数据
我试图让它在一个单独的代码中工作,其中多播组、端口和接口都是硬编码的,一旦我把它整理并理解了,我会将它迁移到我的主程序中,用户输入和验证已经完成. 我已经更新了我的简单程序代码,现在它看起来像:
#!/usr/bin/ruby
require 'socket'
require 'ipaddr'
require 'timeout'
MCAST_GROUP_A
{
:addr1 => '233.54.12.111',
:addr2 => '233.86.230.111',
:port => 26477,
:bindaddr => '172.31.230.156'
}
MCAST_GROUP_B =
{
:addr => '233.54.12.111',
:port => 18170,
:bindaddr => '172.31.230.156'
}
ipA1 = IPAddr.new(MCAST_GROUP_A[:addr1]).hton + IPAddr.new(MCAST_GROUP_A[:bindaddr]).hton
ipA2 = IPAddr.new(MCAST_GROUP_A[:addr2]).hton + IPAddr.new(MCAST_GROUP_A[:bindaddr]).hton
ipB = IPAddr.new(MCAST_GROUP_B[:addr]).hton + IPAddr.new(MCAST_GROUP_B[:bindaddr]).hton
begin
sockA = UDPSocket.open
sockB = UDPSocket.open
sockA.bind Socket::INADDR_ANY, MCAST_GROUP_A[:port]
sockB.bind Socket::INADDR_ANY, MCAST_GROUP_B[:port]
sockA.setsockopt Socket::IPPROTO_IP, Socket::IP_ADD_MEMBERSHIP, ipA1
sockA.setsockopt Socket::IPPROTO_IP, Socket::IP_ADD_MEMBERSHIP, ipA2
sockB.setsockopt Socket::IPPROTO_IP, Socket::IP_ADD_MEMBERSHIP, ipB
timeoutSeconds = 10
Timeout.timeout(timeoutSeconds) do
msg1, info1 = sockA.recvfrom(1024)
msg2, info2 = sockB.recvfrom(1024)
#puts "MSG: #{msg} from #{info[2]} (#{info[3]})/#{info[1]} len #{msg.size}"
puts "MSG: <garbled> from #{info1[2]} (#{info1[3]})/#{info1[1]} len #{msg1.size}"
puts "MSG: <garbled> from #{info2[2]} (#{info2[3]})/#{info2[1]} len #{msg2.size}"
end
rescue Timeout::Error
puts "Nothing received connection timedout\n"
ensure
sockA.close
sockB.close
end
但这产生了问题,因为 B 套接字上的数据不存在,因此它报告没有收到任何内容。
我理解这样做的原因是第二个 recvfrom 超时,因此我们最终进入了代码的救援部分。但由于这是我的第一个 Ruby 程序,而且我仍在学习它,所以我不确定如何解决它。
简而言之,我需要了解:
如何确定在 sockA 上接收到哪个通道数据,因为该套接字上有 2 个多播组
如何同时监控可配置数量的多播组的数据,并且没有一个接收数据失败导致输出不正确的错误