实现socket_client下载socket_server文件

时间：2016-01-12 19:42:49 阅读：183 评论：0 收藏：0 [点我收藏+]

标签：

Socket模块：

在网络编程中的一个基本组件就是套接字(socket)。套接字基本上是两个端点的程序之间的“信息通道”。程序分布在不通的计算机上（通过网络连接），通过套接字相互发送信息。在python中的大多数的网络编程都隐藏了socket模块的基本细节，不直接和套接字交互。

套接字包括两个：服务器套接字和客户机套接字。在创建一个服务器套接字后，让它等待连接。这样它就在某个网络地址处（IP：端口）监听，直到有客户端套接字连接。连接完成后，服务器和客户端就可以进行交互了。

socket_server端

#!/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写在循环外面，这样就可以一直通信，知道客户端主动断开

socket_client端：

#!/usr/bin/env python
#-*- coding:utf-8 -*-
import socket
import sys
soc = socket.socket()
host =  ‘127.0.0.1‘
port = 12800
soc.connect((host,port))  #需要连接的服务器，端口。本次测试为同一台主机

def get_file():
    file_name = raw_input("请输入需要下载的文件名:")
    while not file_name.strip():
        file_name = raw_input("请输入需要下载的文件名:")
    raw_str = "file_get|%s" %(file_name)    #传输过去的内容变成file_get + 文件名
    soc.send(raw_str)        #发送文件名给服务器端
    Data1  = soc.recv(1024)   #接收到服务器传来文件大小信息
    print ‘文件长度为：‘,Data1
    yes_no = raw_input(‘是否接收文件？ yes or no :‘)
    if yes_no != ‘yes‘:
        print ‘退出连接！！！‘
        soc.close()
        sys.exit()
    soc.send(yes_no)   #yes或no发送给服务器
    int(Data1)   #把接收到的长度转换成init格式
    recevied_size = 0
    local_file = open(file_name,‘wb‘)   #通过二进制形式打开文件
    while int(Data1) != recevied_size:  #进入循环，不停接收来自服务器的数据，直到接收完毕
        recevied_data = soc.recv(1024)  #每次最多接收1024字节
        local_file.write(recevied_data)  #把接收到的内容写入文件
        recevied_size += len(recevied_data)  #加上每次接收到的长度
    local_file.close()   #关闭文件
    print "接收完毕！"
    inquire = raw_input(‘是否继续下载文件：yes or no ：‘)
    if inquire == ‘no‘:
        sys.exit()
    
while True:
    get_file()
soc.close()

测试结果：

启动服务器端；