我试图做一个控制台聊天程序,但有一个问题,我的循环。我不能同时得到输入和接收其他人的输入。如果从一端发送两条或更多条消息,则另一端在发送完一条消息之前无法接收下一条消息。我对python相当陌生,正在寻找一个正确的方向。我曾想过多线程,但那有点超出了atm机的范围。还有别的主意吗?在
import EncMod
from socket import *
#Get User Info
Ip = raw_input('IP>>>')
Port = int(raw_input('Port>>>'))
User = raw_input('Username>>>')
#Open Socket To Server
EncCon = socket(AF_INET, SOCK_STREAM)
EncCon.connect((Ip, Port))
print '\nStarting Chat....'
print '\n<-------------------------------------------->\n\n'
#Send/Receive Loop
while 1:
MsgOut = raw_input()
if MsgOut: EncCon.send(MsgOut)
MsgIn = EncCon.recv(1024)
if MsgIn: print MsgIn
EncCon.close()
Twisted framework可用于帮助完成此任务。下面的代码将启动一个聊天服务器,然后客户端可以连接到该服务器并根据服务器实例设置来回通信。您可以进行适当的修改以满足您的要求:
问题是recv()调用会阻塞,直到接收到一些数据,而recv()正在阻塞时,程序不会检查stdin是否有任何输入。传统的单线程解决方案是将套接字设置为非阻塞I/O(通过Encon.setblocking公司(False)),然后将程序块放在select()中。将EncCon和stdin都传递给select()(作为其read socket set参数的一部分),这样select()将在其中任何一个有数据要提供给您时返回。(请注意,此方法在Windows下不起作用,因为Windows不允许select()阻塞stdin:P)
线程并不像你想象的那么难,掌握它是你工具箱中一个无价的补充。在
只需创建一个作为Thread子类的类,并确保它具有run()方法。然后实例化该类并调用其start()方法。在
使线程停止是更难做正确的。最好设置一个标志,并确保在while循环中定期检查它,因此blocking recv()需要一个超时,比如1秒。在
现在,这个程序仍然有一个最初的问题,那就是不可能启动两个实例,因为你不听,而是立即连接。但我相信这不是你问题的主要部分。在
相关问题 更多 >
编程相关推荐