Python网络编程socket模块实例解析

栏目: Python · 发布时间: 5年前

内容简介:网络也是IO的一种,在Python中有专门的socket模块用来处理网络操作的。socket通常也称作”套接字”,用于描述IP地址和端口,是一个通信链的句柄,应用程序通常通过”套接字”向网络发出请求或者应答网络请求。socket起源于Unix,而Unix/Linux基本哲学之一就是“一切皆文件”,对于文件用【打开】【读写】【关闭】模式来操作。socket就是该模式的一个实现,socket即是一种特殊的文件,一些socket函数就是对其进行的操作(读/写IO、打开、关闭)。

网络也是IO的一种,在 Python 中有专门的socket模块用来处理网络操作的。

socket通常也称作”套接字”,用于描述IP地址和端口,是一个通信链的句柄,应用程序通常通过”套接字”向网络发出请求或者应答网络请求。

socket起源于Unix,而Unix/Linux基本哲学之一就是“一切皆文件”,对于文件用【打开】【读写】【关闭】模式来操作。socket就是该模式的一个实现,socket即是一种特殊的文件,一些socket函数就是对其进行的操作(读/写IO、打开、关闭)。

(1)利用socket进行简单的链接

Python里面的socket支持UDP、TCP、以及进程间的通信,socket可以把我们想要发送的东西封装起来,发送过去,然后反解成原来的样子,事实上网路通信可以理解成都是建立在socket之上,下面的代码是演示利用socket进行简单的链接

#要成一次通信,至少要有两个人,也就是一个服务端,一个客户端

#服务端

'''必须先开启着,等待客户端来进行链接请求,所以自己要先有个地址,也就是IP,也要现有自己的端口,没有端口进不去'''

import socket

sk= socket.socket()#创建对象

sk.bind(('127.0.0.1',9999,))#绑定IP和端口,以一个元组的方式传进去

sk.listen(5)#在前面链接已经建立的情况下,后面最多让五个人等待

while True:#让服务器端处于可以永远处于接受客户端请求的状态

conn,address=sk.accept()

print(conn,address)

'''

监听端口,等待以及接受客户端的请求,有可能会阻塞,主要功能是建立链接,以及接受客户端信息

conn相当于双方建立的这个链接,之后互相的通信要依靠这个链接;

address指的的对方的IP和端口

'''

下面是客户端代码

#客户端

import socket

obj =socket.socket()

'''相对于客户端,制定要链接谁就好了

'''

obj.connect(('127.0.0.1',9999,))#链接服务端

obj.close()#链接之后关闭

我们先让服务器端启动,然后再启动客户端,结果如图所示

Python网络编程socket模块实例解析

<socket.socket fd=4, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 9999), raddr=('127.0.0.1', 36126)> ('127.0.0.1', 36126)

<socket.socket fd=5, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 9999), raddr=('127.0.0.1', 36128)> ('127.0.0.1', 36128)

<socket.socket fd=4, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 9999), raddr=('127.0.0.1', 36130)> ('127.0.0.1', 36130)

成功打印出了每次的链接,以及客户端的IP以及端口号

(2)基于socket实现简单的传送消息

#服务器端

import socket

sk= socket.socket()

sk.bind(('127.0.0.1',9999,))#绑定IP和端口,以一个元组的方式传进去

sk.listen(5)#在前面链接已经建立的情况下,后面最多让五个人等待

while True:#让服务器端处于可以永远处于接受客户端请求的状态

conn,address=sk.accept()#基于conn这个链接发送东西

conn.sendall(bytes('有空来 Linux 公社www.linuxidc.com天天给你新知识',encoding='utf-8'))#Python3要用bytes类型,发送字节

'''建立一次链接,服务器就发送这个字段'''

print(conn,address)

然后用是客户端代码

#客户端

import socket

obj =socket.socket()

'''相对于客户端,制定要链接谁就好了

'''

obj.connect(('127.0.0.1',9999,))#链接服务端

