参考视频
# socket服务端编程
# 主要分为如下几个步骤：
# 1.创建socket对象
# import socket
# socket_server = socket.socket()
# 2.绑定socket_server到指定IP和地址
# socket_server.bind(host, port)
# 3.服务端开始监听端口
# socker_server.listen(backlog)
# #backog为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)
# # 可以通过whileTrue无限循环来持续和客户端进行数据交
# # 可以通过判定客户端发来的特殊标记，如exit，来退出无限循环
# 6.通过conn(客户端当次连接对象)，调用send方法可以回复消息
# whileTrue:
# data = conn.recv(1024).decode('UTF-8')
# if data == 'exit':
# break
# print('接收到发送来的数据：', data)
#
# conn.send('你好哈哈哈'.encode('UTF-8'))
# 7.conn（客户端当次连接对象）和socketserver对象调用close方法，关闭连接
"""
演示Socket服务端开发
"""
import socket
# 创建Socket对象
socket_server = socket.socket()
# 绑定ip地址和端口
socket_server.bind(("localhost", 8888))
# 监听端口
socket_server.listen(1)
# listen方法内接受一个整数传参数，表示接受的链接数量
# 等待客户端链接
# result: tuple = socket_server.accept()
# conn = result[0] # 客户端和服务端的链接对象
# address = result[1] # 客户端的地址信息
conn, address = socket_server.accept()
# 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编码，将字节数组转换为字符串对象
print(f"客户端发来的消息是：{data}")
# 发送回复消息
msg = input("请输入你要和客户端回复的消息：") # encode可以将字符串编码为字节数组对象
if msg == 'exit':
break
conn.send(msg.encode("UTF-8"))
# 关闭链接
conn.close()
socket_server.close()
# 主要分为如下几个步骤：
# 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”)) # 消息需要编码为字节数组（UTF-8编码）
# 4.接收返回消息
# while True:
# send_msg=input("请输入要发送的消息”).encode（"UTF-8")
# socket_client.send(send_msg)
#
# recv_data = socket_client.recv(1024) # 1024是缓冲区大小，一般1024即可
# # recv方法是阻塞式的，即不接收到返回，就卡在这里等待
# print('服务端回复消息为：', recv_data.decode('UTF-8')) # 接受的消息需要通过UTF-8解码为字符串
# 5.关闭链接
# socket_client.close() #最后通过cLose关闭链接
"""
演示Socket客户端开发
"""
import socket
# 创建socket对象
socket_client = socket.socket()
# 连接到服务端
socket_client.connect(("localhost", 8888))
while True:
# 发送消息
msg = input("请输入要给服务端发送的消息：")
if msg == 'exit':
break
socket_client.send(msg.encode("UTF-8"))
# 接收返回消息
recv_data = socket_client.recv(1024) # 1024是缓冲区的大小，一般1024即可。 同样recv方法是阻塞的
print(f"服务端回复的消息是：{recv_data.decode('UTF-8')}")
# 关闭链接
socket_client.close()
转载请注明来源，欢迎对文章中的引用来源进行考证，欢迎指出任何有错误或不够清晰的表达。可以在下面评论区评论，也可以邮件至 3415226167@qq.com