罗湖高端网站设计,广州游戏软件开发公司有哪些,网站seo平台,网站域名空间费用什么是socket定义socket通常也称作套接字#xff0c;用于描述IP地址和端口#xff0c;是一个通信链的句柄#xff0c;应用程序通常通过套接字向网络发出请求或者应答网络请求。socket起源于Unix#xff0c;而Unix/Linux基本哲学之一就是“一切皆文件”#xff0c;对于文件… 什么是socket定义socket通常也称作套接字用于描述IP地址和端口是一个通信链的句柄应用程序通常通过套接字向网络发出请求或者应答网络请求。socket起源于Unix而Unix/Linux基本哲学之一就是“一切皆文件”对于文件用【打开】【读写】【关闭】模式来操作。socket就是该模式的一个实现socket即是一种特殊的文件一些socket函数就是对其进行的操作读/写IO、打开、关闭socket和file的区别file模块是针对某个指定文件进行【打开】【读写】【关闭】socket模块是针对 服务器端 和 客户端Socket 进行【打开】【读写】【关闭】python相关Python 提供了两个基本的 socket 模块。py2位大写py3全部小写第一个是 Socket它提供了标准的 BSD Sockets API。第二个是 SocketServer 它提供了服务器中心类可以简化网络服务器的开发socket编程实现流程图说明服务端1.服务端需要导入socket模块并创建套接字(实例化为一个对象)import socket
s socket.socket() 2.绑定套接字s到本地IP和端口ip_port (127.0.0.1,8080)
s.bind(ip_port) 3.监听连接s.listen(0)PS0表示缓冲区可挂起的连接数量 0表示不限制1表示 可挂起一个那么意思就是连接一个、挂起一个第三个再连接的话就无法连接会超时 4.接收客户端建立连接的请求conn,addr s.accept()
PSconn为一个客户端和服务器建立的连接addr为客户端ip 5.接收客户端的消息并做相应处理recv_data conn.recv(1024)
send_data recv_data.upper() 将客户端发送的内容转换为大写注意。python3里面客户端发送的都是二进制数据python2里可以发送字符串 6.给客户端回消息conn.send(send_data) 7.关闭连接conn.close() 客户端1.创建套接字import sockets socket.socket() 2.连接服务端ip_port (127.0.0.1,8080)
s.connect(ip_port) 3.给服务端发送消息send_data input(请输入: )
s.send(send_data.encode()) 注意py3发送的数据需要转换为二进制不能直接发送字符串 4.接收服务端消息并打印recv_data s.recv(1024)print(recv_data.decode()) 服务端回应的是二进制所以需要转换为字符串 5.关闭连接s.close() 以上就是一个简单的客户端和服务端socket连接并发送消息读消息回消息的过程初学者可能一下子就懵了请看下面的类比类比通过上面的服务端和客户端的一个简单的交互可以将其比作打电话小明是服务端小红是客户端小红你好 此时小红是发消息小明此时处于收消息的状态小明你好 小明收到小红发的你好消息做出回应此时小明开始给小红发消息小红处于收消息状态最后小红收到了小明的消息小明此时已经挂断电话最后此次通信已断注意此次通信只是一个简单的交互过程交互完成之后则先完成方会主动关系连接。如果要持续通信请继续往下看小明小红小红和小明交互小红在和小明打电话前得有个通信工具等等所以需要找到一部手机类同创建一个套接字小红需要知道小明的电话号码并拨打电话此步骤就等于客户端连接服务端小明为了接收电话他首先得买个手机此步骤类同创建socket套接字小明有了手机需要办一张电话卡此步骤类同绑定套接字搭配监听的ip和端口小明有了手机和电话卡则手机开机处于待机状态 此步骤类同监听客户端连接当小红打电话进来之后需要接电话此类同于接收客户端建立连接的请求实现服务端保持连接不受客户端断开而断开并实现客户端和服务端持续交互过程服务端import socketip_port (127.0.0.1,8080)s socket.socket()
s.bind(ip_port)s.listen(0)while True: 此次while循环用于客户端断开连接之后重新循环建立新连接conn,addr s.accept() while True: 此while循环用于客户端和服务器持续交互recv_data conn.recv(1024) if not recv_data: break 判断消息是否为空当消息为空时跳出循环如果不判断的话客户端那边如果主动断开连接将会导致服务端处于一个不停的收消息的死循环中因为连接已断开处于非阻塞状态send_data recv_data.upper() 将客户消息转换为大写conn.send(send_data)conn.close() 客户端import sockets socket.socket()ip_port (127.0.0.1,8080)s.connect(ip_port)while True:send_data input(请输入: ) if send_data exit:breakelif send_data :continues.send(send_data.encode())recv_data s.recv(1024) print(recv_data.decode())
s.close() 运行服务端和客户端效果如下请输入: hello
HELLO
请输入: Jeck
JECK
请输入: 123
123请输入:
请输入: exitProcess finished with exit code 0 socket模块功能socket 类型socket.socket(socket.AF_INET,socket.SOCK_STREAM,0)参数一地址簇 socket.AF_INET IPv4默认 socket.AF_INET6 IPv6 socket.AF_UNIX 只能够用于单一的Unix系统进程间通信参数二类型 socket.SOCK_STREAM 流式socket , for TCP 默认 socket.SOCK_DGRAM 数据报式socket , for UDP socket.SOCK_RAW 原始套接字普通的套接字无法处理ICMP、IGMP等网络报文而SOCK_RAW可以其次SOCK_RAW也可以处理特殊的IPv4报文此外利用原始套接字可以通过IP_HDRINCL套接字选项由用户构造IP头。 socket.SOCK_RDM 是一种可靠的UDP形式即保证交付数据报但不保证顺序。SOCK_RAM用来提供对原始协议的低级访问在需要执行某些特殊操作时使用如发送ICMP报文。SOCK_RAM通常仅限于高级用户或管理员运行的程序使用。 socket.SOCK_SEQPACKET 可靠的连续数据包服务参数三协议 0 默认与特定的地址家族相关的协议,如果是 0 则系统就会根据地址格式和套接类别,自动选择一个合适的协议socket方法将套接字绑定到地址。address地址的格式取决于地址族。在AF_INET下以元组host,port的形式表示地址。是否阻塞默认True如果设置False那么accept和recv时一旦无数据则报错。接受连接并返回conn,address,其中conn是新的套接字对象可以用来接收和发送数据。address是连接客户端的地址。接收TCP 客户的连接阻塞式等待连接的到来连接到address处的套接字。一般address的格式为元组hostname,port,如果连接出错返回socket.error错误。同上只不过会有返回值连接成功时返回 0 连接失败时候返回编码例如10061关闭套接字接受套接字的数据。数据以字符串形式返回bufsize指定最多可以接收的数量。flag提供有关消息的其他信息通常可以忽略与recv()类似但返回值是data,address。其中data是包含接收数据的字符串address是发送数据的套接字地址。将string中的数据发送到连接的套接字。返回值是要发送的字节数量该数量可能小于string的字节大小。即可能未将指定内容全部发送。将string中的数据发送到连接的套接字但在返回之前会尝试发送所有数据。成功返回None失败则抛出异常。内部通过递归调用send将所有内容发送出去。将数据发送到套接字address是形式为ipaddrport的元组指定远程地址。返回值是发送的字节数。该函数主要用于UDP协议。设置套接字操作的超时期timeout是一个浮点数单位是秒。值为None表示没有超时期。一般超时期应该在刚创建套接字时设置因为它们可能用于连接的操作如 client 连接最多等待5s 返回连接套接字的远程地址。返回值通常是元组ipaddr,port。返回套接字自己的地址。通常是一个元组(ipaddr,port)sk.fileno()sk.getsockname()sk.getpeername()sk.settimeout(timeout)sk.sendto(string[,flag],address)sk.sendall(string[,flag])sk.send(string[,flag])sk.recvfrom(bufsize[.flag])sk.recv(bufsize[,flag])sk.close()sk.connect_ex(address)sk.connect(address)sk.accept()sk.listen(backlog) 开始监听传入连接。backlog指定在拒绝连接之前可以挂起的最大连接数量。backlog等于5表示内核已经接到了连接请求但服务器还没有调用accept进行处理的连接个数最大为5,这个值不能无限大因为要在内核中维护连接队列sk.setblocking(bool)sk.bind(address) 套接字的文件描述符案例模拟ssh服务端import socketimport subprocessip_port (127.0.0.1,8080)s socket.socket()
s.bind(ip_port)s.listen(0)while True:conn,addr s.accept() while True: try:recv_data conn.recv(1024) if not recv_data: breakp subprocess.Popen(str(recv_data,encodingutf-8),shellTrue,stdoutsubprocess.PIPE,stderrsubprocess.PIPE) 执行shell命令并将标准输出和错误输出放到缓冲区res p.stdout.read() if not res:send_data p.stderr.read() else:send_data resdata_size len(send_data)conn.send(send_data) except Exception: breakconn.close() * 客户端import socketip_port (127.0.0.1,8080)s socket.socket()s.connect(ip_port)while True:send_data input(: ) if send_data exit:exit() elif not send_data:continues.send(bytes(send_data,encodingutf-8))recv_data s.recv(1024) print(recv_data.decode())
s.close() 执行结果: df -h
Filesystem Size Used Avail Use% Mounted on/dev/disk1 112G 51G 62G 45% /: netstat -lnt
Active Internet connections
Proto Recv-Q Send-Q Local Address Foreign Address (state)
tcp4 0 0 172.16.23.42.57334 23.83.227.252.8023 ESTABLISHED
tcp4 0 0 127.0.0.1.1080 127.0.0.1.57333 ESTABLISHED
tcp4 0 0 127.0.0.1.57333 127.0.0.1.1080 ESTABLISHED
tcp4 0 0 127.0.0.1.8080 127.0.0.1.57332 ESTABLISHED
tcp4 0 0 127.0.0.1.57332 127.0.0.1.8080 ESTABLISHED
tcp4 0 0 172.16.23.42.57328 223.252.199.7.80 CLOSE_WAIT
tcp4 0 0 172.16.23.42.57269 163.177.72.143.993 ESTABLISHED
tcp4 0 0 10.255.0.10.57047 203.130.45.175.9000 ESTABLISHED
tcp4 27 0 172.16.23.42.57045 163.177.90.125.993 CLOSE_WAIT
tcp4 0 0 172.16.23.42.56988 114.215.186.163.443 ESTABLISHED
tcp4 27 0 172.16.23.42.56632 163.177.72.143.993 CLOSE_WAIT
tcp4 0 0 10.255.0.10.56374 10.2
: route -n0.7.12.22 ESTABLISHED
tcp4 27 0 172.16.23.42.56229 163.177.90.125.993 CLOSE_WAIT
tcp4 0 0 10.255.0.10.54889 203.130.45.175.9000 ESTABLISHED
tcp4 0 0 10.255.0.10.54605 203.130.45.173.6929 ESTABLISHED
tcp4 0 0 10.255.0.10.53228 10.20.7.12.22 ESTABLISHED
tcp4 0 0 10.255.0.10.53122 203.130.45.175.9000 ESTABLISHED
tcp4 0 0 172.16.23.42.52902 42.62.89.250.1194 ESTABLISHED
tcp4 0 0 127.0.0.1.1337 127.0.0.1.52901 ESTABLISHED
tcp4 0 0 127.0.0.1.52901 127.0.0.1.1337 ESTABLISHED
tcp4 0 0 172.16.23.42.52899 17.172.232.10.5223 ESTABLISHED
tcp4 0 0 172.16.23.42.52855 17.252.236.157.5223 ESTABLISHED
tcp4 0 0 172.16.23.42.52790 223.252.199.6.6003 ESTABLISHED
tcp4 0 0 172.16.23.42.50124 223.167.82.210.80 ESTABLISHED
tcp4 0 0 172.16.23.42.50026 1 从结果中发现执行df -h 返回正常结果执行netstat -lnt返回了一半的结果继续执行命令仍然返回的是netstat lnt的结果这就发生了粘包现象粘包解决所谓粘包现象就是服务端把数据发过来之后客户端接收时会按一定大小来接收决定此操作的是s.recv(1024)1024是每次接收的包大小第一次没有接收完的话第二次会继续接收原来的数据包这就是粘包现象解决办法就是服务端在发送数据时现告诉客户端本次数据的大小然后再发送数据客户端收到数据大小之后循环接收数据知道接收完成再终止此次循环这样就可以拿到所有的数据解决了粘包现象服务端改造#!/usr/bin/env python# -*- coding: UTF-8 -*-#pyversion:python3.5#owner:fuzjimport socketimport subprocessip_port (127.0.0.1,8080)s socket.socket()
s.bind(ip_port)s.listen(0)while True:conn,addr s.accept() while True: try:recv_data conn.recv(1024) if not recv_data: breakp subprocess.Popen(str(recv_data,encodingutf-8),shellTrue,stdoutsubprocess.PIPE,stderrsubprocess.PIPE)res p.stdout.read() if not res:send_data p.stderr.read() else:send_data resdata_size len(send_data) 计算数据大小conn.send(bytes(str(data_size),encodingutf-8)) 发送数据大小res conn.recv(1024) 接收客户端状态conn.send(send_data) 发送数据 except Exception: breakconn.close() * 客户端改造import socketip_port (127.0.0.1,8080)s socket.socket()s.connect(ip_port)while True:send_data input(: ) if send_data exit:exit() elif not send_data:continues.send(bytes(send_data,encodingutf-8))recv_size 0data bdata_size str(s.recv(1024),encodingutf-8) 接收数据大小s.send(bytes(ok,encodingutf-8)) 发送此时的状态 while recv_size int(data_size): 循环接收数据直到接收完所有数据recv_data s.recv(1024)data recv_datarecv_size len(recv_data) print(str(data,encodingutf-8))s.close() 运行结果发现已经解决上述问题: df -h
Filesystem Size Used Avail Use% Mounted on/dev/disk1 112G 51G 62G 45% /: netstat -lnt
Active Internet connections
Proto Recv-Q Send-Q Local Address Foreign Address (state)
tcp4 0 0 172.16.23.42.57476 223.252.199.7.80 CLOSE_WAIT
tcp4 0 0 127.0.0.1.8080 127.0.0.1.57475 ESTABLISHED
tcp4 0 0 127.0.0.1.57475 127.0.0.1.8080 ESTABLISHED
tcp4 0 0 172.16.23.42.57474 223.252.199.7.80 LAST_ACK
tcp4 0 0 172.16.23.42.57465 23.83.227.252.8023 ESTABLISHED
tcp4 0 0 127.0.0.1.1080 127.0.0.1.57464 ESTABLISHED
tcp4 0 0 127.0.0.1.57464 127.0.0.1.1080 ESTABLISHED
tcp4 0 0 172.16.23.42.57461 23.83.227.252.8023 ESTABLISHED
tcp4 0 0 127.0.0.1.1080 127.0.0.1.57460 ESTABLISHED
tcp4 0 0 127.0.0.1.57460 127.0.0.1.1080 ESTABLISHED
tcp4 0 0 172.16.23.42.57455 163.177.72.143.993 CLOSE_WAIT
tcp4 0 0 10.255.0.10.57047 203.130.45.175.9000 ESTABLISHED
tcp4 27 0 172.16.23.42.57045 163.177.90.125.993 CLOSE_WAIT
tcp4 0 0 172.16.23.42.56988 114.215.186.163.443 ESTABLISHED
tcp4 27 0 172.16.23.42.56632 163.177.72.143.993 CLOSE_WAIT
tcp4 0 0 10.255.0.10.56374 10.20.7.12.22 ESTABLISHED
tcp4 27 0 172.16.23.42.56229 163.177.90.125.993 CLOSE_WAIT
tcp4 0 0 10.255.0.10.54889 203.130.45.175.9000 ESTABLISHED
tcp4 0 0 10.255.0.10.54605 203.130.45.173.6929 ESTABLISHED
tcp4 0 0 10.255.0.10.53228 10.20.7.12.22 ESTABLISHED
tcp4 0 0 10.255.0.10.53122 203.130.45.175.9000 ESTABLISHED
tcp4 0 0 172.16.23.42.52902 42.62.89.250.1194 ESTABLISHED
tcp4 0 0 127.0.0.1.1337 127.0.0.1.52901 ESTABLISHED
tcp4 0 0 127.0.0.1.52901 127.0.0.1.1337 ESTABLISHED
tcp4 0 0 172.16.23.42.52899 17.172.232.10.5223 ESTABLISHED
tcp4 0 0 172.16.23.42.52855 17.252.236.157.5223 ESTABLISHED
tcp4 0 0 172.16.23.42.52790 223.252.199.6.6003 ESTABLISHED
tcp4 0 0 172.16.23.42.50124 223.167.82.210.80 ESTABLISHED
tcp4 0 0 172.16.23.42.50026 123.151.10.187.14000 ESTABLISHED
tcp4 0 0 172.16.23.42.49612 163.177.90.125.993 ESTABLISHED
tcp4 0 0 127.0.0.1.49871 127.0.0.1.49375 ESTABLISHED
tcp4 0 0 127.0.0.1.49375 127.0.0.1.49871 ESTABLISHED
tcp4 0 0 127.0.0.1.49871 127.0.0.1.49370 ESTABLISHED
tcp4 0 0 127.0.0.1.49370 127.0.0.1.49871 ESTABLISHED
tcp4 0 0 192.168.123.164.49282 112.90.83.61.443 ESTABLISHED socketserver 实现支持多客户端上述ssh模拟客户端只能支持一定数量的客户端受s.listen(0)参数限制。下面可以实现支持多客户端操作SocketServer内部使用 IO多路复用 以及 “多线程” 和 “多进程” 从而实现并发处理多个客户端请求的Socket服务端。即每个客户端请求连接到服务器时Socket服务端都会在服务器是创建一个“线程”或者“进程” 专门负责处理当前客户端的所有请求ThreadingTCPServerThreadingTCPServer实现的Soket服务器内部会为每个client创建一个 “线程”该线程用来和客户端进行交互实现步骤1.创建一个类并继承SocketServer.BaseRequestHandler 的类2.在新类中需要创建一个handle的方法3.启动ThreadingTCPServer代码如下import socketserverimport subprocessclass MyServer(socketserver.BaseRequestHandler): 继承 def handle(self): handle方法。注意此时send和recv时调用的self.request方法self.request.sendall(bytes(Welcome,encodingutf-8)) while True: try:recv_data self.request.recv(1024) if not recv_data: breakp subprocess.Popen(str(recv_data, encodingutf-8), shellTrue, stdoutsubprocess.PIPE,stderrsubprocess.PIPE)res p.stdout.read() if not res:send_data p.stderr.read() else:send_data res if not send_data:send_data no output.encode()data_size len(send_data)self.request.send(bytes(str(data_size), encodingutf-8))self.request.recv(1024)self.request.send(send_data) except Exception: breakif __name__ __main__:server socketserver.ThreadingTCPServer((127.0.0.1,8080),MyServer) 启动serverserver.serve_forever() PS:SocketServer.BaseRequestHandler类源码其定义了三个方法:setup(),handle()he finish()执行顺序为setup(0--handle()--finish()class BaseRequestHandler:def __init__(self, request, client_address, server):self.request requestself.client_address client_addressself.server serverself.setup() try:self.handle() finally:self.finish()def setup(self): passdef handle(self): passdef finish(self): passSocketServer.BaseRequestHandler ThreadingTCPServer源码剖析内部调用流程启动服务端程序执行 TCPServer.__init__ 方法创建服务端Socket对象并绑定 IP 和 端口执行 BaseServer.__init__ 方法将自定义的继承自SocketServer.BaseRequestHandler 的类 MyRequestHandle赋值给 self.RequestHandlerClass执行 BaseServer.server_forever 方法While 循环一直监听是否有客户端请求到达 ...当客户端连接到达服务器执行 ThreadingMixIn.process_request 方法创建一个 “线程” 用来处理请求执行 ThreadingMixIn.process_request_thread 方法执行 BaseServer.finish_request 方法执行 self.RequestHandlerClass() 即执行 自定义 MyRequestHandler 的构造方法自动调用基类BaseRequestHandler的构造方法在该构造方法中又会调用 MyRequestHandler的handle方法 转载于:https://blog.51cto.com/studys/1827235
