Python_Day34_Socket模块2和黏包现象详解编程语言

要创建套接字，必須使用socket.socket()函数，它一般的语法如下： 
socket（socket_family, socket_type, protocol=0) 
其中，socket_family 是AF_UNIX或AF_INET, socket_type 是SOCK_STREAM 或SOCK_DGRAM,  
protocol通常省略，默认为0。 
 
创建TCP/IP套接字： 
tcpSock = socket.socket（socket.AF_INET, socket.SOCK_STREAM) 
创建UDP/IP套接字： 
udpSock = socket.socket（socket.AF_INET, socket.SOCK_DGRAM) 
 
因为有很多socket模块属性，所以此时使用'from module import *'这种导入方式可以简便许多， 
使用'from socket import *',就把socket属性引入到命名空间中，虽然看起来有些麻烦， 
但是通过这种方式将能够大大缩短代码，如： 
tcpSock = socket（AF_INET, SOCK_STREAM)

例：socket TCP仿ssh远程执行命令服务器 
#!/usr/bin/env python 
# _*_ coding: utf-8 _*_ 
 
from socket import * 
import subprocess 
 
''' 
socket TCP仿ssh远程执行命令服务器 
''' 
 
HOST = 'localhost' 
PORT = 9527 
ADDR = (HOST, PORT) 
BUFSIZ = 1024 
 
tcpss = socket(AF_INET, SOCK_STREAM) 
tcpss.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1) 
tcpss.bind(ADDR) 
tcpss.listen(5) 
 
while True: 
    conn, addr = tcpss.accept() 
    print('接受客户端连接中...:', addr) 
    while True: 
        # 接收客户端发过来的cmd命令 
        cmd = conn.recv(BUFSIZ) 
        # 命令为空时退出循环 
        if not cmd:break 
        ''' 
        subprocess通过子进程来执行外部指令，shell参数为True时，直接传入命令； 
        Popen方法用于先进入到某个输入环境，再执行一系列指令； 
        stdin 程序的标准输入，stdout 标准输出 stderr 标准错误。 
        ''' 
        result = subprocess.Popen(cmd.decode('utf-8'), shell=True, 
                                  stdout = subprocess.PIPE, 
                                  stdin  = subprocess.PIPE, 
                                  stderr = subprocess.PIPE ) 
 
        stderr = result.stderr.read() 
        stdout = result.stdout.read() 
        # 将标准输出和标准错误发送给客户端 
        conn.send(stderr) 
        conn.send(stdout) 
 
conn.close() 
tcpss.close() 
 
socket TCP仿ssh远程执行命令客户端 
 
#!/usr/bin/env python 
# _*_ coding: utf-8 _*_ 
 
from socket import * 
 
'''socket TCP仿ssh远程执行命令客户端''' 
 
HOST = 'localhost' 
PORT = 9527 
BUFSIZ = 1024 
ADDR = (HOST, PORT) 
 
tcpsc = socket(AF_INET, SOCK_STREAM) 
tcpsc.connect(ADDR) 
 
while True: 
    cmd = input('请输入要对服务端操作的命令>>>').strip() 
    if not cmd:break 
    # 当客户端输入quit时退出循环 
    if cmd == 'quit':break 
 
    tcpsc.send(cmd.encode('utf-8')) 
    result = tcpsc.recv(BUFSIZ) 
    # 注意，服务器操作系统为windows，所以解码的时候使用gbk 
    print(result.decode('gbk'), end='') 
 
tcpsc.close() 
 
正常命令输出短消息时不黏包如下： 
D:/PortableSoft/Python35/python.exe E:/Python/重要的代码/socket-远程执行命令/TCPscCmd.py 
请输入要对服务端操作的命令>>>dir 
 驱动器 E 中的卷是 VM 
 卷的序列号是 4AE6-716D 
 
 E:/Python/重要的代码/socket-远程执行命令 的目录 
 
2018-05-10  17:24    <DIR>          . 
2018-05-10  17:24    <DIR>          .. 
2018-05-10  17:24               532 TCPscCmd.py 
2018-05-10  17:24             1,375 TCPssCmd.py 
               2 个文件          1,907 字节 
               2 个目录 26,977,878,016 可用字节 
 
