标签:except bin soc net sock res tcp strip break
服务端:
import socket
#1.买手机
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) #SOCK_STEAM=>TCP流式协议,
print(phone) #是用来接收链接请求,从而建立链接的
# phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
# print(phone)
#2.插手机卡
phone.bind((‘127.0.0.1‘,8080)) #0-65535
#3.开机
phone.listen(5) # 同一时刻最大请求数为5个
print(‘start....‘)
#4.等待电话请求
conn,client_addr=phone.accept() #(双向链接的套接字对象,存放客户端ip和端口的小元组)
# print(conn) # conn代表双向链接,用来收发消息
# print(client_addr)
#5.收\发消息
data=conn.recv(1024) #1024接收的最大字节数bytes
print(‘收到客户的数据‘,data)
conn.send(data.upper())
#6.挂电话链接
conn.close()
#7.关机
phone.close()
客户端:
import socket
#1.买手机
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) #SOCK_STEAM=>TCP流式协议,
#2.拨号
phone.connect((‘127.0.0.1‘,8080))
#3.发\收消息
phone.send(‘hello‘.encode(‘utf-8‘)) # 只能发bytes类型
data=phone.recv(1024)
print(‘收到服务端的消息: ‘,data)
#4.挂电话链接
phone.close()
通信循环模板:
服务端:
import socket
iphone = socket.socket()
iphone.bind((‘127.0.0.1‘,5000))
iphone.listen()
while True:
client,addr = iphone.accept()
print(type(client),client,type(addr),addr)
while True:
try:
data = client.recv(1024)
if not data:
client.close()
break
print(‘收到客户端消息:%s‘% data.decode(‘utf-8‘))
client.send(data.upper())
except ConnectionResetError:
print(‘客户端强行关闭了连接‘)
client.close()
break
client.close()
iphone.close()
客户端:
import socket
iphone = socket.socket()
iphone.connect((‘127.0.0.1‘,5000))
while True:
msg = input(‘>>: ‘).strip()
iphone.send(msg.encode(‘utf-8‘))
data = iphone.recv(1024)
print(‘收到服务端消息:%s‘%data.decode(‘utf-8‘))
iphone.close()
基于UDP的通信循环:
服务端:
import socket
# UDP协议 在创建socket是 只有一个类型不同
server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM,proto=0)
server.bind(("127.0.0.1",8888))
while True:
data,addr = server.recvfrom(1024) # 阻塞 直到收到数据为止
print("收到来自%s的消息:%s" % (data.decode("utf-8"),addr[0]))
# 返回值为 数据 和 对方ip地址 和端口号
server.sendto(data.upper(),addr)
print(res)
server.close()
# 写一个UDP的多人聊天程序
#
客户端:
import socket
client = socket.socket(socket.AF_INET,socket.SOCK_DGRAM,0)
while True:
data = input(">>:").encode("utf-8")
client.sendto(data,("127.0.0.1",8888))
d,addr = client.recvfrom(1024)
print(d.decode("utf-8"))
client.close()
标签:except bin soc net sock res tcp strip break
原文地址:https://www.cnblogs.com/huangchaonan/p/10176518.html