python - 如何在python中实现非阻塞套接字服务器

一个类似但不同的问题:

我有一个生成字符串的IRC客户端。每当有人说出内容时，此IRC客户端都会使用钩子(Hook)来调用方法(somone_said)。我想通过套接字将此字符串发送到我的Flash客户端。

我在Flash中有一个工作的客户端，在python中有一个服务器，但问题是它阻止了:
1)在监听客户端连接时
2)在等待下一条消息产生时

这将阻止IRC客户端响应其他输入。

我想我需要在单独的线程中创建我的套接字，但这会带来另外三个问题。
1)我的someone_said事件驱动方法如何访问套接字
2)如果在没有服务器客户端连接(监听时)或客户端已关闭连接时有人说了什么，该怎么办？
3)如何检查线程是否还活着，如果不打开一个新线程？

我的阻止服务器代码是这样的:

# Echo server program
import socket
import sys

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

def startListening():
    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'
        sys.exit(1)
    conn, addr = s.accept()
    print 'Connected by', addr
    while 1:
        try:
            data = conn.recv(1024)
        except:
            print "cannot recieve data"
            break
        if not data:
            break
        print data
        message = ""
        while not "quit" in message:
            message = raw_input('Say Something : ') # This will come from event driven method
            try:
                conn.sendall(message)
            except Exception as exc:
                print "message could not be sent"
                break


    conn.close()
    print "connection closed"

while 1:
    startListening()

xchat模块python脚本的工作原理如下(需要运行HexChat)

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

import sys
import xchat

def someone_said(word, word_eol, userdata):
    # method called whenever someone speaks in IRC channel
    username = str(word[0]) # From IRC contains the username string
    message = str(word[1]) # From IRC contains the user message
    sendString = username + " : " + message
    send_to_server(sendString)


def send_to_server(message):
    # send over socket method to be implemented here

xchat.hook_print('Channel Message' , someone_said)

几天来，我一直在撞墙。帮我obi wan kenobi，你是我唯一的希望。

最佳答案

看看Asyncore，它完全按照您要搜索的内容完成:)

http://docs.python.org/2/library/asyncore.html

干杯，

K.