35.网络编程

网络编程

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