如何在Python中进行简单的命令行聊天？

Question

我学习网络编程，想用Python编写一个简单的命令行聊天。

我想知道如何使接收常数和输入一起可随时发送。

如您所见，此客户端一次只能执行一项工作：

from socket import *

HOST = 'localhost'
PORT = 21567
BUFSIZE = 1024
ADDR = (HOST, PORT)

tcpCliSock = socket(AF_INET, SOCK_STREAM)
tcpCliSock.connect(ADDR)

while 1:
    data = raw_input('> ')
    if not data: break
    tcpCliSock.send(data)
    data = tcpCliSock.recv(BUFSIZE)
    if not data: break
    print data

tcpCliSock.close()

因此，如果另一个客户机发送了一条消息，那么这个客户机也只能在发送了一条消息之后才能接收到它。我打赌你理解我。我在google上找到了很多有趣的东西，比如异步I/O、线程、非阻塞同步、并发编程等等。我还安装了扭曲包。总之，我一直在学习这些东西，但还没有找到我要找的东西。（当然，我会一直努力，直到我说到点子上。）

所以，我的问题是怎么做到的？=）

Answer 1

你的问题不太连贯。然而，您的程序根本不需要异步来实现您的要求。

这是一个工作的聊天脚本，你最初想要的变化很小。它使用1个线程接收和1个线程发送，都使用阻塞套接字。它比使用异步方法简单得多。

from socket import *
from threading import Thread
import sys

HOST = 'localhost'
PORT = 21567
BUFSIZE = 1024
ADDR = (HOST, PORT)

tcpCliSock = socket(AF_INET, SOCK_STREAM)
tcpCliSock.connect(ADDR)

def recv():
    while True:
        data = tcpCliSock.recv(BUFSIZE)
        if not data: sys.exit(0)
        print data

Thread(target=recv).start()
while True:
    data = raw_input('> ')
    if not data: break
    tcpCliSock.send(data)

tcpCliSock.close()