五 套接字发展史及分类

六 套接字工作流程

一个生活中的场景。你要打电话给一个朋友，先拨号，朋友听到电话铃声后提起电话，这时你和你的朋友就建立起了连接，就可以讲话了。等交流结束，挂断电话结束此次交谈。 生活中的场景就解释了这工作原理。

图3

先从服务器端说起。服务器端先初始化Socket，然后与端口绑定(bind)，对端口进行监听(listen)，调用accept阻塞，等待客户端连接。在这时如果有个客户端初始化一个Socket，然后连接服务器(connect)，如果连接成功，这时客户端与服务器端的连接就建立了。客户端发送数据请求，服务器端接收请求并处理请求，然后把回应数据发送给客户端，客户端读取数据，最后关闭连接，一次交互结束

socket()模块函数用法

3：客户端发送空，卡主，证明是从哪个位置卡的

import socket

#先买手机

phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)  #SOCK_STREAM指的是TCp协议#实例话一个套接字对象

#绑定电话卡

#phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)#就是它在bind前加  没什么用

phone.bind(('127.0.0.1',8081))

phone.listen(5)#  开机  #后边的值是当前最大的连接数量

print('statring....')#   等电话
while True:

　　conn,addr=phone.accept()  #等待传入连接。返回一个新套接字表示客户端的连接和地址。

# IP套接字的地址，信息是一对。

　　print(addr)  #与服务器连接的客户端地址

　　print(conn) #客户端发过来的信息

　　#data=input('回复：')

　　while True:

    　　data=conn.recv(1024)#收发消息，1024最大接受字节数

    　　conn.send(data.upper()) # 将信息返回给客户端，返回的是二进制字节

　　conn.close()  #挂电话

phone.close()  #关机

客户端

import socket

#先买手机

phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)

#打电话

phone.connect(('127.0.0.1',8081))   #要连接的IP 地址

while True:

    #收发消息

    msg=input('请输入').strip()

    phone.send(msg.encode('utf-8'))  #将发送的信息，编码成UTF-8的格式传送给接受者

    data=phone.recv(1024)  #接受服务端的发送过来的信息

    print(data.decode('utf-8')) #将服务端发送的信息（二进制）解码出来

phone.close() #关闭

1 ss = socket() #创建服务器套接字

2 ss.bind()      #把地址绑定到套接字

3 ss.listen()      #监听链接

4 inf_loop:      #服务器无限循环

5     cs = ss.accept() #接受客户端链接

6     comm_loop:         #通讯循环

7         cs.recv()/cs.send() #对话(接收与发送)

8     cs.close()    #关闭客户端套接字

9 ss.close()        #关闭服务器套接字(可选)

1 cs = socket()    # 创建客户套接字

2 cs.connect()    # 尝试连接服务器

3 comm_loop:        # 通讯循环

4     cs.send()/cs.recv()    # 对话(发送/接收)

5 cs.close()            # 关闭客户套接字

服务端
import socket

import subprocess

import struct

import json

srevice=socket.socket()

srevice.bind(('127.0.0.1',8081))

srevice.listen(5)

print('statring......')

while True:

    conn,addr=srevice.accept()

    while True:

        try:

            data=conn.recv(1024).decode('gbk')#将接收的数据解码成'utf-8'或者'bgk'类型的

                      #因为subprocess.Popen()不支持bytes类型的

            if not data:break  #针对linux        #print(data)

            # 调用模块，执行命令，并且收集命令的执行结果，而不是打印

            obj=subprocess.Popen(data,shell=True,#aa代表的是读取字符串类型的命令

                         #  并且aa必须是utf-8类型的不能是bytesde ，

                         # sell=True代表是打开winds自带的shell命令解释器

                                 stdout=subprocess.PIPE,#存放正确结果的管道

                                 stderr=subprocess.PIPE#存放错误结果的管道

                                 )

            stdout = obj.stdout.read()  # 从管道中读取正确的内容，

            # print(stdout)

            stderr = obj.stderr.read()  # 从管道中读取错误的内容，

            # 1：先制作报头，报头里放：数据大小, md5, 文件

            header_dic={'total_size': len(stderr)+len(stdout),

                      'md5':'xxxxxxxx',

                      'filename':'xxxx'}

            header_json = json.dumps(header_dic)  #先json

            header_bytes = header_json.encode('utf-8')  #再将其写成bytes的格式

            header_size = struct.pack('i', len(header_bytes)) #将报头长度打包成一个4位的bytes类型数据

            conn.send(header_size)#2将长度发送过去

            conn.send(header_bytes)#3发送报头

            conn.send(stdout)  #4将得出的内容发送过去

            conn.send(stderr)

        except ConnectionResetError:#当结束后断开连接

            break

    conn.close()

srevice.close()

        #设置报头，将他包装在要传输的内容里

import socket

import struct

import json

#先买手机

phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)

#打电话

phone.connect(('127.0.0.1',8081))

while True:

    #收发消息

    msg=input('请输入').strip()

    if not msg:continue

    phone.send(msg.encode('utf-8'))  #将发送的信息，编码成UTF-8的格式传送给接受者

    data=phone.recv(4)  #4为接受的最大字节数，接受服务端的发送过来的信息，

    # 设置为4是为了防止报头和内容粘包，现将长度取出来

    heade_dict_size=struct.unpack('i',data)[0]#将长度解包出来，因为他是一个元祖，

    # 且长度放在索引位置的0位上，所以这样

    head_dic=phone.recv(heade_dict_size)  #将字典取出

    head_dic_bytes= head_dic.decode('utf-8') #将bytes合适解码出来

    head_dic_jsonloads=json.loads(head_dic_bytes)#反序列话得出字典

    max_len=head_dic_jsonloads['total_size']  #取出字典中的文件大小

    print(max_len)

    sum=0

    to_print=b''

    while sum<max_len:  #当长度小于返回值的总长度时，在循环中打印收到的内容

        data=phone.recv(1024)  #每次最多接受1024个字节

        to_print+=data  #将每一次的内容字符串加起来，得到最终的字符串

        sum+=len(data)

    print(to_print.decode('gbk')) #将服务端发送的信息（二进制）解码出来

phone.close() #关闭

from socket import *

cilence=socket(AF_INET,SOCK_DGRAM)

while True:

    info=input('>>')

    if not info:continue

    cilence.sendto(info.encode("utf-8"),('127.0.0.1',8081))#将内容发送给服务端，

    # 无需在开始绑定接受者的ip，直接传给他就行

    data,addr=cilence.recvfrom(1024) #接收服务器发送的内容

    print(data.decode('utf-8'))

cilence.close()

UDP客户端

from socket import *

cilence=socket(AF_INET,SOCK_DGRAM)

while True:

    info=input('>>')

    if not info:continue

    cilence.sendto(info.encode("utf-8"),('127.0.0.1',8081))#将内容发送给服务端，

    # 无需在开始绑定接受者的ip，直接传给他就行

    data,addr=cilence.recvfrom(1024) #接收服务器发送的内容

    print(data.decode('utf-8'))

cilence.close()

UDP服务端