码迷,mamicode.com
首页 > Web开发 > 详细

网络编程 --ftp上传

时间:2018-09-04 21:19:36      阅读:266      评论:0      收藏:0      [点我收藏+]

标签:cdb   head   操作   accept   header   config   元组   执行   put   

这是一个模拟的ftp上传功能,客户端输入命令之后,在客户端执行一个命令,把输入都上传到服务端在返回,前面是一个类似练习的例子

客户端

技术分享图片
#小试牛刀
# import socket
# kt=socket.socket() #创建socket对象
# info=("127.0.0.1",8800)
# kt.connect(info)
# while True:
#     import subprocess
#     res = subprocess.Popen("ipconfig",                #实例化Popen类  #并且接受的值是byte类型
#                            shell=True,
#                            stderr=subprocess.PIPE,
#                            stdout=subprocess.PIPE)
#     # print(len(res.stdout.read().decode("gbk")))  # 实例res通过stdout.read()方法读取数据
#     # print(">>>hello")                            # 这个地方不能写print
#     kt.send(res.stdout.read())

###########################################################################
# use=input("用户名:")
# pwd=input("密码:")
# val=("%s|%s"%(use,pwd)).encode("utf8")             #把多个变量同时传过去

############################################################################
import socket
kt=socket.socket() #创建socket对象
info=("127.0.0.1",8800)
kt.connect(info)
while True:
    import subprocess
    cmd=input(">>>请输入命令")
    res = subprocess.Popen(cmd,                #实例化Popen类  #并且接受的值是byte类型
                           shell=True,
                           stderr=subprocess.PIPE,
                           stdout=subprocess.PIPE)
    # print(len(res.stdout.read().decode("gbk")))  # 实例res通过stdout.read()方法读取数据
    # print(">>>hello")                            # 这个地方不能写print
    # out=res.stdout.read().decode("gbk")                          #写两个变量不让冲突,都在res上操作后面会出问题
    # print(len(out))
    # kt.send(res.stdout.read())

    out = res.stdout.read()
    err = res.stderr.read()
    print("out长度",len(out))
    print("err长度", len(err))

    #构建包头
    import struct
    # header_pack = struct.pack("i", len(out))   #把数据的长度打包成包头,和数据一起粘包发送过去,在服务端在解包
    #要发送的包头内容
    header_pack = struct.pack("i",len(out))      #i模式只能打包压缩整型类,打包的结果就是4个字节,可以直接发送
    #发送包头,
    kt.send(header_pack)
    #发送内容
    kt.send(out)                                 #包头和内容会作为粘包一起传过去,在对方一起解开
                                                #时间间隔特别短,两次发的就会当成一个包发过去
客户端

 

服务端

技术分享图片
#小试牛刀
# import socket
# sock=socket.socket() #创建socket对象,后面的操作都是对这个对象进行操作
#
# info=("127.0.0.1",8800)
# sock.bind(info)
# sock.listen(5)
# while   True:
#     conn,addr=sock.accept() #开始阻塞
#     # print("接收成功!")
#     data=conn.recv(1024)             #recv的参数是固定长度
#     print(data.decode("gbk"))
#     print("接收成功!")
###########################################################################################
#conn是谁?
import socket
import struct
sock=socket.socket() #创建socket对象,后面的操作都是对这个对象进行操作

info=("127.0.0.1",8800)
sock.bind(info)
sock.listen(5)
while   True:
    conn,addr=sock.accept() #开始阻塞
    # print("接收成功!")
    data=conn.recv(4)             #recv的参数是固定长度
    data_length=struct.unpack("i",data)[0]     #对方传过来是4长度的字节,解包以后是数字表示的长度,默认在元组中,用索引取出
    print(data)
    print(data_length)
    print("接收成功!")

    recv_data_length=0
    recv_data=b""
    while recv_data_length<data_length:     #data_length的长度是对方传过来的,这个是最大的
        data=conn.recv(1024)
        recv_data_length+=len(data)
        recv_data+=data
    print(">>>>>>>%s"%type(recv_data))
    print(recv_data.decode("gbk"))
    # data_length=int(conn.recv(1024).decode("utf8"))
服务端

 

其中用到的一些知识点:

struct模块


subprocess模块





网络编程 --ftp上传

标签:cdb   head   操作   accept   header   config   元组   执行   put   

原文地址:https://www.cnblogs.com/zhuhaofeng/p/9588474.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!