客户端
import socket
# 1、用户
user = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 2、接通用户对象
user.connect(('127.2.2.1', 8080))
# 3、通信
while True:
msg = input("清输入对话信息: ").strip()
if len(msg) == 0: continue
user.send(msg.encode('utf-8'))
data = user.recv(1024)
print(data.decode('utf-8'))
# 4、关闭
phone.close()
服务器
# 服务端应该满足的特点:
# 1、一直提供服务
# 2、并发地提供服务
import socket
# 1、用户
user = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 流式协议=》tcp协议
# 2、绑定
user.bind(('127.2.2.1', 8080)) # 0-65535, 1024以前的都被系统保留使用
# 3、开机
user.listen(5)
print('服务端启动完成')
# 4、循环
while True:
conn, client_addr = user.accept()
# 5、通信
while True:
try:
data = conn.recv(1024)
if len(data) == 0:
break
print("客户端发来的消息:", data.decode('utf-8'))
conn.send(data.upper())
except Exception:
break
# 6、关闭
conn.close()
# 7、关机
phone.close()