运行一个python套接字服务器，如果关闭远程启动它再次监听

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，而你的while循环什么都不做。（顺便说一句，您检查socketIsOpen的方式允许竞争条件，您可以在设置之前启动多个线程。）

最后，您应该尝试使用线程模块，而不是不建议使用的线程。