13518219792
本地进程间通信(IPC)
• 队列
• 同步(互斥锁、条件变量等)
• 管道
网络进程间通信
问题: 本地通过进程PID来唯一标识一个进程,在网络中如何唯一标识一个进程?
网络层的“IP地址”可以唯一标识网络中的主机,而传输层的“协议+端口”
可以唯一标识主机中的应用程序(进程)。因此利用IP地址,协议,端口就
可以标识网络的进程。
什么是socket?
socket(简称套接字) 是进程间通信的一种方式, 能实现不同主机间的进程间通信,我们
网络上各种各样的服务大多都是基于 Socket 来完成通信的。
创建socket
在 Python 中 使用socket 模块的函数 socket 就可以完成:
socket.socket(AddressFamily, Type)
1). Address Family:
AF_INET: IPV4用于 Internet 进程间通信
AF_INET6: IPV6用于 Internet 进程间通信
2). Type:套接字类型
SOCK_STREAM: 流式套接字,主要用于 TCP 协议
SOCK_DGRAM: 数据报套接字,主要用于 UDP 协 议
import socket
#1. 创建socket对象
#family: AF_INET(IPv4) AF_INET6(IPv6) ========= 网络层协议
#type: # SOCK_STREAM(TCP) SOCK_DGRAM(UDP) ========== 传输层协议
#Linux： 可以认为是一个文件；
socketObj = socket.socket(family=socket.AF_INET, type=socket.SOCK_STREAM)
print(socketObj.getsockname())
#2. 关闭socket对象
socketObj.close()
2. socket基本使用
import os
os.system('hostname')
hostname = socket.gethostname()
print("主机名:", hostname)
print(socket.gethostbyname('localhost'))UDP介绍
UDP 用户数据报协议,是一个无连接的简单的面向数据报的运输层协议。UDP不提供可靠
性,它只是把应用程序传给IP层的数据报发送出去,但 是并不能保证它们能到达目的地。
由于UDP在传输数据报前不用在客户和服 务器之间建立一个连接,且没有超时重发等机制,
故而传输速度很快
UDP是一种面向无连接的协议,每个数据报都是一个独立的信息,包括完整 的源地址
或目的地址,它在网络上以任何可能的路径传往目的地,因此能否到达目的地,到达
目的地的时间以及内容的正确性都是不能被保证的
UDP特点
UDP是面向无连接的通讯协议,UDP数据包括目的端口号和源端口号信息, 由于通讯不需要连接,
所以可以实现广播发送。 UDP传输数据时有大小限 制,每个被传输的数据报必须限定在64KB之内。
UDP是一个不可靠的协 议,发送方所发送的数据报并不一定以相同的次序到达接收方。
UDP网络程序
import socket
udpserver = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM)
udpserver.bind(('0.0.0.0', 9999))
print('QQ用户A上线.........')
while True:
# 返回的是元组， 一个个元素是客户端发送的信息， 第二个元素是客户端和服务端交互的地址(IP, port)
recv_data, address = udpserver.recvfrom(1024)
#print(address)
print("B:>> ", recv_data.decode('utf-8'))
if recv_data == b'quit':
print("聊天结束.......")
break
#发送的消息必须是bytes类型
#bytes --> str bytesObj.decode('utf-8')
#str --> bytes strObj.encode('utf-8')
send_data = input('A: >> ').encode('utf-8')
if not send_data:
continue
udpserver.sendto(send_data, address)
udpserver.close()import socket
udpclient = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM)
print("QQ用户B上线.........")
while True:
send_data = input('B:>> ').encode('utf-8')
if not send_data:
continue
udpclient.sendto(send_data, ('172.25.254.197', 9999))
if send_data == b'quit':
print("聊天结束.....")
break
recv_data, address = udpclient.recvfrom(1024)
print("A:>> ", recv_data.decode('utf-8'))
udpclient.close()TCP介绍
TCP: 传输控制协议(英语:Transmission Control Protocol,缩写为TCP)是一种面向连
接的、可靠的、基于字节流的传输层通信协议。
TCP介绍
TCP: 传输控制协议(英语:Transmission Control Protocol,缩写为TCP)是一种面向连
接的、可靠的、基于字节流的传输层通信协议。
TCP网络程序
TCP三次握手
• 两个包: 同步序列标号 SYN
确认包 ACK
• 四种状态: SYN_SENT, LISTEN, SYN_RECV, ESTABLISHED
在三次握手中,客户端和服务器端都发送两个包SYN和ACK,只不过服务器端的两个包是一次性
发过来的,客户端的两个包是分两次发送的
TCP数据传输
TCP四次分手
当A端和B端要断开连接时,需要四次握手,这里称为四次挥手。
• 两个包: FIN:Finish, ACK确认序号
import socket
#1. 创建服务端socket对象
server = socket.socket(family=socket.AF_INET, type=socket.SOCK_STREAM)
#2. 绑定地址和端口(IP:port)
server.bind(('0.0.0.0', 9998))
#3. 监听是否有客户端连接?listen
server.listen(5)
print('server start .........')
#4.接收客户端的连接accept
clientSocketObj, clientAddress = server.accept()
#5. 接收客户端发送的消息
recv_data = clientSocketObj.recv(1024).decode('utf-8')
print("接收到客户端发送的消息:", recv_data)
#6. 给客户端发送消息
send_data = b'hello client'
clientSocketObj.send(send_data)
#7. 关闭socket对象
clientSocketObj.close()
server.close()import socket
#1. 创建服务端socket对象
client = socket.socket(family=socket.AF_INET, type=socket.SOCK_STREAM)
#2. 连接服务端
client.connect(('172.25.254.197', 9998))
#3.给服务端发送消息
client.send(b'hello server')
#4. 接收服务端发送的消息
recv_data = client.recv(1024).decode('utf-8')
print("接收服务端发送的消息:", recv_data)
#5. 关闭socket对象
client.close()并发服务器
并发服务器是socket应用编程中最常见的应用模型。根据连接方式分为长连接和短连接.
通信方式 具体通信过程
长连接 建立SOCKET连接后不管是否使用都保持连接
短连接 双方有数据交互时,建立TCP连接,数据发送完成后断开连接
并发服务器模型根据处理方式可分为同步方式和异步方式。
单进程服务器
• 同一时刻只能为一个客户进行服务,不能同时为多个客户服务
• 类似于找一个“明星”签字一样,客户需要耐心等待才可以获取到服务
多进程服务器
优点: 通过为每个客户端创建一个进程的方式,能够同时为多个客户端进行服务
缺点: 当客户端不是特别多的时候,这种方式还行,如果有几百上千个,就不 可取了,
因为每次创建进程等过程需要好较大的资源
#实现多进程的方式:
#1. 实例化对象
#2. 继承子类
#注意: 一定要确定多进程要处理的任务
#任务: 处理客户端请求并为其服务
def dealWithClient(clientSocketObj, clientAddress):
while True:
# 5. 接收客户端发送的消息
recv_data = clientSocketObj.recv(1024).decode('utf-8')
print(clientAddress[0] + str(clientAddress[1]) + ':> ' + recv_data)
if recv_data == 'quit':
break
clientSocketObj.close()
import socket
from multiprocessing import Process
#1. 创建服务端socket对象
server = socket.socket(family=socket.AF_INET, type=socket.SOCK_STREAM)
server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
#2. 绑定地址和端口(IP:port)
server.bind(('0.0.0.0', 9997))
#3. 监听是否有客户端连接?listen
server.listen(5)
print('server start .........')
while True:
# 4.接收客户端的连接accept
clientSocketObj, clientAddress = server.accept()
#dealWithClient(clientSocketObj)
p = Process(target=dealWithClient, args=(clientSocketObj, clientAddress))
p.start()
#server.close()import socket
#1. 创建服务端socket对象
client = socket.socket(family=socket.AF_INET, type=socket.SOCK_STREAM)
#2. 连接服务端
client.connect(('172.25.254.197', 9997))
while True:
# 3.给服务端发送消息
send_data = input('client: >> ').encode('utf-8')
if not send_data:
continue
client.send(send_data)
if send_data == 'quit':
break
#5. 关闭socket对象
client.close()另外有需要云服务器可以了解下创新互联cdcxhl.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。
