|
#!/usr/bin/env python
#-*- coding:utf8 -*- #支持汉字
import socket #导入socket模块
#/home/dragon/python/day5/bank_card.py #
s = socket.socket() #s等于socket模块中的socket类
host = '127.0.0.1' #socket模块中gethostname()函数能够得到当前主机名
port = 12800 #端口
s.bind((host,port)) #使用bind方法后,在调用listen方法监听某个地址;
s.listen(5) #listen方法只有一个参数,表示服务器未处理的连接数(允许的排队长度)
c,addr = s.accept() #accept方法会返回一个格式为(client,address)的元组,client是客户端套接字,address是地址
print "Got connection from" , addr #打印出目前连接的地址
def send_file():
File = Data.split('|') #获取客户端传过来的数据,以|作为分隔符
file_name1 = File[1] #获取客户端传过来的文件名
file_name = '/home/dragon/python/day5/%s' %(file_name1) #设置文件存放路径,名字用变量代替
print file_name
data_file = open(file_name,'rb') #以二进制方式打开文件
file_len = str(len(data_file.read())) #获取到文件长度,并转换为字符串格式,不能直接发送int格式的内容
c.send(file_len) #发送文件长度过去
yes_no = c.recv(1024) #接收客户端传过来的准备就绪信息
send_size = 0 #定义已经传送的字节
if yes_no == 'yes': #如果客户端已经准备yes
data_file.seek(0) #回到文件起始位置!
while int(file_len) != send_size: #进行文件传输,如果文件长度不等于传送的长度,进入循环
data_chuan = data_file.read(1024) #每次传输1024字节,可以自己定义4096页可以
c.send(data_chuan) #传输给客户端
send_size += len(data_chuan) #已经传送的字节大小
print '传输进度:%s : %s'%(send_size, file_len)
print '传输完成!!!!'
data_file.close() #关闭文件
while True:
Data = c.recv(1024) #接收客户端传输过来的信息
if not Data:break #如果客户端发过来的信息为空,则关闭连接
else:
send_file() #如果客户端发过来 的信息不为空,则调用send_file()函数
s.close() #关闭套接字,可以把close写在循环外面,这样就可以一直通信,知道客户端主动断开
|
|