运行一个pythonsocket服务器，如果远程关闭，则重新开始侦听

Question

我正在努力让python套接字正常工作。在

主要有两个问题：

1）当它侦听客户端连接时，程序会暂停，这是一个问题，因为它正在IRC客户端python解释器上运行，导致IRC客户端在客户端连接之前没有响应。在

2）当客户端断开连接时，必须停止整个脚本，然后再次重新启动，以便让套接字服务器再次侦听。在

我想解决这个问题的方法可能是在一个单独的线程中启动套接字监听，这样IRC客户机可以在等待客户机连接时继续。另外，一旦客户机决定关闭连接，我需要一种重新启动它的方法。在

下面的代码很糟糕，不起作用，但它可能会让您了解我在尝试什么：

__module_name__ = "Forward Module"
__module_version__ = "1.0.0"
__module_description__ = "Forward To Flash Module by Xcom"


# Echo client program
import socket
import sys
import xchat
import thread
import time

HOST = None               # Symbolic name meaning all available interfaces
PORT = 7001              # Arbitrary non-privileged port
s = None
socketIsOpen = False

def openSocket():
    # start server
    print "starting to listen"

    for res in socket.getaddrinfo(HOST, PORT, socket.AF_UNSPEC,
                                  socket.SOCK_STREAM, 0, socket.AI_PASSIVE):
        af, socktype, proto, canonname, sa = res
        try:
            s = socket.socket(af, socktype, proto)
        except socket.error as msg:
            s = None
            continue
        try:
            s.bind(sa)
            s.listen(1)
        except socket.error as msg:
            s.close()
            s = None
            continue
        break
    if s is None:
        print 'could not open socket'
        global socketIsOpen = False
        sys.exit(1)
    conn, addr = s.accept()
    print 'Connected by', addr  
    global socketIsOpen = True

def someone_said(word, word_eol, userdata):
    username = str(word[0])
    message = str(word[1])
    sendMessage = username + " : " + message
    send_to_server(sendMessage)



def send_to_server(message):
    conn.send(message)


def close_connection():
    conn.close()
    print "connection closed"


xchat.hook_print('Channel Message' , someone_said)

def threadMethod(arg) :
    while 1:
        if (not socketIsOpen) :
            openSocket()

try: 
    thread.start_new_thread(threadMethod, args = [])
except:
    print "Error: unable to start thread"

python运行在一个名为HexChat的IRC客户机上，这是xchat导入的来源。在

Answer 1

通常，编写线程套接字服务器的方法是：

• 在循环中调用accept()
• 生成一个新线程来处理新连接

一个非常简单的例子如下：

import socket
import threading
import time

server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(('0.0.0.0', 9999))
server.listen(1)

def handle(conn):
    conn.send(b'hello')
    time.sleep(1)  # do some "heavy" work
    conn.close()

while True:
    print('listening...')
    conn, addr = server.accept()
    print('handling connection from %s' % (addr,))
    threading.Thread(target=handle, args=(conn,)).start()

您正在生成新线程，在其中创建侦听套接字，然后接受并处理连接。当socketIsOpen是{}时，你的程序将在while循环中使用大量的cpu循环，什么也不做。（顺便说一句，检查socketIsOpen的方式允许竞争条件，您可以在设置之前启动多个线程。）

最后一件事，您应该尝试使用threading模块，而不是不推荐使用的thread。在