'''

客户端去链接服务端,如果服务器端没有返回消息给客户端,则客户端会一直

在recv状态,一直等待服务器的消息

'''

result1= obj.recv(2014)#表示最多接收1024个字节,超过了下次接收、

result2= str(result1,encoding='utf-8')

print(result2)

obj.close()#链接之后关闭

当启动一次客户端建立一次链接,就会收到消息,结果如图

Python网络编程socket模块实例解析

(3)基于socket实现聊天机器人

#服务器端

import socket

sk= socket.socket()

sk.bind(('127.0.0.1',9999,))#绑定IP和端口,以一个元组的方式传进去

sk.listen(5)#在前面链接已经建立的情况下,后面最多让五个人等待

while True:#让服务器端处于可以永远处于接受客户端请求的状态

conn,address=sk.accept()#基于conn这个链接发送东西

conn.sendall(bytes('你好www.linuxidc.com,链接已经建立',encoding='utf-8'))#Python3要用bytes类型,发送字节

# '''建立一次链接,服务器就先发送这个字段'''

while True:#让通信状态不中断

ret_bytes = conn.recv(1024)

ret_str = str(ret_bytes,encoding='utf-8')

if ret_str =='q':#如果收到q,则终止链接

break

conn.sendall(bytes(ret_str+' 已收到该信息',encoding='utf-8'))

#print(conn,address)

下面是客户端代码

#客户端

import socket

obj =socket.socket()

'''相对于客户端,制定要链接谁就好了

'''

obj.connect(('127.0.0.1',9999,))#链接服务端

'''

客户端去链接服务端,如果服务器端没有返回消息给客户端,则客户端会一直

在recv状态,一直等待服务器的消息

'''

result1= obj.recv(2014)#表示最多接收1024个字节,超过了下次接收、

result2= str(result1,encoding='utf-8')

print(result2)

while True:

data = input('请输入你要发送的内容:')

if data == 'q':

obj.sendall(bytes(data, encoding='utf-8'))

print('链接断开')

break

else:

obj.sendall(bytes(data,encoding='utf-8'))

rec_byte = obj.recv(1024)#发了之后,接收信息

rec_str = str(rec_byte,encoding='utf-8')

print(rec_str)

obj.close()#链接之后关闭

结果如图所示

Python网络编程socket模块实例解析

(4)利用socket传送图片文件

#服务器端

import socket

sk= socket.socket()

sk.bind(('127.0.0.1',9999,))#绑定IP和端口,以一个元组的方式传进去

sk.listen(5)#在前面链接已经建立的情况下,后面最多让五个人等待

while True:#

conn,address= sk.accept()

conn.sendall(bytes('链接已建立,可以发送数据了',encoding='utf-8'))

file_size = str(conn.recv(1024),encoding='utf-8')#接收文件大小

print('接收的文件字节数:'+file_size)

total_size = int(file_size)

has_recv = 0#默认已接收了0个字节

f = open('linuxidc.com.png','wb')

#先接收文件大小,再开始接收文件

while True:

if total_size ==has_recv:#如果已接收的文件大小与客户端发送的一样大,则表示已经接收完毕

break

data = conn.recv(1024)

f.write(data)

has_recv +=len(data)

print('文件接收成功')

f.close()

下面是客户端

#客户端

import os

import socket

obj =socket.socket()

obj.connect(('127.0.0.1',9999,))#链接服务端

'''

客户端去链接服务端,如果服务器端没有返回消息给客户端,则客户端会一直

在recv状态,一直等待服务器的消息

# '''

#obj.sendall(bytes('你好',encoding='utf-8'))

ret_bytes = obj.recv(1024)

ret_str = str(ret_bytes,encoding='utf-8')

print(ret_str)

#发送文件大小

size=os.stat('linuxidc.png').st_size#获取文件大小

obj.sendall(bytes(str(size),encoding='utf-8'),)#文件大小的int型,要先转化为字符串

with open('linuxidc.png','rb')as f:

for line in f:

obj.sendall(line)

obj.close()

