|
|
# Server program
|
|
|
# UDP VERSION
|
|
|
|
|
|
|
|
|
import socket
|
|
|
|
|
|
class Server:
|
|
|
|
|
|
# Set the socket parameters
|
|
|
#host = "localhost"
|
|
|
host = '192.168.1.255'
|
|
|
port = 5500
|
|
|
buf = 1024
|
|
|
addr = (host,port)
|
|
|
|
|
|
def __init__(self):
|
|
|
|
|
|
self.createObjects()
|
|
|
|
|
|
def createObjects(self):
|
|
|
|
|
|
# Create socket and bind to address
|
|
|
self.sock_s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
|
|
self.sock_s.bind(self.addr)
|
|
|
|
|
|
def listen(self):
|
|
|
|
|
|
# Receive messages
|
|
|
print "Server initialized ..."
|
|
|
print
|
|
|
while 1:
|
|
|
data_rx, addr_rx = self.sock_s.recvfrom(self.buf)
|
|
|
if not data_rx:
|
|
|
print "Client has exited!"
|
|
|
break
|
|
|
|
|
|
print "\nSERVER:"
|
|
|
print "Received message '", data_rx,"'"
|
|
|
print "Sendinf ack ..."
|
|
|
self.sock_s.sendto('ack', addr_rx)
|
|
|
|
|
|
# Close socket
|
|
|
self.sock_s.close()
|
|
|
|
|
|
def start(self):
|
|
|
|
|
|
self.listen()
|
|
|
|
|
|
class Client:
|
|
|
|
|
|
|
|
|
# Set the socket parameters
|
|
|
#host = '0.0.0.0'
|
|
|
host = '192.168.1.255'
|
|
|
#port = 5140
|
|
|
port = 5500
|
|
|
#port = 7000
|
|
|
buf = 1024
|
|
|
multicast_addr = (host,port)
|
|
|
|
|
|
def __init__(self):
|
|
|
|
|
|
self.createObjects()
|
|
|
|
|
|
def createObjects(self):
|
|
|
|
|
|
# Create socket
|
|
|
#self.socket_c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
|
|
self.socket_c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM,0)
|
|
|
self.socket_c.settimeout(0.2)
|
|
|
|
|
|
# self.socket_c.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, 20)
|
|
|
self.socket_c.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
|
|
|
|
|
|
|
|
|
def sendData(self):
|
|
|
|
|
|
def_msg = "===Enter message to send to server===";
|
|
|
print "\n", def_msg
|
|
|
print
|
|
|
|
|
|
# Send messages
|
|
|
while (1):
|
|
|
print "\nCLIENT"
|
|
|
data = raw_input('>> ')
|
|
|
if not data or data == 'q':
|
|
|
break
|
|
|
|
|
|
if(self.socket_c.sendto(data, self.multicast_addr)):
|
|
|
|
|
|
print "Sending message '",data,"'....."
|
|
|
|
|
|
data_rx, server_rx = self.socket_c.recvfrom(16)
|
|
|
|
|
|
print "Data received ", data_rx, server_rx
|
|
|
|
|
|
# Close socket
|
|
|
self.socket_c.close()
|
|
|
|
|
|
def start(self):
|
|
|
|
|
|
self.sendData()
|
|
|
|
|
|
import threading
|
|
|
|
|
|
class MiThread(threading.Thread):
|
|
|
def __init__(self, obj):
|
|
|
|
|
|
threading.Thread.__init__(self)
|
|
|
self.obj = obj
|
|
|
|
|
|
def run(self):
|
|
|
|
|
|
self.obj.start()
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
|
|
|
serverObj = Server()
|
|
|
clientObj = Client()
|
|
|
|
|
|
ts = MiThread(serverObj)
|
|
|
tc = MiThread(clientObj)
|
|
|
|
|
|
ts.start()
|
|
|
tc.start()
|
|
|
|
|
|
tc.join()
|
|
|
ts.join(60)
|
|
|
|
|
|
|
|
|
|
