网络编程
Socket (简称 套接字)是进程之间通信的一个工具,好比现实生活中的插座,所有的家用电器要想工作都是基于插座进行
进程之间想要进行网络通信需要socket,Socket 负责进程之间的网络数据传输,好比数据的搬运工
客户端和服务端
2个进程之间通过Socket进行相互通讯,就必须有服务端和客户端
- Socket服务端:等待其它进程的连接、可接受发来的消息、可以回复消息
- Socket客户端:主动连接服务端、可以发送消息、可以接收回复
Socket服务端编程
# 主要分为如下几个步骤:
# 1、创建socket对象
import socket
socket_server = socket.socket()
# 2、绑定socket_server 到指定IP和地址
socket_server.bind((host, port))
# 3、服务端开始监听端口
socket_server.listen(backlog) # backlog为int整数,表示允许连接的数量,超出的会等待,不填会自动设置一个合理值
# 4、接收客户端连接,获得连接对象
conn, address = socket_server.accept()
print(f"接收到客户端连接,连接来自:{address}")
# accept方法是阻塞方法,如果没有连接,会卡在当前这一行不向下执行代码
# accept返回的是一个二元元组,可以使用上述形式,用两个变量接收二元元组的2个元素
# 5、客户端连接后,通过recv方法,接收客户端发送的消息
while True:
data = conn.recv(1024).decode("UTF-8")
# recv方法的返回值是字节数组(Bytes),可以通过decode使用UTF-8解码为字符串
# recv方法的传参是buffsize,缓冲区大小,一般设置为1024即可
if data == "exit":
break
print ("接收到发送来的数据:", data)
# 可以通过while True 无限循环来持续和客户端进行数据交互
# 可以通过判定客户端发来的特殊标记,如exit,来退出无限循环
# 5、通过conn(客户端当次连接对象),调用send方法可以回复消息
while True:
data = conn.recv(1024).decode("UTF-8")
if data == "exit":
break
print ("接收到发送来的数据:", data)
conn.send("Hello,你好呀!".encode("UTF-8"))
# 6、conn(客户端当次连接对象)和socket_server对象调用close方法,关闭连接
# 演示Socket服务端开发
# 1、创建socket对象
import socket
socket_server = socket.socket()
# 2、绑定socket_server 到指定IP和地址
socket_server.bind(("localhost", 8888))
# 3、服务端开始监听端口
socket_server.listen(1) # listen方法内接受一个int整数,表示允许连接的数量,超出的会等待,不填会自动设置一个合理值
# 4、接收客户端连接,获得连接对象
# result: tuple = socket_server.accept()
# conn = result[0] # 客户端和服务端的连接对象
# address = result[1] # 客户端的地址信息
conn, address = socket_server.accept()
print(f"接收到了客户端连接,连接来自:{address}")
# accept方法是阻塞方法,如果没有连接,会卡在当前这一行不向下执行代码
# accept返回的是一个二元元组,可以使用上述形式,用两个变量接收二元元组的2个元素
# 5、客户端连接后,通过recv方法,接收客户端发送的消息
while True:
data: str = conn.recv(1024).decode("UTF-8")
# recv方法的返回值是字节数组(Bytes),可以通过decode使用UTF-8解码为字符串
# recv方法的传参是buffsize,缓冲区大小,一般设置为1024即可
if data == "exit":
break
print ("接收到发送来的数据:", data)
# 可以通过while True 无限循环来持续和客户端进行数据交互
# 可以通过判定客户端发来的特殊标记,如exit,来退出无限循环
# 5、通过conn(客户端当次连接对象),调用send方法可以回复消息
msg = input("请输入你要和客户端回复的消息")
if msg == "exit":
break
conn.send(msg.encode("UTF-8"))
# 6、conn(客户端当次连接对象)和socket_server对象调用close方法,关闭连接
conn.close()
socket_server.close()
接收到了客户端连接,连接来自:('127.0.0.1', 64552)
接收到发送来的数据: 你好
接收到发送来的数据: 你是猪
接收到发送来的数据:
Socket客户端编程
# 演示Socket客户端开发
# 1、创建socket对象
import socket
socket_client = socket.socket()
# 2、连接到服务端
socket_client.connect(("localhost", 8888))
# 3、发送、接收消息
while True:
send_msg = input("请输入你要发送的消息:")
if send_msg == "exit":
break
socket_client.send(send_msg.encode("UTF-8"))
recv_data = socket_client.recv(1024)
if recv_data == "exit":
break
print("服务端回复消息为:", recv_data.decode("UTF-8"))
# 4、关闭连接
socket_client.close()
# 请输入你要发送的消息:你好
# 服务端回复消息为: 你好,干嘛
# 请输入你要发送的消息:你是猪
# 服务端回复消息为: 你也是
# 请输入你要发送的消息:exit