网络编程ssh,粘包

1.什么是socket?

TCP,可靠地,面向连接协议,有阻塞rect 

udp,不可靠的,无线连接的服务 这里因为不需要阻塞,所以速度会很快,但安全性不高

2.关于客户端退出而服务器未退出的解决办法

import socket
sock=socket.socket() # TCP协议
IP_PORT=("127.0.0.1",8899)
sock.bind(IP_PORT)
sock.listen(5)
while 1:
    conn,addr=sock.accept()
    while 1:
        try:#这里是因为如果当客户端完成登陆后,由于客户端的退出,而
            #服务端只是刚刚退出第一层循环,还在等着接收客户端传来的信息,所以
            #会报错 只需要加一个异常处理,如果客户端离开则不会等待客户传来信息
            #会处于待命状态,等待下一次传入
            data=conn.recv(1024).decode("utf8")
            print("接收信息：",data)
            print("接收信息：",type(data))
            print("-----",data.split("|"))
            user,pwd=data.strip().split("|")
            # 文件操作
            flag=False
            with open("account","r") as f:

                for line in f:
                    print("===",line.strip().split(":"))
                    username,password=line.strip().split(":")
                    if username==user and password==pwd:
                        flag=True
                        break
            if flag:
                conn.send(b"success")
            else:
                conn.send(b"fail")
        except Exception as e:
            break

客户端

import socket

sock=socket.socket() # TCP
sock.connect(("127.0.0.1",8899))

while 1:
    user=input("用户名>>>>")
    pwd=input("密码>>>>")
    val=("%s|%s"%(user,pwd)).encode("utf8")
    sock.send(val)
    response=sock.recv(1024)
    print(response.decode("utf8"))
    if response.decode("utf8")=="success":
        break
    else:
        print("用户名或者密码错误！")
        continue

3.模拟ssh

import struct

#打包
res=struct.pack("i","")#这里可以放数字

print(res)#最终显示的是4个字节
print(len(res))#始终四个字节.长度为4

obj=struct.unpack("i",res)#用于解包,最后显示元祖,后面一逗号结尾
print(obj[0])#获取解包后的数字
#struct模块主要用于当发生粘包时.由于向客户端/服务端发送两个
#字节时,计算机无法判断前后位置,所以又来区分因为打包后固定长度为4
#所以取前四段
b'xxx/xxx/xxx/bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb'
#就可以区分了
#当然也可以用时间(睡眠)来区分

import subprocess#可以使cmd之间的程序在python中显示

res=subprocess.Popen("dir",#进行命令
                     shell=True,
                     stderr=subprocess.PIPE,#终端错误输出stderr
                     stdout=subprocess.PIPE)# 终端输出stdout

print(res.stdout.read().decode("gbk"))##返回的字节所以用gbk
#可以实现将cmd中的命令显示在python

import socket
import subprocess
server = socket.socket()
server.bind(('127.0.0.1',8008))
server.listen(5)
while True:
    print("server is working.....")
    conn,addr = server.accept()
    # 字节类型
    while True:
        # 针对window系统
        try:
            cmd = conn.recv(1024).decode("utf8") # 阻塞#客户端传入的命令需要解码显示成字符串的形式

            if cmd == b'exit':
                break
            # res=subprocess.Popen(cmd,#subprocess模块
            #                  shell=True,
            #                  stderr=subprocess.PIPE,
            #                  stdout=subprocess.PIPE,
            #                  )
            # print("stdout",res.stdout.read())
            # print("stderr",res.stderr.read().decode("gbk"))
            out=res.stdout.read()#终端输出 显示的是使用命令的正确
            err=res.stderr.read()#终端错误 显示的是不是系统命令的报错提示

            print("out响应长度",len(out))#知道长度才可以使他们逐一实现
            print("err响应长度",len(err))
            if err:
                 import struct
                 header_pack = struct.pack("i", len(err))#首先一定要给出长度,客户端才会跟据长度
                 #来显示
                 conn.send(header_pack)
                 conn.send(err)
            else:#没阻塞一次就发过去了
                 #构建报头
                 import struct#构建
                 header_pack=struct.pack("i",len(out))#数字的长度压缩完成报头
                 print("header_pack",header_pack)
                 # # 发送报头#将报文连在一起发送
                 conn.send(str(len(out)).encode("utf8"))#把数字转换成字符串,再转化成字节才可以发过去
                 # 发送数据
                 conn.send(out)#整体的数据

        except Exception as e:
            break
    conn.close()

客户端

sk.connect(('127.0.0.1',8008))

while 1:
    cmd = input("请输入命令：")
    sk.send(cmd.encode('utf-8')) # 字节
    if cmd=="":
        continue
    if cmd == 'exit':
        break

    header_pack=sk.recv(4)#取前四个字节
    data_length=struct.unpack("i",header_pack)[0]#解包
    print("data_length",data_length)
    '''
    b'xxx/xxx/xxx/bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb'
    
    
    '''
    data_length=int(sk.recv(1024).de- code("utf8"))
    print("data_length",data_length)
    recv_data_length=0#判断是否小于接收到的字节
    recv_data=b""
    while recv_data_length<data_length:
        data=sk.recv(1024)
        recv_data_length+=len(data)#接收多少就是这个
        #实现的前提需要总长度,
        recv_data+=data
    print(recv_data.decode("gbk"))
sk.close()

3.关于粘包

粘包:发送长度和数据但是计算机不知道怎么去区分 两个send计算机不知道怎么区分
我们丢的东西没有丢
1.间隔短 2.文件不大3.
sleep 不让粘包

关于加密

import hashlib

# md5=hashlib.md5()
# md5.update(b"hello")#当分别输入hello 和 yaun时 结果与helloyuan
#一样,但是这样的好处是可以分开存储节省内存,要是一次写入那么多
#会疯的
# md5.update(b"yuan")
#
# print(md5.hexdigest())
# print(len(md5.hexdigest()))

#helloyuan:   d843cc930aa76f7799bba1780f578439
#             d843cc930aa76f7799bba1780f578439

#############################################
md5=hashlib.md5()

with open("ssh_client.py","rb") as f:
    for line in f:
        md5.update(line)

print(md5.hexdigest()) # f.read() 16位字节