pythonsocket详细用法(Python中的Socket 与 ScoketServer 通信及遇到问题解决方法)
pythonsocket详细用法
Python中的Socket 与 ScoketServer 通信及遇到问题解决方法Socket有一个缓冲区,缓冲区是一个流,先进先出,发送和取出的可自定义大小的,如果取出的数据未取完缓冲区,则可能存在数据怠慢。其中【recv(1024)】表示从缓冲区里取最大为1024个字节,但实际取值大小是不确定的,推荐其值小于等于8192。
黏包问题:
Socket发送两条连续数据时,可能最终会拼接成一条进行发送
解决方法一:
两条数据间进行延时发送,如【tiem.sleep(0.5) #延时0.5s】
解决方法二:
每次发送后等待对方确认接收信息数据,发送一条后就立即接收等待
解决方法三:
设定接收数据大小,发送端每次发送需要发送的数据的数据大小,接收端通过设置【recv(xx)】只接收确定的大小
Socket基本使用:
简单的服务器:
|
import socket sser = socket.socket() #得到socket对象 sser.bind(( "0.0.0.0" , 2699 )) #建立监听 sser.listen( 3 ) print ( "等等客户端连接" ) conn,addr = sser.accept() #等待连接,会一直处于阻塞,返回连接对象和对方地址 print ( "有客户端已经连接,IP地址和端口为:" ,addr) #接收数据,会一直阻塞,建议低于8192 #使用连接对象操作 rdata = conn.recv( 1024 ) print (rdata.decode( "gbk" )) conn.send( "服务器返回,收到数据" .encode( "gbk" )) #发送数据,使用连接对象操作 #关闭连接 sser.close() |
简单的客户端:
|
import socket sclient = socket.socket() #得到socket对象 #连接服务器 #失败会报错:ConnectionRefusedError sclient.connect(( "192.168.1.135" , 2699 )) sclient.send( "东小东" .encode( "gbk" )) #发送数据 #接收数据,会一直阻塞,建议低于8192 rdata = sclient.recv( 1024 ) print (rdata.decode( "gbk" )) #关闭连接 sclient.close() |
Soket进阶:
服务器进阶:
实现客户循环连接及数据循环收发和判断客户端是否断开
|
import socket sser = socket.socket() #得到socket对象 sser.bind(( "0.0.0.0" , 2699 )) #建立监听 sser.listen( 3 ) while True : print ( "等等客户端连接" ) conn,addr = sser.accept() #等待连接,会一直处于阻塞,返回连接对象和对方地址 print ( "有客户端已经连接,IP地址和端口为:" ,addr) conn.send(( "服务器欢迎你:%s\r\n" % ( str (addr))).encode( "gbk" )) # 发送数据,使用连接对象操作 while True : #接收数据,会一直阻塞 #使用连接对象操作 rdata = conn.recv( 1024 ) if not rdata: break #判断客户端是否断开,断开则收到空数据 print (rdata.decode( "gbk" )) conn.send( "服务器返回,收到数据\r\n" .encode( "gbk" )) #发送数据,使用连接对象操作 #关闭连接 sser.close() |
客户端进阶:
实现循环收发和判断服务器是否断开
|
import socket sclient = socket.socket() #得到socket对象 #连接服务器 #失败会报错:ConnectionRefusedError sclient.connect(( "192.168.1.135" , 2699 )) while True : #接收数据,会一直阻塞 rdata = sclient.recv( 1024 ) if not rdata: break # 判断服务器是否断开,断开则收到空数据 print (rdata.decode( "gbk" )) sclient.send(( "客户端收到数据:%s\r\n" % rdata.decode( "gbk" )).encode( "gbk" )) # 发送数据 #关闭连接 sclient.close() |
注意:
发送数据不可发送空字符,否则会卡住,解决方法为判断输入的是否为空值,空值则进行数据发送
|
strx = input ( "输入:" ).strip() #得到控制台输入值 if ( len (strx) = = 0 ): continue #如果为空字符,则跳出本次循环 print (strx) #打印 sclient.send(strx.encode( "gbk" )) # 发送数据 |
发送大数据:
先发送总体数据大小,socket另一端判断实际接收的数据大小与总数据大小进行比较,循环recv()进行数据接收
简单的ssh实现:
服务端:
|
import os import socket sser = socket.socket() #得到socket对象 sser.bind(( "0.0.0.0" , 2697 )) #建立监听 sser.listen( 3 ) while True : print ( "等等客户端连接" ) conn,addr = sser.accept() #等待连接,会一直处于阻塞,返回连接对象和对方地址 print ( "有客户端已经连接,IP地址和端口为:" ,addr) conn.send(( "服务器欢迎你:%s\r\n" % ( str (addr))).encode( "gbk" )) # 发送数据,使用连接对象操作 while True : #接收数据,会一直阻塞 rdata = conn.recv( 1024 ) if not rdata: break #判断客户端是否断开,断开则收到空数据 sendtox = os.popen(rdata.decode( "gbk" )).read() #执行命令 conn.send( str ( len (sendtox)).encode( "gbk" )) #发送执行命令的结果长度 #如果长度大于0 则发送命令结果数据 if len (sendtox)> 0 : if conn.recv( 10 ).decode( "gbk" ) = = "1" : conn.sendall(sendtox.encode( "gbk" )) #发送最终数据 #关闭连接 sser.close() |
客户端:
|
import socket sclient = socket.socket() #得到socket对象 #连接服务器 #失败会报错:ConnectionRefusedError sclient.connect(( "192.168.43.21" , 2697 )) # 接收数据,会一直阻塞 rdata = sclient.recv( 1024 ) print (rdata.decode( "gbk" )) while True : strx = input ( "请输入命令:" ).strip() # 得到控制台输入值 if ( len (strx) = = 0 ): continue # 如果为空字符,则跳出本次循环 sclient.send(strx.encode( "gbk" )) # 发送数据 rdata = sclient.recv( 10 ) if not rdata: break # 判断服务器是否断开,断开则收到空数据 #判断命令是否执行成功,0为失败 dataall = int (rdata.decode( "gbk" )) if dataall = = 0 : continue sclient.send( "1" .encode( "gbk" )) # 发送确认接收数据命令 #循环接收数据 datanew = 0 while dataall ! = datanew: rdata = sclient.recv( 1024 ).decode( "gbk" ) datanew + = len (rdata) print (rdata) #关闭连接 sclient.close() |
发送文件:
发送文件,使用read()读取文件数据后,可循环调用send()发送数据,或者使用sendall()一次性发送所有数据,socket另一端接收可循环recv()进行数据接收,且每次接收的数据大小是不确定的。文件传输需要验证发送和接受的数据是否完全一致,可以通过数据大小加md5双重验证,发送端:md5在每次发送一条数据时进行update(),在数据发送完成后再发送md5值;接受端:md5在每次接收到一条数据后进行update(),在文件接收完成后再接收发送端发送的md5值,将两值进行比较,相同则表示传输无丢包,但加入md5校验,将会影响传输速率。
发送文件数据:先发送总体数据大小,socket另一端判断实际接收的数据大小与总数据大小进行比较,循环recv()进行数据接收
示例:客户端发送文件名,服务器判断文件是否存在,如果不存在或者是空文件则不进行传输,服务器进行文件发送,客户端实现文件接收
服务器
|
import os import socket sser = socket.socket() #得到socket对象 sser.bind(( "0.0.0.0" , 2697 )) #建立监听 sser.listen( 3 ) while True : print ( "等等客户端连接" ) conn,addr = sser.accept() #等待连接,会一直处于阻塞,返回连接对象和对方地址 print ( "有客户端已经连接,IP地址和端口为:" ,addr) conn.send(( "服务器欢迎你:%s\r\n" % ( str (addr))).encode( "gbk" )) # 发送数据,使用连接对象操作 while True : #接收数据,会一直阻塞 rdata = conn.recv( 1024 ) if not rdata: break #判断客户端是否断开,断开则收到空数据 filesize = 0 filenamex = rdata.decode( "gbk" ) if os.path.isfile(filenamex): #判断是否是文件 filesize = os.stat(filenamex).st_size #得到文件大小 conn.send( str (filesize).encode( "gbk" )) #不是文件则发送0,是文件则是实际大小 #如果文件大小大于0 则发送文件 if filesize> 0 : if conn.recv( 10 ).decode( "gbk" ) = = "1" : #等待确认接收命令 #一行一行发送数据 f = open (filenamex, "rb" ) for linex in f: conn.sendall(linex) #发送最终数据 #关闭连接 sser.close() |
客户端
|
import socket sclient = socket.socket() #得到socket对象 #连接服务器 #失败会报错:ConnectionRefusedError sclient.connect(( "192.168.43.21" , 2697 )) # 接收数据,会一直阻塞 rdata = sclient.recv( 1024 ) print (rdata.decode( "gbk" )) while True : filenamex = input ( "请输入文件名:" ).strip() # 得到控制台输入值 if ( len (filenamex) = = 0 ): continue # 如果为空字符,则跳出本次循环 sclient.send(filenamex.encode( "gbk" )) # 发送数据 rdata = sclient.recv( 10 ) if not rdata: break # 判断服务器是否断开,断开则收到空数据 #判断命令是否执行成功,0为失败 dataall = int (rdata.decode( "gbk" )) if dataall = = 0 : print ( "文件不存在或者为空" ) continue sclient.send( "1" .encode( "gbk" )) # 发送确认接收数据命令 #打开文件 f = open (filenamex, "wb" ) #循环接收数据 datanew = 0 while dataall ! = datanew: rdata = sclient.recv( 1024 ) datanew + = len (rdata) f.write(rdata) print ( "文件(%s)接收完毕" % filenamex) f.close() #关闭文件 #关闭连接 sclient.close() |
ScoketServer
服务端实现多并发效果,可以同时接入多个客户端
|
import socketserver #建立一个类,必须继承 socketserver.BaseRequestHandler 类 class DongSocket(socketserver.BaseRequestHandler): #必须重写handle方法 def handle( self ): print ( "建立新连接,对方地址为:{}" . format ( self .client_address)) while True : try : self .datax = self .request.recv( 1024 ).decode( "gbk" ) #接收数据 print ( "接收的数据为:%s" % self .datax) self .request.send(( "服务器返回数据:%s" % self .datax).encode( "gbk" )) except Exception as e: print ( "断开,再见:{}" . format ( self .client_address)) break #参数:(("ip",端口),自定义类) #ss=socketserver.TCPServer(("0.0.0.0",2351),DongSocket) #与之前的socket服务器效果一致,同时只能连接一个客户端 ss = socketserver.ThreadingTCPServer(( "0.0.0.0" , 2351 ),DongSocket) #同时可以连接多个客户端,多并发 ss.serve_forever() |
- 如何用python人脸识别(Python学习笔记之视频人脸检测识别实例教程)
- python对于gbk处理(Python 2/3下处理cjk编码的zip文件的方法)
- scrapy框架爬取小说的正文内容(Scrapy框架爬取Boss直聘网Python职位信息的源码)
- python发送微信消息脚本(python实现微信定时每天和女友发送消息)
- python网页自动化selenium(python利用selenium进行浏览器爬虫)
- opencv人脸识别实战(Python opencv实现人眼/人脸识别以及实时打码处理)
- 使用python编辑个人名片(python实现名片管理系统项目)
- python函数操作大全(Python的高阶函数用法实例分析)
- python采集微信电脑端聊天信息(利用Python实现微信找房机器人实例教程)
- python面向对象练习方法(Python面向对象实现一个对象调用另一个对象操作示例)
- python代码如何进行切片索引(Python读取Pickle文件信息并计算与当前时间间隔的方法分析)
- python的turtle库怎么进入(python的turtle库使用详解)
- python带权限复制文件夹(python定时复制远程文件夹中所有文件)
- python开启两个线程(Python开启线程,在函数中开线程的实例)
- 如何查看python beautifulsoup(Python爬虫beautifulsoup4常用的解析方法总结)
- python分析excel基础数据生成报表(Python实现定制自动化业务流量报表周报功能XlsxWriter模块)
- 泪目 这位 刷屏 的英雄,是全椒人的骄傲(泪目这位刷屏)
- 人从众 火炎焱 全椒再现 正月十六走太平 的魅力(人从众火炎焱全椒再现)
- 官宣 全椒籍明星许海峰 奚秀兰 方芳 王璐瑶携手回家 走太平(全椒籍明星许海峰)
- 以前全椒人是怎么过冬的 满满都是回忆(以前全椒人是怎么过冬的)
- NVIDIA显卡份额冲上88 A饭发愁 游戏优化恐没A卡份了(NVIDIA显卡份额冲上88A饭发愁)
- AMD YES A卡还是N卡 A卡和N卡的区别(AMDYESA卡还是N卡)
热门推荐
- python定时推送邮件(python实现定时压缩指定文件夹发送邮件)
- laravel自定义命令(laravel-admin select框默认选中的方法)
- wampserver配置教程图文(WampServer安装配置及使用图文教程)
- sqlserver语句显示表字段(SQL Server查找表名或列名中包含空格的表和列实例代码)
- python注册码实现(python实现Virginia无密钥解密)
- python加密和解密(python实现对输入的密文加密)
- 制作共用的头部和底部html5界面(html5移动端价格输入键盘的实现)
- dedecms如何建站(多端全媒体建站系统DEDECMS V6全新发布)
- 小鸟云怎么登录服务器(小鸟云服务器登陆图文教程)
- http404解决方案(http403禁止访问怎么解决?http403禁止访问错误原因汇总)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9