2

我已经制作了这个发送/接收脚本，但我损坏了文件！我不知道为什么我会遇到这个问题！

发件人.py

#!/usr/bin/env python

from socket import *
import sys

s = socket(AF_INET,SOCK_DGRAM)
host =sys.argv[1]
port = 9999
buf =1024
addr = (host,port)

file_name=sys.argv[2]

f=open(file_name,"rb") 
data = f.read(buf)

s.sendto(file_name,addr)
s.sendto(data,addr)
while (data):
    if(s.sendto(data,addr)):
        print "sending ..."
        data = f.read(buf)
s.close()
f.close()

接收器.py

#!/usr/bin/env python

from socket import *
import sys
import select

host="0.0.0.0"
port = 9999
s = socket(AF_INET,SOCK_DGRAM)
s.bind((host,port))

addr = (host,port)
buf=1024

data,addr = s.recvfrom(buf)
print "Received File:",data.strip()
f = open(data.strip(),'wb')

data,addr = s.recvfrom(buf)
try:
    while(data):
        f.write(data)
        s.settimeout(2)
        data,addr = s.recvfrom(buf)
except timeout:
    f.close()
    s.close()
    print "File Downloaded"

这是我修改过的原始接收器（工作正常 100%）

#!/usr/bin/env python

from socket import *
import sys
import select

host="0.0.0.0"
port = 9999
s = socket(AF_INET,SOCK_DGRAM)
s.bind((host,port))

addr = (host,port)
buf=1024

f = open("file.pdf",'wb')

data,addr = s.recvfrom(buf)
try:
    while(data):
        f.write(data)
        s.settimeout(2)
        data,addr = s.recvfrom(buf)
except timeout:
    f.close()
    s.close()
    print "File Donwloaded"

正如您所注意到的，它在开始时正在制作文件。

严格：客户端=>发送文件（name.ext）=>服务器：保存它（name.ext）

我的输出：pdf文件损坏，txt文件为空

4

2 回答 2

4

这里有两个问题：

语法错误：

您正在使用from socket import *. 它本身并不是一个错误，但是当你这样做时它就会变成一个错误except socket.timeout。

使用UDP：

使用 UDP，腐败应该不足为奇。您可能不想在这里使用 UDP，您应该切换到 TCP。

这就是为什么 UDP 在这里不合适的原因：

  • 数据包可能会丢失，但其他数据包仍然可以到达目的地。
  • 数据包可能重复
  • 数据包可能以错误的顺序到达

请注意，切换到 TCP 将涉及对您的代码进行一些重构（这比用 替换要复杂一些SOCK_DGRAM）SOCK_STREAM，但在您的情况下，您必须这样做。

我并不是说 UDP 不好，但它不适合你的情况。

于 2012-12-21T16:28:54.820 回答
4

您的代码的问题：

  • 当通过套接字发送数据时，通常下层会将来自多个 sendTo 调用的数据合并并一起发送以减少网络负载。
  • 您将文件的前 1024 个字节发送两次。

你应该做什么：

使用某种具有几个字符的分隔符字符串（例如“**_$$”），这样它就不会存在于实际的文件二进制表示中。然后将此分隔符附加到文件名的末尾。

在开始 while 循环之前再次从文件中读取。

在接收端，将所有内容接收到单个流中，然后使用分隔符拆分。您将拥有文件名和文件数据。

更新：

工作代码（Ubuntu / Windows XP）

# ----- sender.py ------

#!/usr/bin/env python

from socket import *
import sys

s = socket(AF_INET,SOCK_DGRAM)
host =sys.argv[1]
port = 9999
buf =1024
addr = (host,port)

file_name=sys.argv[2]

s.sendto(file_name,addr)

f=open(file_name,"rb")
data = f.read(buf)
while (data):
    if(s.sendto(data,addr)):
        print "sending ..."
        data = f.read(buf)
s.close()
f.close()

# ----- receiver.py -----

#!/usr/bin/env python

from socket import *
import sys
import select

host="0.0.0.0"
port = 9999
s = socket(AF_INET,SOCK_DGRAM)
s.bind((host,port))

addr = (host,port)
buf=1024

data,addr = s.recvfrom(buf)
print "Received File:",data.strip()
f = open(data.strip(),'wb')

data,addr = s.recvfrom(buf)
try:
    while(data):
        f.write(data)
        s.settimeout(2)
        data,addr = s.recvfrom(buf)
except timeout:
    f.close()
    s.close()
    print "File Downloaded"

用法

>> python recevier.py

>> python sender.py localhost filename.txt
于 2012-12-21T17:19:34.273 回答