Python Socket WebChat，我不明白 Select.select() 以及它是如何工作的答案

【问题标题】：Python Socket WebChat, I don't understand Select.select() and how it worksPython Socket WebChat，我不明白 Select.select() 以及它是如何工作的
【发布时间】：2015-06-09 23:02:11
【问题描述】：

我不想让这篇文章太长，所以我直接进入我不明白的部分

这是我从here 得到的代码我已经制作了自己的应用程序，但我以最糟糕的方式制作了它！

# Tcp Chat server

import socket, select

#Function to broadcast chat messages to all connected clients
def broadcast_data (sock, message):
    #Do not send the message to master socket and the client who has send us the message
    for socket in CONNECTION_LIST:
        if socket != server_socket and socket != sock :
            try :
                socket.send(message)
            except :
                # broken socket connection may be, chat client pressed ctrl+c for example
                socket.close()
                CONNECTION_LIST.remove(socket)

if __name__ == "__main__":

    # List to keep track of socket descriptors
    CONNECTION_LIST = []
    RECV_BUFFER = 4096 # Advisable to keep it as an exponent of 2
    PORT = 5000

    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # this has no effect, why ?
    server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    server_socket.bind(('', PORT))
    6.listen(10)

    # Add server socket to the list of readable connections
    CONNECTION_LIST.append(server_socket)

    print "Chat server started on port " + str(PORT)

    while 1:
        # Get the list sockets which are ready to be read through select
        read_sockets,write_sockets,error_sockets = select.select(CONNECTION_LIST,[],[])

        for sock in read_sockets:
            #New connection
            if sock == server_socket:
                # Handle the case in which there is a new connection recieved through server_socket
                sockfd, addr = server_socket.accept()
                CONNECTION_LIST.append(sockfd)
                print "Client (%s, %s) connected" % addr

                broadcast_data(sockfd, "[%s:%s] entered room\n" % addr)

            #Some incoming message from a client
            else:
                # Data recieved from client, process it
                try:
                    #In Windows, sometimes when a TCP program closes abruptly,
                    # a "Connection reset by peer" exception will be thrown
                    data = sock.recv(RECV_BUFFER)
                    if data:
                        broadcast_data(sock, "\r" + '<' + str(sock.getpeername()) + '> ' + data)                

                except:
                    broadcast_data(sock, "Client (%s, %s) is offline" % addr)
                    print "Client (%s, %s) is offline" % addr
                    sock.close()
                    CONNECTION_LIST.remove(sock)
                    continue

    server_socket.close()

我不明白使用 select 并添加新连接的部分，我猜每次应用程序尝试连接（myport，myip）时都会创建一个新描述符并且此方法尝试得到连接（）的人？你能解释一下吗？而且我不知道为什么将服务器套接字附加到套接字以及为什么将其传递给选择！我已经读过this 但我还是不明白

我也不明白为什么if sock == server_socket:意味着有一个新的连接，我想是因为我还没有理解select

【问题讨论】：

您的应用程序如何运行不符合您的预期？还是根本不工作？
阅读此docs.python.org/2/howto/sockets。那里有很多关于选择的解释。 Python 版本与 c 版本非常相似，因此不要将搜索限制在 Python 教程中。

标签： python sockets select web-chat

【解决方案1】：

Select()（就像 C 中的 select() 函数）有点神奇。它使您能够等待事件，而不会占用计算机的 CPU。

在您的情况下，事件是套接字的输入和输出操作。想象一下，您在关门前等待（“您”是 CPU）。如果可以做一些有用的事情，（正确的）门就会打开。每个门都会导致添加到 CONNECTION_LIST 的 I/O 操作。

在等待期间，CPU 不会在您的程序上花费时间。无论哪个门先打开，都会唤醒 CPU，让您处理数据。

注意：在 Linux 中，select() 适用于所有文件操作（例如，在本例中为套接字）。在 Windows 中，这仅适用于套接字。

注意 2：虽然套接字工作正常，但我更喜欢回调机制，例如 gio 库（glib 的一部分）中的 iowatch。这些将在需要操作时调用函数。

【讨论】：