python-socket-简易版实时通信

一、socket服务端代码

"""
演示Socket服务端开发
"""
import socket
# 创建Socket对象
socket_server = socket.socket()

# 绑定ip地址和端口
socket_server.bind(("localhost",8888))

# 监听端口
socket_server.listen(1)
# listen方法内接受一个整数传参数,表示接受的连接数量

# 等待客户端连接
conn, address = socket_server.accept()
"""
此行代码分开写:
result:tuple = socket_server.accept()
conn = result[0] # 客户端和服务端的连接对象
address = result[1] # 客户端的地址信息
"""
# accept方法返回的是二元元组(连接对象,客户端地址信息)
# 可以通过 变量1,变量2 = socket_server.accept()的形式,直接接受二元元组内的两个元素
# accept()方法,是阻塞的方法,等待客户端的连接,如果没有连接,就卡在这一行不向下执行了

print(f"接收到了客户端的连接,客户端的信息是:{address}")

while True:
    # 接收客户端信息,要使用客户端和服务端的本次连接对象,而非socket_server对象
    data: str = conn.recv(1024).decode("UTF-8")
    # recv接受的参数是缓冲区大小,一般给1024即可
    # recv方法的返回值是一个字节数组也就是bytes对象,不是字符串,可以通过decode方法使用UTF-8编码,将字节数组转换为字符串对象
    # decode解码
    
    print(f"接收到客户端的信息:{data}")


    # 发送回复消息
    msg = input("请输入你要回复的消息:")
    if msg == 'exit':
        break
    # send发送的需要是bytes对象,使用encode方法使用UTF-8编码,将字符串对象转换为字节数组
    # encode编码
    conn.send(msg.encode("UTF-8"))

# 关闭连接
conn.close()
socket_server.close()

二、socket客户端代码

"""
演示socket客户端开发
"""
import socket

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


# 连接到服务端
socket_client.connect(("localhost",8888))

while True:
    # 发送消息
    msg = input("请输入客户端要发送的消息:")
    if msg == 'exit':
        break
    # encode编码
    socket_client.send(msg.encode("UTF-8"))

    # 接收返回消息
    data:str = socket_client.recv(1024)  # 1024是缓冲区的大小,一般1024即可,同样recv方法是阻塞的

    # decode解码
    print(f"接收服务端发来的消息是:{data.decode('UTF-8')}")

# 关闭连接
socket_client.close()

三、socket通信截图

socket服务端和客户端通信的完整过程.PNG
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。