1.socket编程
socket又叫套接字
socket编程其实就是用代码来实现进行网络通信的两个端；套接字就是实现通信的两个程序
实现通信的两个端分为服务器和客户端两种
python通过socket模块来提供socket编程相关的类和方法；其中socket类就是套接字对应的类
2.服务器端的实现
1)创建套接字对象(买电话机)
socket(family=AF_INET, type=SOCK_STREAM)
family - 设置ip类型; AF_INET对应的是ipv4; AF_INET6对应的是ipv6
type - 设置传输类型; SOCK_STREAM对应的是TCP协议; SOCK_DGRAM对应的是UDP协议
"""
server = socket()
2)绑定IP和端口(插电话线)
bind((ip地址, 端口))
ip地址: 找到互联网中唯一的一台计算机; 赋值ip地址对应的字符串
端口: 区分同一台计算机中不同的服务(程序); 赋整数,值的范围是0~65535, 其中0~1024属于著名，不能随便用。
同一时间同一个端口只能对应一个服务
server.bind(('10.7.156.58', 12342))
3)开始监听（等电话）
server.listen(512)
4)保证服务器一直运行
while True:
print('开始监听...')
5)接收客户端的请求(接电话)，返回为这个客户端创建的独立的套接字对象(分机)和客户端的地址
当程序运行到这句代码的时候会停下来，直到有请求为止
connection, address = server.accept()
print(connection, type(connection))
print(address)
print('============')
6)接收消息(听别人说话)
# recv(一次性能够接收的数据的大小) - 返回接收到的数据, 数据类型是二进制
recv_data = connection.recv(1024)
print(recv_data.decode(encoding='utf-8'))
7)发送消息(说话给别人听)
# send(需要发送的数据)
# with open('test.html', 'r', encoding='utf-8') as f:
# message = f.read()
# connection.send(('HTTP/1.1 200 OK\r\n\r\n'+message).encode())
message = input('(server)请输入:')
connection.send(message.encode())
8）关闭连接(挂电话)
connection.close()
二、socket客户端
1.客户端套接字
1)创建套接字对象(买电话)
client = socket()
2)连接服务器(拨号)
client.connect(('10.7.156.58', 12342))
3)发送消息
client.send('服务器你好吗？'.encode())
4)接收消息
re_data = client.recv(1024)
print(re_data.decode(encoding='utf-8'))
5)关闭连接
client.close()
三、server单人通讯
1.创建套接字对象
server = socket()
2.绑定ip和端口
server.bind(('10.7.156.58', 8081))
3.准备监听
server.listen(512)
4.让服务一直运行
while True:
print('开始监听...')
# 1.接受请求
connection, address = server.accept()
# 2.持续交流
while True:
# 接收消息
re_data = connection.recv(1024)
re_message = re_data.decode(encoding='utf-8')
print('%s:%s'% (address[0], re_message))
if re_message == '拜拜' or re_message == 'ByeBye':
connection.close()
break
# 发送消息
message = input('server:')
connection.send(message.encode())
if message == '拜拜' or message == 'ByeBye':
connection.close()
break
四、client持续通信
1.创建套接字对象
client = socket()
2.建立连接
client.connect(('10.7.156.58', 8086))
3.持续交流
while True:
# 1.发送消息
message = input('client:')
client.send(message.encode())
if message == '拜拜' or message == 'ByeBye':
client.close()
break
# 2.接收消息
re_message = client.recv(1024).decode(encoding='utf-8')
print('server:', re_message)
if re_message == '拜拜' or re_message == 'ByeBye':
client.close()
break
五、server图片数据
server = socket()
server.bind(('10.7.156.58', 8086))
server.listen(512)
while True:
connection, address = server.accept()
# 发送图片
with open('海贼王/aa.wav', 'rb') as f:
data = f.read()
# 先发送整个图片的总长度 100 -> '100'
length = len(data)
connection.send(str(length).encode())
# 再发送图片数据
connection.send(data)
六、client图片数据
client = socket()
client.connect(('10.7.156.58', 8086))
# 接收图片长度
total_length = int(client.recv(1024).decode())
print('第一次:', total_length)
sum_length = 0 # 保存接收到的图片的总长度
sum_data = bytes() # 保存接收到的图片的总数据
# 接收图片
while True:
# 方法一: 接收一点儿写一点儿
# re_data = client.recv(1024)
# length = len(re_data)
# sum_length += length
# print('当前接收的数据的长度:', length)
# with open('client/test.jpeg', 'ab') as f:
# f.write(re_data)
#
# if sum_length == total_length:
# break
re_data = client.recv(1024)
sum_data += re_data
if len(sum_data) == total_length:
with open('client/test1.wav', 'wb') as f:
f.write(sum_data)
break
七、多人同时聊天
class ConnectionThread(Thread):
def __init__(self, connection: socket, address):
super().__init__()
self.connection = connection
self.address = address
def run(self):
# 实现和一个客户端不断聊天的效果
while True:
re_message = (self.connection.recv(1024)).decode(encoding='utf-8')
print('%s:%s'%(self.address[0], re_message))
self.connection.send('我是余婷!'.encode())
server = socket()
server.bind(('10.7.156.58', 8086))
server.listen(512)
while True:
print('监听....')
connection, address = server.accept()
t1 = ConnectionThread(connection, address)
t1.start()