结果如图

Python网络编程socket模块实例解析

(5)socket粘包问题

发送文件需要依赖双方的缓冲区,就是我们先把文件写到缓冲区,然后再发送过去,但是我们一般不知道什么时候发过去,这容易造成粘包问题。例如上面的例子,客户端先发送文件大小,然后读文件写进缓冲区,假如文件读取特别快,第一次发送过去的可能既有文件大小又有文件内容,造成错误,这叫粘包,简而言之就是收到的信息比原本应收的多。

那么怎么解决粘包问题呢,通过发送以及接收确认包,还是以上面的例子说明,客户在发送文件大小之后不要马上发送文件,先recv接收一下,等待服务器发送已收到文件大小的确认包之后,再读取文件、发送文件,这样文件的发送和之前数据的发送就

完全独立开来了。

#服务器端

import socket

sk= socket.socket()

sk.bind(('127.0.0.1',9999,))#绑定IP和端口,以一个元组的方式传进去

sk.listen(5)#在前面链接已经建立的情况下,后面最多让五个人等待

while True:#

conn,address= sk.accept()

conn.sendall(bytes('链接已建立,可以发送数据了',encoding='utf-8'))

file_size = str(conn.recv(1024),encoding='utf-8')#接收文件大小

print('接收的文件字节数:'+file_size)

total_size = int(file_size)

has_recv = 0#默认已接收了0个字节

conn.sendall(bytes('文件大小已收到,可以开始发送数据了',encoding='utf-8'))#解决粘包问题,已经收到了文件大小,后面就可以单独发文件了

f = open('linuxidc.com.png','wb')

#先接收文件大小,再开始接收文件

while True:

if total_size ==has_recv:#如果已接收的文件大小与客户端发送的一样大,则表示已经接收完毕

break

data = conn.recv(1024)

f.write(data)

has_recv +=len(data)

print('文件接收成功')

f.close()

下面是客户端

#客户端

import os

import socket

obj =socket.socket()

obj.connect(('127.0.0.1',9999,))#链接服务端

'''

客户端去链接服务端,如果服务器端没有返回消息给客户端,则客户端会一直

在recv状态,一直等待服务器的消息

# '''

#obj.sendall(bytes('你好www.linuxidc.com',encoding='utf-8'))

ret_bytes = obj.recv(1024)

ret_str = str(ret_bytes,encoding='utf-8')

print(ret_str)

#发送文件大小

size=os.stat('linuxidc.png').st_size#获取文件大小

obj.sendall(bytes(str(size),encoding='utf-8'),)#文件大小的int型,要先转化为字符串

ack_packet=obj.recv(1024)

print(str(ack_packet,encoding='utf-8'))

with open('linuxidc.png','rb')as f:

for line in f:

obj.sendall(line)

obj.close()

Python网络编程socket模块实例解析

Linux公社的RSS地址https://www.linuxidc.com/rssFeed.aspx

本文永久更新链接地址: https://www.linuxidc.com/Linux/2018-12/156062.htm


以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

数据结构(C语言版)

数据结构(C语言版)

严蔚敏、吴伟民 / 清华大学出版社 / 2012-5 / 29.00元

《数据结构》(C语言版)是为“数据结构”课程编写的教材,也可作为学习数据结构及其算法的C程序设计的参数教材。 本书的前半部分从抽象数据类型的角度讨论各种基本类型的数据结构及其应用;后半部分主要讨论查找和排序的各种实现方法及其综合分析比较。其内容和章节编排1992年4月出版的《数据结构》(第二版)基本一致,但在本书中更突出了抽象数据类型的概念。全书采用类C语言作为数据结构和算法的描述语言。 ......一起来看看 《数据结构(C语言版)》 这本书的介绍吧!

CSS 压缩/解压工具
CSS 压缩/解压工具

在线压缩/解压 CSS 代码

SHA 加密
SHA 加密

SHA 加密工具

Markdown 在线编辑器
Markdown 在线编辑器

Markdown 在线编辑器