在wxpython中使用套接字

Question

我有一个TCP服务器和一个TCP客户端。
我想用wxpython做一个图形界面的版本，基于下面的代码。
我已经准备好了图形界面的脚本，但在把这两个脚本合并时遇到了问题。

我该如何把我的socket脚本和图形界面合并在一起呢？

我的socket服务器

from socket import *
from time import ctime
import random

bufsiz = 1024
port = random.randint(1025,36000)
host = 'localhost'
addr = (host, port)
print 'Port:',port

tcpServer = socket(AF_INET , SOCK_STREAM)
tcpServer.bind(addr)
tcpServer.listen(5)
try:
    while True:
        print 'Waiting for connection..'
        tcpClient, caddr = tcpServer.accept()
        print 'Connected To',caddr

        while True:
            data = tcpClient.recv(bufsiz)
            if not data:
                break
            tcpClient.send('[%s]\nData\n%s' % (ctime(),data))
            print data
        tcpClient.close()

except KeyboardInterrupt:
    tcpServer.close()

raw_input('Enter to Quit')

我的图形界面脚本（使用wxglade制作）

#!/usr/bin/env python
# -*- coding: iso-8859-15 -*-
# generated by wxGlade 0.6.5 (standalone edition) on Mon Feb 18 19:50:59 2013

import wx

# begin wxGlade: extracode
# end wxGlade


class MyFrame(wx.Frame):
    def __init__(self, *args, **kwds):
        # begin wxGlade: MyFrame.__init__
        kwds["style"] = wx.DEFAULT_FRAME_STYLE
        wx.Frame.__init__(self, *args, **kwds)
        self.chat_log = wx.TextCtrl(self, -1, "", style=wx.TE_MULTILINE | wx.TE_READONLY)
        self.text_send = wx.TextCtrl(self, -1, "")

        self.__set_properties()
        self.__do_layout()

        self.Bind(wx.EVT_TEXT_ENTER, self.text_e, self.text_send)
        # end wxGlade

    def __set_properties(self):
        # begin wxGlade: MyFrame.__set_properties
        self.SetTitle("frame_1")
        self.SetSize((653, 467))
        self.chat_log.SetMinSize((635, 400))
        self.text_send.SetMinSize((635, -1))
        self.text_send.SetFocus()
        # end wxGlade

    def __do_layout(self):
        # begin wxGlade: MyFrame.__do_layout
        sizer_1 = wx.FlexGridSizer(1, 1, 1, 1)
        sizer_1.Add(self.chat_log, 0, 0, 0)
        sizer_1.Add(self.text_send, 0, wx.ALL, 1)
        self.SetSizer(sizer_1)
        self.Layout()
        # end wxGlade

    def text_e(self, event):  # wxGlade: MyFrame.<event_handler>
        text = self.text_send.GetValue()
        self.chat_log.AppendText("\n"+text)
        self.text_send.SetValue("")
        event.Skip()

# end of class MyFrame

class MyMenuBar(wx.MenuBar):
    def __init__(self, *args, **kwds):
        # begin wxGlade: MyMenuBar.__init__
        wx.MenuBar.__init__(self, *args, **kwds)
        self.File = wx.Menu()
        self.Append(self.File, "File")
        self.View = wx.Menu()
        self.Append(self.View, "View")

        self.__set_properties()
        self.__do_layout()
        # end wxGlade

    def __set_properties(self):
        # begin wxGlade: MyMenuBar.__set_properties
        pass
        # end wxGlade

    def __do_layout(self):
        # begin wxGlade: MyMenuBar.__do_layout
        pass
        # end wxGlade

# end of class MyMenuBar
if __name__ == "__main__":
    app = wx.PySimpleApp(0)
    wx.InitAllImageHandlers()
    frame_1 = MyFrame(None, -1, "")
    app.SetTopWindow(frame_1)
    frame_1.Show()
    app.MainLoop()

Answer 1

简单来说：把你的第一个脚本放进一个函数里。然后把这个函数导入到wxPython应用程序中。在某个事件处理器中调用这个函数。最后，把函数的返回结果传回到图形界面（GUI）。

不过，你需要重新设计你的软件，确保它不会出现无限循环。事件处理器应该只运行很短的时间。另一种方法是把你的函数放在一个单独的线程中运行，这样可以和图形界面进行通信，并且还要能从主图形界面线程中终止这个线程。

大致可以这样做：

import wx
from socket import *
from time import ctime
import random
import threading

bufsiz = 1024
port = random.randint(1025,36000)
host = 'localhost'
addr = (host, port)

class MainWindow(wx.Frame):
    def __init__(self, *args, **kwargs):
        wx.Frame.__init__(self, *args, **kwargs)

        self.panel = wx.Panel(self)
        self.text = wx.TextCtrl(self.panel, style=wx.TE_MULTILINE)

        self.sizer = wx.BoxSizer()
        self.sizer.Add(self.text, 1, wx.ALL | wx.EXPAND, 5)

        self.panel.SetSizerAndFit(self.sizer)  
        self.Show()

        self.thread = threading.Thread(target=self.Server)
        self.thread.start()

    def Print(self, text):
        wx.CallAfter(self.text.AppendText, text + "\n")

    def Server(self):
        self.Print("Port: {}".format(port))

        tcpServer = socket(AF_INET , SOCK_STREAM)
        tcpServer.bind(addr)
        tcpServer.listen(5)
        try:
            while True:
                self.Print("Waiting for connection...")
                tcpClient, caddr = tcpServer.accept()
                self.Print("Connected To {}".format(caddr))

                while True:
                    data = tcpClient.recv(bufsiz)
                    if not data:
                        break
                    tcpClient.send('[%s]\nData\n%s' % (ctime(), data))
                    self.Print(data)
                tcpClient.close()

        except KeyboardInterrupt:
            tcpServer.close()

app = wx.App(False)
win = MainWindow(None)
app.MainLoop()

不过，这样做在退出时并不会终止另一个线程。tcpServer.accept() 是一个阻塞操作。你可能需要查看这个 答案，了解如何以非阻塞的方式连接到套接字。这样你就可以通过某种共享标志轻松终止你的线程。