实现socket_client下载socket_server文件

321ed · 发表于 2016-1-13 08:56:23

Socket模块：

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

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

socket_server端

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

#!/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端：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

#!/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()

测试结果：
启动服务器端；

启动客户端；