1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
#!/usr/bin/python
"""
__version__ = "$Revision: 1.6 $"
__date__ = "$Date: 2004/05/05 16:53:25 $"
"""
from PythonCard import model
import threading
import Queue
import wx
# EchoServer derived
# from echo server example in Programming Python by Mark Lutz
# get socket constructor and constants
import socket
# server machine, '' means local host
myHost = ''
# listen on a non-reserved port number
myPort = 50007
class EchoServer:
def __init__(self, parent):
self._parent = parent
self.keepRunning = 1
def server(self):
# make a TCP socket object
sockobj = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# bind it to server port number
sockobj.bind((myHost, myPort))
# listen, allow 5 pending connects
sockobj.listen(5)
# listen until process killed
while self.keepRunning:
#print 'outer loop'
connection, address = sockobj.accept() # wait for next client connect
#print 'Server connected by', address # connection is a new socket
while self.keepRunning:
#print 'inner loop'
# read next line on client socket
data = connection.recv(1024)
if not data: break
self._parent.msgQueue.put(data)
wx.WakeUpIdle()
connection.close()
# The same port as used by the server
PORT = myPort
def echoSend(host, port, txt):
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((host, port))
s.send(txt)
s.close()
class Chat(model.Background):
def on_initialize(self, event):
self.msgQueue = Queue.Queue()
self.components.fldYourIPAddress.text = socket.gethostbyname(socket.gethostname())
self.echoServer = EchoServer(self)
self.thread = threading.Thread(target = self.echoServer.server)
# I think this allows Python to kill the thread when we quit wxPython
# setDaemon must be called before start
self.thread.setDaemon(1)
self.thread.start()
def on_idle(self, event):
if not self.msgQueue.empty():
msg = self.msgQueue.get()
self.doDisplayMsgReceived(msg)
event.RequestMore()
def doDisplayMsgReceived(self, data):
if data is not None:
self.components.fldTranscript.appendText(data + '\n')
else:
pass
def on_btnSend_mouseClick(self, event):
#print "btnSend", self.components.fldSendAddresses.text, PORT, self.components.fldInput.text
txt = self.components.fldNickname.text + \
" (" + self.components.fldYourIPAddress.text + "): " + \
self.components.fldInput.text
addresses = self.components.fldSendAddresses.text.split(',')
#print addresses
for ip in addresses:
echoSend(ip.strip(), PORT, txt)
self.components.fldTranscript.appendText(txt + '\n')
self.components.fldInput.text = ""
#print "after send"
def on_close(self, event):
self.echoServer.keepRunning = 0
event.skip()
if __name__ == '__main__':
app = model.Application(Chat)
app.MainLoop()
|
