import struct

num = 156

#将int类型的数据打包成4个字节的数据

num_stru = struct.pack('i',num)

print(len(num_stru))

print(num_stru)

print('')

#在通过int类型解包,将前面打包的数据解包成打包之前的int数据

num2 = struct.unpack('i',num_stru) #解包出来是个元组

print(num2)#(156,)

print(num2[0])

import socket

import subprocess

import struct

server = socket.socket()

ip = ('192.168.15.142',8003)

server.bind(ip)

server.listen()

coon,addr = server.accept()
while 1:

　　from_client_msg = coon.recv(1024).decode('utf-8')

　　sub_obj = subprocess.Popen(from_client_msg,stdout=subprocess.PIPE,stderr=subprocess.PIPE,shell=True)

　　server_cmd_msg = sub_obj.stdout.read()

　　cmd_msg_len = len(server_cmd_msg)

　　msg_len_stru = struct.pack('i',cmd_msg_len)

　　coon.send(msg_len_stru)

　　coon.sendall(server_cmd_msg)

import struct

import socket

client = socket.socket()

server_ip = ('192.168.15.142',8003)

client.connect(server_ip)

while 1:

    msg = input('请输入指令：')

    client.send(msg.encode('utf-8'))

    from_server_msglen = client.recv(4)

    unpack_len_msg = struct.unpack('i',from_server_msglen)[0]

    recv_msg_len = 0

    all_msg = b''

    while recv_msg_len < unpack_len_msg:

        every_recv_data = client.recv(1024)

        all_msg += every_recv_data

        recv_msg_len += len(every_recv_data)

    print(all_msg.decode('gbk'))

import socket

import struct

import json

import os

tcp_server = socket.socket()

ip_port = ('127.0.0.1',8001) #127.0.0.1本机的回环地址,供内部程序之间测试用的

tcp_server.bind(ip_port)

tcp_server.listen()

#客户端上传的文件路径,都放在这个路径下

client_file_path = r'D:\jj'

conn,addr = tcp_server.accept()

#首先接收到文件信息长度转换出来的4个字节的数据

file_info_stru = conn.recv(4)

#解包文件信息的长度

file_info_len = struct.unpack('i',file_info_stru)[0]

#然后接收文件的描述信息

client_file_info = conn.recv(file_info_len).decode('utf-8')

#将接收到的json字符串反序列化

abc_file_info = json.loads(client_file_info)

print('abc_file_info>>>',abc_file_info)

client_file_size = abc_file_info['file_size']

recv_all_size = 0

#拼接一下全路径

client_full_path = client_file_path + '\\' + abc_file_info['file_name']

# client_full_path = os.path.join(client_file_path,abc_file_info['file_name'])

with open(client_full_path,'wb') as f:

    while recv_all_size < client_file_size:

        every_recv_data = conn.recv(1024)

        f.write(every_recv_data)

        recv_all_size += len(every_recv_data)

conn.send('小伙玩的行,上传成功!'.encode('utf-8'))

conn.close()

tcp_server.close()

import socket

import struct

import os

import json

tcp_client = socket.socket()

server_ip_port = ('127.0.0.1',8001)

tcp_client.connect(server_ip_port)

read_size = 1024

file_info = {

    'file_path':r'D:\python_workspace\day030\aaa.mp4',

    'file_name':'aaa.mp4',

    'file_size':None,

}

#获取文件大小

file_size = os.path.getsize(file_info['file_path'])

#将文件大小添加到文件信息的字典中

file_info['file_size'] = file_size

#因为我们要发送的数据是字节类型,那么必须将字典转换为bytes类型,但是字典不能直接转换为bytes,所以我们想到了json,

#通过json模块将字典类型的文件信息数据转换为了json类型的字符串

file_info_json = json.dumps(file_info)

#获取了字符串的长度

file_info_len = len(file_info_json)

#将长度打包为4个字节的数据,

file_info_stru = struct.pack('i',file_info_len)

#将打包好的4个自己的数据和我的文件信息数据一起发送给了服务端

tcp_client.send(file_info_stru)

tcp_client.send(file_info_json.encode('utf-8'))

#统计文件数据

all_file_data = b''

#统计文件数据长度

all_size_len = 0

with open(file_info['file_path'],'rb') as f:

    while all_size_len < file_size:

        every_read_data = f.read(read_size)

        all_file_data += every_read_data

        all_size_len += len(every_read_data)

        #发送每次读取的数据

        tcp_client.send(every_read_data)

print(tcp_client.recv(1024).decode('utf-8'))

tcp_client.close()

import socketserver

#1 定义一个类

class MyServer(socketserver.BaseRequestHandler): #2 类里面继承socketserver.BaseRequestHandler

    # 3 类里面定义一个handle方法,handle名称不能变

    def handle(self):

        while 1:

        # self.request      #conn链接通道

            from_client_data = self.request.recv(1024).decode('utf-8')

            print(from_client_data)

            server_input = input('明巍sb说>>>')

            self.request.send(server_input.encode('utf-8'))

        # self.request.close()

if __name__ == '__main__':

    #服务端的IP地址和端口

    ip_port = ('127.0.0.1',8001)

    socketserver.TCPServer.allow_reuse_address = True

    #绑定IP地址和端口,并且启动我定义的上面这个类

    server = socketserver.ThreadingTCPServer(ip_port,MyServer)

    #永久的给我执行下去

    server.serve_forever()

import socket

tcp_client = socket.socket()

server_ip_port = ('127.0.0.1',8001)

tcp_client.connect(server_ip_port)

while 1:

    client_msg = input('大阳哥>>>')

    tcp_client.send(client_msg.encode('utf-8'))

    from_server_msg = tcp_client.recv(1024).decode('utf-8')

    print(from_server_msg)