命令输出长消息时（1024字节一次显示不全）黏包如下： 
D:/PortableSoft/Python35/python.exe E:/Python/重要的代码/socket-远程执行命令/TCPscCmd.py 
请输入要对服务端操作的命令>>>help 
有关某个命令的详细信息，请键入 HELP 命令名 
ASSOC          显示或修改文件扩展名关联。 
ATTRIB         显示或更改文件属性。 
BREAK          设置或清除扩展式 CTRL+C 检查。 
BCDEDIT        设置启动数据库中的属性以控制启动加载。 
CACLS          显示或修改文件的访问控制列表(ACL)。 
CALL           从另一个批处理程序调用这一个。 
CD             显示当前目录的名称或将其更改。 
CHCP           显示或设置活动代码页数。 
CHDIR          显示当前目录的名称或将其更改。 
CHKDSK         检查磁盘并显示状态报告。 
CHKNTFS        显示或修改启动时间磁盘检查。 
CLS            清除屏幕。 
CMD            打开另一个 Windows 命令解释程序窗口。 
COLOR          设置默认控制台前景和背景颜色。 
COMP           比较两个或两套文件的内容。 
COMPACT        显示或更改 NTFS 分区上文件的压缩。 
CONVERT        将 FAT 卷转换成 NTFS。您不能转换 
               当前驱动器。 
COPY           将至少一个文件复制到另一个位置。 
DATE           显示或设置日期。 
DEL            删除至少一个文件。 
DIR            显示一个目录中的文件和子目录。 
DISKCOMP      请输入要对服务端操作的命令>>> 
 
此时继续输入一条比较短消息的命令会怎样，答案是之前未显示全的消息会继续发送过来接收： 
DISKCOMP      请输入要对服务端操作的命令>>>DATE 
 比较两个软盘的内容。 
DISKCOPY       将一个软盘的内容复制到另一个软盘。 
DISKPART       显示或配置磁盘分区属性。 
DOSKEY         编辑命令行、调用 Windows 命令并创建宏。 
DRIVERQUERY    显示当前设备驱动程序状态和属性。 
ECHO           显示消息，或将命令回显打开或关上。 
ENDLOCAL       结束批文件中环境更改的本地化。 
ERASE          删除一个或多个文件。 
EXIT           退出 CMD.EXE 程序(命令解释程序)。 
FC             比较两个文件或两个文件集并显示它们之间的不同。 
FIND           在一个或多个文件中搜索一个文本字符串。 
FINDSTR        在多个文件中搜索字符串。 
FOR            为一套文件中的每个文件运行一个指定的命令。 
FORMAT         格式化磁盘，以便跟 Windows 使用。 
FSUTIL         显示或配置文件系统的属性。 
FTYPE          显示或修改用在文件扩展名关联的文件类型。 
GOTO           将 Windows 命令解释程序指向批处理程序 
               中某个带标签的行。 
GPRESULT       显示机器或用户的组策略信息。 
GRAFTABL       启用 Windows 在图形模式显示扩展字符集。 
HELP           提供 Windows 命令的帮助信息。 
ICACLS         请输入要对服务端操作的命令>>> 
 
----------------------

>>> struct.pack('i',1111111111111) 
 
struct.error: 'i' format requires -2147483648 <= number <= 2147483647  
#这个是范围

例：传输大文件，解决黏包 
 
#!/usr/bin/env python 
# _*_ coding: utf-8 _*_ 
''' 
socket struct 传输大文件 解决黏包 TCP服务端 
''' 
import os 
import json 
import socket 
import struct 
 
server = socket.socket() 
server.bind(('127.0.0.1', 9527)) 
server.listen() 
conn, addr = server.accept() 
 
# 要传输的文件路径，文件名，文件大小 
filepath = r'E:/Python/file/三体.txt' 
filename = os.path.basename(filepath) 
filesize = os.path.getsize(filepath) 
dic = {'filename': filename, 
       'filesize': filesize} 
# 字典json并转码bytes字节 
str_dic = json.dumps(dic).encode('utf-8') 
# 计算出json的字节长度并固定为struct模块的四位模式 
len_dic = struct.pack('i', len(str_dic)) 
 
conn.send(len_dic) # 发送json的长度 
conn.send(str_dic) # 发送json 
 
with open(filepath, 'rb') as f: 
    while filesize: 
        content = f.read(4096) 
        conn.send(content) 
        filesize -= len(content) 
 
conn.close() 
server.close() 
 
客户端： 
#!/usr/bin/env python 
# _*_ coding: utf-8 _*_ 
 
''' 
socket struct 传输大文件 解决黏包 TCP客户端 
''' 
 
import json 
import struct 
import socket 
 
client =socket.socket() 
client.connect(('127.0.0.1', 9527)) 
 
dic_len = client.recv(4) 
dic_len = struct.unpack('i', dic_len)[0] 
dic = client.recv(dic_len) 
str_dic = dic.decode('utf-8') 
dic = json.loads(str_dic) 
 
with open(dic['filename'], 'wb') as f: 
    while dic['filesize']: 
        content = client.resv(4096) 
        dic['filesize'] -= len(content) 
        f.write(content) 
 
client.close()