add: official multicast example
|Deletions are marked like this.||Additions are marked like this.|
|Line 48:||Line 48:|
|= Discussion =||== Discussion ==|
|Line 54:||Line 54:|
|Extending UDP to add synchronization is basically writing TCP on top of it. You may do it, but why bother?
|Line 55:||Line 57:|
The ''official'' example of multicast can be found at /usr/share/doc/python2.3/examples/Demo/sockets/mcast.py (at least on Debian Sarge, after `apt-get install python-examples`). It worked on my machine, but I have yet to try it running on different machines.
Here's simple code to post a note by UDP in Python:
1 import socket 2 3 UDP_IP="127.0.0.1" 4 UDP_PORT=5005 5 MESSAGE="Hello, World!" 6 7 print "UDP target IP:", UDP_IP 8 print "UDP target port:", UDP_PORT 9 print "message:", MESSAGE 10 11 sock = socket.socket( socket.AF_INET, # Internet 12 socket.SOCK_DGRAM ) # UDP 13 sock.sendto( MESSAGE, (UDP_IP, UDP_PORT) )
Here's simple code to receive UDP messages in Python:
* It would seem easy to extend this to a simple means to open a file on the sender side, send datagrams to the receiver side, and write those packets to a file there - I just wonder about synchronisation issues regarding the buffer...Anyone smart care to put something down, say as a simple practical extension of what is already here? (And if you do it pls delete this message) *
Extending UDP to add synchronization is basically writing TCP on top of it. You may do it, but why bother?
The official example of multicast can be found at /usr/share/doc/python2.3/examples/Demo/sockets/mcast.py (at least on Debian Sarge, after apt-get install python-examples). It worked on my machine, but I have yet to try it running on different machines.
I've been googling for some time now, and still have yet to find a working example of Python multicast listening.
(The example below has been updated to work -- Steven Spencer DateTime(2005-04-14T13:19:00Z))
(I've replaced it with one that works. -- Asgeir S. Nilsen DateTime(2005-05-09T19:25:00Z))
(I've corrected the mreq according to the comment below -- Sebastian Setzer DateTime(2006-01-25T14:28:00Z))
1 import socket 2 import struct 3 4 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP) 5 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 6 sock.bind(('', 4242)) 7 # wrong: mreq = struct.pack("sl", socket.inet_aton("22.214.171.124"), socket.INADDR_ANY) 8 mreq = struct.pack("4sl", socket.inet_aton("126.96.36.199"), socket.INADDR_ANY) 9 10 sock.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq) 11 12 while True: 13 print sock.recv(10240)
The mreq packing is based on [http://www.senux.com/linux/network/multicast/ some code that I found,] that does not work. On my computer, at least.
Sending to multicast groups is just fine; Here's some functional text:
(You might want to reconsider the IP_MULTICAST_TTL setting here -- the recommended value for local-network multicasts is < 32, whilst a value > 32 indicates multicasts which should traverse onto the Internet -- Asgeir S. Nilsen)
The above multicasting examples do not work on my computer, but I was able to fix them using code from http://sourceforge.net/projects/pyzeroconf. Try these examples:
1 # UDP multicast examples, Hugo Vincent, 2005-05-14. 2 import socket 3 4 def send(data, port=50000, addr='188.8.131.52'): 5 """send(data[, port[, addr]]) - multicasts a UDP datagram.""" 6 # Create the socket 7 s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 8 # Make the socket multicast-aware, and set TTL. 9 s.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, 20) # Change TTL (=20) to suit 10 # Send the data 11 s.sendto(data, (addr, port)) 12 13 def recv(port=50000, addr="184.108.40.206", buf_size=1024): 14 """recv([port[, addr[,buf_size]]]) - waits for a datagram and returns the data.""" 15 16 # Create the socket 17 s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 18 19 # Set some options to make it multicast-friendly 20 s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 21 try: 22 s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1) 23 except AttributeError: 24 pass # Some systems don't support SO_REUSEPORT 25 s.setsockopt(socket.SOL_IP, socket.IP_MULTICAST_TTL, 20) 26 s.setsockopt(socket.SOL_IP, socket.IP_MULTICAST_LOOP, 1) 27 28 # Bind to the port 29 s.bind(('', port)) 30 31 # Set some more multicast options 32 intf = socket.gethostbyname(socket.gethostname()) 33 s.setsockopt(socket.SOL_IP, socket.IP_MULTICAST_IF, socket.inet_aton(intf)) 34 s.setsockopt(socket.SOL_IP, socket.IP_ADD_MEMBERSHIP, socket.inet_aton(addr) + socket.inet_aton(intf)) 35 36 # Receive the data, then unregister multicast receive membership, then close the port 37 data, sender_addr = s.recvfrom(buf_size) 38 s.setsockopt(socket.SOL_IP, socket.IP_DROP_MEMBERSHIP, socket.inet_aton(addr) + socket.inet_aton('0.0.0.0')) 39 s.close() 40 return data
At this point, I'm beginning to think: "Python multicast simply does not work."
Are you running on Windows 2000/XP (pre-SP2)/Server 2003 with more than one network adapter? If so, the problem is Windows, not Python. The original code works for me on Windows 2000 (1 network adapter), but fails under XP Pro (pre-SP2, 3 adapters though 2 are disabled). Microsoft has a [http://support.microsoft.com/default.aspx?scid=kb;en-us;827536 support page] on the issue. The problem appears to be in the receiver: with both machines running the receiver, the Win2K machine sees packets sent from both machines, while the receiver on XP sees messages sent from the Win2K machine only. This, despite specifying the local IP address of the appropriate adapter in the second part of the mreq structure in the IP_ADD_MEMBERSHIP call. -- VinaySajip
Hm, that's interesting. No, I'm not running on Windows; I'm running on FC3. That said, I hadn't considered the machine as a possible problem. What I'll do is this: I'll run this on my home FC3 computer, and on my home Redhat 9 computer, and see if I can get it to work on one of them. -- LionKimbro DateTime(2005-01-20T02:07:18Z)
The new version still doesn't work for me. I mean, it does work for local traffic: the host talking with itself. But as soon as I get to another link-local computer, and do the same over again, it doesn't work. I've replaced 127.0.0.1 with the actual IP address of the computer, and I've shut down the firewall (service iptables stop). No dice. This is all on my FC3 host, again. -- LionKimbro DateTime(2005-04-14T17:27:42Z)
When implementing multicast, it's important to understand the requirements of [ftp://ftp.rfc-editor.org/in-notes/rfc3376.txt IGMP], especially when working in a switched network. IGMP describes how routers should exchange membership information, but does not describe how layer 2 switches should handle this. Many switches have a feature called IGMP snooping, where the switch snoops for IGMP traffic, thereby gaining knowledge of which switch ports belong to a multicast group. Cheap switches typically either does not handle this or handles it wrongly. -- Asgeir S. Nilsen DateTime(2005-05-09T19:39:00Z)
The first version, I tested side-by-side equivalent C code. The C code worked, the Python code did not. Thus, I ruled out special router, switch, hub issues. However, the second version, I just ran the Python code. I did not test vis-a-vis C code. Sol, I will have to try it vis-a-vis C code, again, to be sure." -- LionKimbro DateTime(2005-05-09T22:56:26Z)
It's too bad we don't have anything as simple as this:
...or something like that.
You could do something like this:
1 class McastSocket(socket.socket): 2 def __init__(self, local_port, reuse=False): 3 socket.socket.__init__(self, socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP) 4 if(reuse): 5 self.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 6 if hasattr(socket, "SO_REUSEPORT"): 7 self.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1) 8 self.bind(('', local_port)) 9 def mcast_add(self, addr, iface): 10 sock.setsockopt( 11 socket.IPPROTO_IP, 12 socket.IP_ADD_MEMBERSHIP, 13 socket.inet_aton(mcast_addr) + socket.inet_aton(mcast_iface))
Then to listen to multicast events locally:
The perl IO::Socket::Multicast class doesn't look much different from this.
I was able to get the above example to work fine on a linux platform, with one small change. I had to put a "4sl" in the pack statement for creating mreq. It seems as if when I didn't have a 4, the pack statement was just using the first octet (somehow dropping the other octets), so I could only create the multi-cast "listener" on a 220.127.116.11 ip. After some debugging, I put the 4 in front of the "s", which forced it to get all 4 octets from the inet_aton, and everything worked fine. Hope this helps.
...Which is exactly what the pack statement is expected to do, according to the manual:
For the "s" format character, the count is interpreted as the size of the string, ... For packing, the string is truncated or padded with null bytes as appropriate to make it fit.