ASPN ActiveState Programmer Network
ActiveState
/ Home / Perl / PHP / Python / Tcl / XSLT /
/ Safari / My ASPN /
Cookbooks | Documentation | Mailing Lists | Modules | News Feeds | Products | User Groups


Recent Messages
List Archives
About the List
List Leaders
Subscription Options

View Subscriptions
Help

View by Topic
ActiveState
.NET Framework
Open Source
Perl
PHP
Python
Tcl
Web Services
XML & XSLT

View by Category
Database
General
SOAP
System Administration
Tools
User Interfaces
Web Programming
XML Programming


MyASPN >> Mail Archive >> python-list
python-list
Re: multicast
by Seb other posts by this author
Nov 4 2009 6:10PM messages near this date
Re: Python 3 | Re: set pdb break condition based upon number of hits?
Forgot the code... doh! :)

#! /usr/bin/env python

import socket
import time

class MulticastSender(object):
	def __init__(self, MCAST_ADDR = "224.168.2.9", MCAST_PORT = 1600):
		self.MCAST_ADDR = MCAST_ADDR
		self.MCAST_PORT = MCAST_PORT
		ANY = "0.0.0.0"
		SENDERPORT=1501
#create a UDP socket
		self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM,
socket.IPPROTO_UDP)
#allow multiple sockets to use the same PORT number
		self.sock.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
#The sender is bound on (0.0.0.0:1501)
		self.sock.bind((ANY,SENDERPORT))
#Tell the kernel that we want to multicast and that the data is sent
#to everyone (255 is the level of multicasting)
		self.sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL,
255)

	def send(self, data):
		self.sock.sendto(data, (self.MCAST_ADDR, self.MCAST_PORT));

class MulticastReceiver(object):
	def __init__(self, MCAST_ADDR = "224.168.2.9", MCAST_PORT = 1600):
		ANY = "0.0.0.0"
#create a UDP socket
		self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM,
socket.IPPROTO_UDP)
#allow multiple sockets to use the same PORT number
		self.sock.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
#Bind to the port that we know will receive multicast data
		self.sock.bind((ANY,MCAST_PORT))
#tell the kernel that we are a multicast socket
		self.sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL,
255)
#Tell the kernel that we want to add ourselves to a multicast group
#The address for the multicast group is the third param
		status = self.sock.setsockopt(socket.IPPROTO_IP,
socket.IP_ADD_MEMBERSHIP, socket.inet_aton(MCAST_ADDR) +
socket.inet_aton(ANY));
		self.sock.setblocking(0)

	def setblocking(self, flag):
		self.sock.setblocking(flag)

	def recv(self, size = 1024):
		return self.sock.recvfrom(size)

class Multicast(object):
	def __init__(self):
		self.__ms = MulticastSender()
		self.__mr = MulticastReceiver()

	def send(self, data):
		self.__ms.send(data)

	def recv(self, size = 1024):
		return self.__mr.recv()

if __name__ == "__main__":
	mc = Multicast()
	while 1:
		try:
			data, addr = mc.recv()
		except socket.error, e:
			#print "sock.error: ", e
			pass
		else:
			print "FROM: ", addr
			print "DATA: ", data
-- 
http://mail.python.org/mailman/listinfo/python-list

Privacy Policy | Email Opt-out | Feedback | Syndication
© ActiveState Software Inc. All rights reserved