|
|
@@
-1,134
+1,132
|
|
|
1
|
1
|
# Server program
No newline at end of file
|
|
|
2
|
2
|
# UDP VERSION
No newline at end of file
|
|
|
3
|
3
|
No newline at end of file
|
|
|
4
|
4
|
No newline at end of file
|
|
|
5
|
5
|
import socket
No newline at end of file
|
|
|
6
|
6
|
No newline at end of file
|
|
|
7
|
7
|
class Server:
No newline at end of file
|
|
|
8
|
8
|
No newline at end of file
|
|
|
9
|
9
|
# Set the socket parameters
No newline at end of file
|
|
|
10
|
10
|
#host = "localhost"
No newline at end of file
|
|
|
11
|
11
|
host = '192.168.1.255'
No newline at end of file
|
|
|
12
|
12
|
port = 5500
No newline at end of file
|
|
|
13
|
13
|
buf = 1024
No newline at end of file
|
|
|
14
|
14
|
addr = (host,port)
No newline at end of file
|
|
|
15
|
15
|
No newline at end of file
|
|
|
16
|
16
|
def __init__(self):
No newline at end of file
|
|
|
17
|
17
|
No newline at end of file
|
|
|
18
|
18
|
self.createObjects()
No newline at end of file
|
|
|
19
|
19
|
No newline at end of file
|
|
|
20
|
20
|
def createObjects(self):
No newline at end of file
|
|
|
21
|
21
|
No newline at end of file
|
|
|
22
|
22
|
# Create socket and bind to address
No newline at end of file
|
|
|
23
|
23
|
self.sock_s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
No newline at end of file
|
|
|
24
|
24
|
self.sock_s.bind(self.addr)
No newline at end of file
|
|
|
25
|
25
|
No newline at end of file
|
|
|
26
|
26
|
def listen(self):
No newline at end of file
|
|
|
27
|
27
|
No newline at end of file
|
|
|
28
|
28
|
# Receive messages
No newline at end of file
|
|
|
29
|
29
|
print "Server initialized ..."
No newline at end of file
|
|
|
30
|
30
|
print
No newline at end of file
|
|
|
31
|
31
|
while 1:
No newline at end of file
|
|
|
32
|
32
|
data_rx, addr_rx = self.sock_s.recvfrom(self.buf)
No newline at end of file
|
|
|
33
|
33
|
if not data_rx:
No newline at end of file
|
|
|
34
|
34
|
print "Client has exited!"
No newline at end of file
|
|
|
35
|
35
|
break
No newline at end of file
|
|
|
36
|
36
|
No newline at end of file
|
|
|
37
|
37
|
print "\nSERVER:"
No newline at end of file
|
|
|
38
|
38
|
print "Received message '", data_rx,"'"
No newline at end of file
|
|
|
39
|
39
|
print "Sendinf ack ..."
No newline at end of file
|
|
|
40
|
40
|
self.sock_s.sendto('ack', addr_rx)
No newline at end of file
|
|
|
41
|
41
|
No newline at end of file
|
|
|
42
|
42
|
# Close socket
No newline at end of file
|
|
|
43
|
43
|
self.sock_s.close()
No newline at end of file
|
|
|
44
|
44
|
No newline at end of file
|
|
|
45
|
45
|
def start(self):
No newline at end of file
|
|
|
46
|
46
|
No newline at end of file
|
|
|
47
|
47
|
self.listen()
No newline at end of file
|
|
|
48
|
48
|
No newline at end of file
|
|
|
49
|
49
|
class Client:
No newline at end of file
|
|
|
50
|
50
|
No newline at end of file
|
|
|
51
|
51
|
No newline at end of file
|
|
|
52
|
52
|
# Set the socket parameters
No newline at end of file
|
|
|
53
|
53
|
#host = '0.0.0.0'
No newline at end of file
|
|
|
54
|
54
|
host = '192.168.1.255'
No newline at end of file
|
|
|
55
|
55
|
#port = 5140
No newline at end of file
|
|
|
56
|
56
|
port = 5500
No newline at end of file
|
|
|
57
|
57
|
#port = 7000
No newline at end of file
|
|
|
58
|
58
|
buf = 1024
No newline at end of file
|
|
|
59
|
59
|
multicast_addr = (host,port)
No newline at end of file
|
|
|
60
|
60
|
No newline at end of file
|
|
|
61
|
61
|
def __init__(self):
No newline at end of file
|
|
|
62
|
62
|
No newline at end of file
|
|
|
63
|
63
|
self.createObjects()
No newline at end of file
|
|
|
64
|
64
|
No newline at end of file
|
|
|
65
|
65
|
def createObjects(self):
No newline at end of file
|
|
|
66
|
66
|
No newline at end of file
|
|
|
67
|
67
|
# Create socket
No newline at end of file
|
|
|
68
|
68
|
#self.socket_c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
No newline at end of file
|
|
|
69
|
69
|
self.socket_c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM,0)
|
|
|
|
70
|
No newline at end of file
|
|
|
70
|
|
#self.socket_c.settimeout(0.2)
|
|
|
|
|
No newline at end of file
|
|
|
71
|
|
#if self.socket_c == -1:
|
|
|
|
|
No newline at end of file
|
|
|
72
|
|
# print "No se pudo establecer conexion con el socket"
No newline at end of file
|
|
|
73
|
71
|
|
|
|
|
72
|
No newline at end of file
|
|
|
74
|
|
#self.socket_c.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, 20)
No newline at end of file
|
|
|
75
|
73
|
self.socket_c.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
No newline at end of file
|
|
|
76
|
74
|
No newline at end of file
|
|
|
77
|
75
|
No newline at end of file
|
|
|
78
|
76
|
def sendData(self):
No newline at end of file
|
|
|
79
|
77
|
No newline at end of file
|
|
|
80
|
78
|
def_msg = "===Enter message to send to server===";
No newline at end of file
|
|
|
81
|
79
|
print "\n", def_msg
No newline at end of file
|
|
|
82
|
80
|
print
No newline at end of file
|
|
|
83
|
81
|
No newline at end of file
|
|
|
84
|
82
|
# Send messages
No newline at end of file
|
|
|
85
|
83
|
while (1):
No newline at end of file
|
|
|
86
|
84
|
print "\nCLIENT"
No newline at end of file
|
|
|
87
|
85
|
data = raw_input('>> ')
No newline at end of file
|
|
|
88
|
86
|
if not data or data == 'q':
No newline at end of file
|
|
|
89
|
87
|
break
No newline at end of file
|
|
|
90
|
88
|
No newline at end of file
|
|
|
91
|
89
|
if(self.socket_c.sendto(data, self.multicast_addr)):
No newline at end of file
|
|
|
92
|
90
|
No newline at end of file
|
|
|
93
|
91
|
print "Sending message '",data,"'....."
No newline at end of file
|
|
|
94
|
92
|
No newline at end of file
|
|
|
95
|
93
|
data_rx, server_rx = self.socket_c.recvfrom(16)
No newline at end of file
|
|
|
96
|
94
|
No newline at end of file
|
|
|
97
|
95
|
print "Data received ", data_rx, server_rx
No newline at end of file
|
|
|
98
|
96
|
No newline at end of file
|
|
|
99
|
97
|
# Close socket
No newline at end of file
|
|
|
100
|
98
|
self.socket_c.close()
No newline at end of file
|
|
|
101
|
99
|
No newline at end of file
|
|
|
102
|
100
|
def start(self):
No newline at end of file
|
|
|
103
|
101
|
No newline at end of file
|
|
|
104
|
102
|
self.sendData()
No newline at end of file
|
|
|
105
|
103
|
No newline at end of file
|
|
|
106
|
104
|
import threading
No newline at end of file
|
|
|
107
|
105
|
No newline at end of file
|
|
|
108
|
106
|
class MiThread(threading.Thread):
No newline at end of file
|
|
|
109
|
107
|
def __init__(self, obj):
No newline at end of file
|
|
|
110
|
108
|
No newline at end of file
|
|
|
111
|
109
|
threading.Thread.__init__(self)
No newline at end of file
|
|
|
112
|
110
|
self.obj = obj
No newline at end of file
|
|
|
113
|
111
|
No newline at end of file
|
|
|
114
|
112
|
def run(self):
No newline at end of file
|
|
|
115
|
113
|
No newline at end of file
|
|
|
116
|
114
|
self.obj.start()
No newline at end of file
|
|
|
117
|
115
|
No newline at end of file
|
|
|
118
|
116
|
No newline at end of file
|
|
|
119
|
117
|
if __name__ == '__main__':
No newline at end of file
|
|
|
120
|
118
|
No newline at end of file
|
|
|
121
|
119
|
serverObj = Server()
No newline at end of file
|
|
|
122
|
120
|
clientObj = Client()
No newline at end of file
|
|
|
123
|
121
|
No newline at end of file
|
|
|
124
|
122
|
ts = MiThread(serverObj)
No newline at end of file
|
|
|
125
|
123
|
tc = MiThread(clientObj)
No newline at end of file
|
|
|
126
|
124
|
No newline at end of file
|
|
|
127
|
125
|
ts.start()
No newline at end of file
|
|
|
128
|
126
|
tc.start()
No newline at end of file
|
|
|
129
|
127
|
No newline at end of file
|
|
|
130
|
128
|
tc.join()
No newline at end of file
|
|
|
131
|
129
|
ts.join(60)
No newline at end of file
|
|
|
132
|
130
|
No newline at end of file
|
|
|
133
|
131
|
No newline at end of file
|
|
|
134
|
132
|
No newline at end of file
|
