我正在编写一个接受下载命令的TCP并发(基于进程的并发)服务器。客户端应该从服务器下载一个文件,到目前为止,我已经硬编码了要下载的文件名,以便测试我的下载算法。
我查找了一个示例下载算法,并使用了该代码中使用的while循环。
我认为我的问题是,while循环中的一个(或者两个)被挂断了,不会结束我相信是客户端,它可能正在等待更多的fileContent。
服务器
file = open('download.txt','rb+')
print "Opened File: " , file.name
fileContent = file.read(1)
clientsocket.send(fileContent)
while (fileContent):
print "iteration", fileContent
clientsocket.send(fileContent)
fileContent = file.read(1)
file.close()
客户端
print "Attempting download..."
f = open('downloaded.txt' , 'wb+')
print "Opened File: " , f.name
fileContent = s.recv(1)
while (fileContent):
print "iteration", fileContent
f.write(fileContent)
fileContent = s.recv(1)
print "Download Complete"
f.close()
我已经使用等代码在没有while循环的情况下完成了文件传输
f.open(file)
fContent = f.read(1024)
client.send(fContent)
f.close
f.open(file)
fContent = server.recv(1024)
f.write(fContent)
f.close
但我知道如果文件大于缓冲区大小,这会导致问题。
这是一个并发服务器,它使用一个单独的进程来处理每个连接。(我不认为这会影响我当前的问题,但我对并发性很陌生,我想我会提到它。)
有人知道为什么我的while循环没有结束吗?或者有人知道我可能做错了什么吗?提前感谢!
编辑:
我的输出:
cli
Attempting download...
Opened File: downloaded.txt
iteration t
iteration h
iteration i
iteration s
iteration
iteration i
iteration s
iteration
iteration a
iteration
iteration f
iteration i
iteration l
iteration e
iteration
serv
Recived dl from: ('127.0.0.1', 38161) | 2015-12-06 13:07:12.835998
Opened File: download.txt
iteration t
iteration h
iteration i
iteration s
iteration
iteration i
iteration s
iteration
iteration a
iteration
iteration f
iteration i
iteration l
iteration e
iteration
客户被卡住了,我不得不把它关掉。服务器将继续接受连接。我刚刚意识到,我可以在服务器的while循环之后添加一个简单的print语句,以检查服务器的whire循环是否完成。
第二次编辑:
服务器没有挂断(它在循环后成功地显示了消息)。这让我相信客户端正在调用recv()并等待更多的fileContent。
第三次编辑:
出于测试目的,读/写缓冲区仅为1。
逐字节发送文件可能非常慢。最好使用shutil.copyfileobj
,它为您处理传输:
def send_file(socket, filename):
with open('download.txt','rb') as inp:
print "Opened File: " , file.name
out = socket.makefile('wb')
shutil.copyfileobj(inp, out)
def recv_file(socket, filename):
with open('download.txt','wb') as out:
print "Opened File: " , file.name
inp = socket.makefile('rb')
shutil.copyfileobj(inp, out)