我觉得我错过了这段代码如何工作的主要部分，或者发生了一些非常奇怪的事情。我包含了一个名为“handle”的方法，该方法作为参数传递给 thread.start_new_thread，但似乎未识别/执行此方法。即使在 PythonWin 编辑器中，当您键入“self”时。它通常会预先填充一个可识别的选项列表，并且 handle 没有出现在这个版本中，但是在这个文件的工作版本中它确实出现在编辑器中。

代码如下:

(这里有很多进口)

class AppServerSvc (win32serviceutil.ServiceFramework):
    _svc_name_ = "flaspsrv"
    _svc_display_name_ = "Flash Policy Server"
    _svc_description_ = "Initialize Flash Policy Server"

    def __init__(self,args):
        logging.basicConfig(filename='C:\\Uploads\\testing.log', level=logging.DEBUG, filemode='a', format='%(asctime)s %(levelname)s %(message)s')
        win32serviceutil.ServiceFramework.__init__(self,args)
        self.hWaitStop = win32event.CreateEvent(None,0,0,None)
        socket.setdefaulttimeout(60)

    def SvcStop(self):
        self.ReportServiceStatus(win32service.SERVICE_STOP_PENDING)
        win32event.SetEvent(self.hWaitStop)

    def SvcDoRun(self):
        servicemanager.LogMsg(servicemanager.EVENTLOG_INFORMATION_TYPE,
                              servicemanager.PYS_SERVICE_STARTED,
                              (self._svc_name_,''))
        self.main()

    def main(self):
        try:
            self.sock = socket.socket(socket.AF_INET6, socket.SOCK_STREAM)
        except AttributeError:
            # AttributeError catches Python built without IPv6
            self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        except socket.error:
            # socket.error catches OS with IPv6 disabled
            self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
            logging.info('Listening on port 843')
            self.sock.bind(('localhost', 843))
            self.sock.listen(5)

        try:
            while True:
                thread.start_new_thread(self.handle, self.sock.accept())
        except socket.error, e:
            logging.info('Error accepting connection: %s' % (e[1],))

    def handle(self, conn, addr):
        logging.info('Temp2')
        addrstr = '%s:%s' % (addr[0],addr[1])
        try:
            logging.info('Connection from %s' % (addrstr,))
            with contextlib.closing(conn):
                # It's possible that we won't get the entire request in
                # a single recv, but very unlikely.
                request = conn.recv(1024).strip()
                if request != '<policy-file-request/>\0':
                    logging.info('Unrecognized request from %s: %s' % (addrstr, request))
                    return
                logging.info('Valid request received from %s' % (addrstr,))
                fo = file('flashpolicy.xml', 'rb')
                conn.sendall(fo.read(10001))
                logging.info('Sent policy file to %s' % (addrstr,))
        except socket.error, e:
            logging.info('Error handling connection from %s: %s' % (addrstr, e[1]))
        except Exception, e:
            logging.info('Error handling connection from %s: %s' % (addrstr, e[1]))

if __name__ == '__main__':
    win32serviceutil.HandleCommandLine(AppServerSvc)

最佳答案

换行

thread.start_new_thread(self.handle, self.sock.accept())

到

thread.start_new_thread(self.handle, *self.sock.accept())

来自 socket.accept() 的文档，此套接字方法返回一个元组 (conn, address)，其中您的处理程序接受三个参数(包括对自身的引用)。

thread.start_new_thread的第二个和第三个参数是 args(位置参数)和 kwargs(关键字参数)，它们应该传递给在线程模块中注册的回调。因此，除非您解压缩来自 socket.accept() 的参数，否则您可能会收到一个类型错误。

因此，在作为参数传递给 handle 之前，您需要从 self.socket 中解压返回元组。

关于PYTHON:从同一个类中调用一个方法需要什么？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/20753855/