socket介绍
建立连接前的【握手】与断开连接的【挥手】都封装在socket中
socket和file区别:
file模块针对指定【文件】进行【打开】【读写】【关闭】
socket模块针对【服务器】和【客户端】进行【打开】【读写】【关闭】
socket参数
sk = socket.socket(family=socket.AF_INET,type=socket.SOCK_STREAM,proto=0,fileno=None)
Socket Familiems(地址簇) socket.AF_UNIX unix本机进程间通信 socket.AF_INET IPV4 socket.AF_INET6 IPV6 Socket Types # 套接类型 socket.SOCK_STREAM # tcp 协议 socket.SOCK_DGRAM # udp 协议 socket.SOCK_RAW # 可处理ICMP、IGMP等网络报文,处理特殊的IPV4报文,通过IP_HDRINCL伪造IP头(高级用户与管理员运行程序使用) socket.SOCK_RDM # 可靠的UDP形式,保证交付数据但不保证顺序
Socket Proto # 协议
0 #(默认)与特定的地址家族相关的协议,如果是 0 ,则系统就会根据地址格式和套接类别,自动选择一个合适的协议
socket.getaddrinfo(host, port, family=0, type=0, proto=0, flags=0) #获取要连接的对端主机地址 sk.bind(address) 将套接字绑定到地址。 address地址格式取决于地址族,在AF_INET下,以元组(host,port)的形式表示地址 sk.listen(backlog) 开始监听传入连接。backlog指定在拒绝连接之前,可挂起的最大连接数量,这个值不能无限大,因为要在内核中维护连接队列 sk.setblocking(bool) 是否阻塞(默认True),如果设置False,那么accept和recv时一旦无数据,则报错 sk.accept() 接受连接并返回(conn,address),其中conn是新的套接字对象,可以用来接收和发送数据。address是连接过来的客户端地址。 接收TCP 客户的连接(阻塞式)等待连接的到来 sk.connect(address) 连接到address处的套接字。一般,address的格式为元组(hostname,port),如果连接出错,返回socket.error错误。 sk.connect_ex(address) 连接到address处的套接字,会有返回值,连接成功时返回 0 ,连接失败时候返回编码,例如:10061 sk.recv(bufsize[,flag]) 接受套接字的数据。数据以字符串形式返回,bufsize指定最多可以接收的数量。flag提供有关消息的其他信息,通常可以忽略。 sk.recvfrom(bufsize[.flag]) 与recv()类似,但返回值是(data,address)。其中data是包含接收数据的字符串,address是发送数据的套接字地址。 sk.send(string[,flag]) 将string中的数据发送到连接的套接字。返回值是要发送的字节数量,该数量可能小于string的字节大小。即:可能一次性发不完 sk.sendall(string[,flag]) 将string中的数据发送到连接的套接字,但在返回之前会尝试发送所有数据。成功返回None,失败则抛出异常。 内部通过递归调用send,将所有内容发送出去。 sk.sendto(string[,flag],address) 将数据发送到套接字,address是形式为(ipaddr,port)的元组,指定远程地址。返回值是发送的字节数。该函数主要用于UDP协议。 sk.settimeout(timeout) 设置套接字操作的超时期,timeout是一个浮点数,单位是秒。值为None表示没有超时期。一般,超时期应该在刚创建套接字时设置,因为它们可能用于连接的操作(如 client 连接最多等待5s ) sk.getpeername() 返回连接套接字的远程地址。返回值通常是元组(ipaddr,port) sk.getsockname() 返回套接字自己的地址。通常是一个元组(ipaddr,port) sk.fileno() 套接字的文件描述符
socket连接过程
没有【客户端】连接的时候【服务器】一直处于waitting状态
socket 实例
1 import socket 2 import os 3 4 server = socket.socket() 5 6 server.bind((‘127.0.0.1‘,9999)) 7 8 server.listen(5) 9 10 while True: 11 print("等待客户端连接....") 12 conn,addr = server.accept() 13 print("新连接:",addr) 14 while True: 15 data = conn.recv(1024) 16 if not data: 17 print("客户端断开了...") 18 break 19 print("收到命令:",data) 20 res = os.popen(data.decode()).read() 21 print(len(res)) 22 conn.send(res.encode())
1 import os 2 3 server = socket.socket() 4 5 server.bind((‘127.0.0.1‘,9999)) 6 7 server.listen(5) 8 9 while True: 10 print("等待客户端连接....") 11 conn,addr = server.accept() 12 print("新连接:",addr) 13 while True: 14 data = conn.recv(1024) 15 if not data: 16 print("客户端断开了...") 17 break 18 print("收到命令:",data) 19 res = os.popen(data.decode()).read() 20 print(len(res)) 21 conn.send(res.encode(
1 import socket 2 3 client = socket.socket() 4 5 client.connect((‘127.0.0.1‘,9999)) 6 7 while True: 8 msg = input(">>>: ").strip() 9 if len(msg) == 0: continue 10 if msg == ‘q‘: break 11 client.send(msg.encode()) 12 data = client.recv(1024) 13 print(data.decode()) 14 15 client.close()