socket又叫套接字,就是进行数据通信两端。分为服务器套接字和客户端套接字。
套接字编程:自己写服务器或者客户端,进行数据传输。
python对socket编程的支持:提供一个socket库(内置)
import socket
一、服务器端(socket)
1、创建套接字对象
def creat_server():
socket(family,type)
a.family:确定IP协议类型
AF_INET:ipv4(默认)
AF_INET6:ipv6
b.type:传输协议类型
SOCK_STREAM:TCP协议(默认)
SOCK_DGRAM:UDP协议
server = socket.socket()
2、绑定IP地址和端口
端口:一台电脑上一个端口标记一个唯一的服务。范围0~65535,0~1014是著名端口,专门标记一个特殊服务,一般不适用。
注意:同一端口同一时间只能绑定一个服务。
server.bind(("10.7.153.113",8080))
3、监听(客户端请求)
listen(个数)
同一时间能够连接的客户端个数。
"""
server.listen()
4、让服务器处于运行状态
while True:
print('监听状态!')
连接客户端(建立连接),返回连接对象和客户端地址。
这句代码会阻塞线程,直到有客户端来请求当前服务器为止。
connect, addr = server.accept()
print(addr)
5、服务器给客户端发送消息
```
send(data)
date:python3中要求类型是bytes,python2中可以是字符串。
字符串 >>>> 二进制 :
1、字符串.encode(编码方式)默认utf-8
2、bytes(字符串,编码方式)默认None
connect.send('你好!'.encode())
connect.send(bytes('你好','utf-8'))
#6、接收从客户端发送过来的消息
recv(bufsize)
bufsize:每次能够接收的最大字节数
返回值:接收到的数据(二进制)
二进制 >>> 字符串:
1、二进制.decode()
2、str(二进制,编码方式)
注意:recv方法也会阻塞线程。
recv_data = connect.recv(1024)
print(recv_data.decode())
print(str(recv_data, 'utf-8'))
#7、断开连接
connect.close()
二、客户端(socket)
1、创建套接字对象
import socket
def creat_client():
client = socket.socket()
2、连接服务器
"""
connect(服务器地址,端口)
"""
client.connect(('10.7.153.113', 8080))
3、接收服务器发送的消息
data = client.recv(1024)
print(data.decode(encoding='utf-8'))
4、给服务器发送消息
client.send('我是客户端~~'.encode())
5、断开连接
client.close()
实例一:通信
服务器端
"""__author__=Deathfeeling"""
import socket
def creat_server():
"""写一个服务器"""
# 1、创建套接字对象
server = socket.socket()
# 2、绑定IP地址和端口
server.bind(("10.7.153.113",8080))
# 3、监听(客户端请求)
server.listen(5)
print('监听状态!')
connect, addr = server.accept()
# 4、让服务器处于运行状态
while True:
mesag = input('服务器:')
connect.send(mesag.encode())
#6、接收从客户端发送过来的消息
recv_data = connect.recv(1024)
print(recv_data.decode())
#7、断开连接
connect.close()
creat_server()
客户端
"""__author__=Deathfeeling"""
import socket
def creat_client():
# 1、创建套接字对象
client = socket.socket()
# 2、连接服务器
"""
connect(服务器地址)
"""
client.connect(('10.7.153.113', 8080))
while True:
# 3、接收服务器发送的消息
data = client.recv(1024)
print(data.decode(encoding='utf-8'))
# 4、给服务器发送消息
mesag = input('客户端:')
client.send(mesag.encode())
# 5、断开连接
client.close()
creat_client()
实例二:下载图片
图片服务器
"""__author__=Deathfeeling"""
import socket
server = socket.socket()
server.bind(('10.7.153.113', 8082))
server.listen(100)
while True:
connect,addr = server.accept()
with open('./beauty.png','rb') as f:
data = f.read()
connect.send(data)
connect.close()
#图片客户端
"""__author__=Deathfeeling"""
import socket
client = socket.socket()
client.connect(('10.7.153.113',8082))
#创建一个空的二进制数据
all_data = bytes()
data = client.recv(1024)
while data:
print('正在接收~~~')
#拼接二进制数据,得到完整的图片
all_data += data
data = client.recv(1024)
print('接收完毕!')
#写入在本地
with open('./new.png','wb') as f:
f.write(all_data)
client.close()
三、网络请求
get方法
"""__author__=Deathfeeling"""
import requests
# 1、准备url
url = 'https://www.apiopen.top/satinApi?type=1&page=1'
# 2、发送请求(get)
"""
get(url,参数对应的字典)
post(url,参数对应的字典)
"""
response = requests.get(url)
# requests.get('https://www.apiopen.top/satinApi',{'type'=1,'page'=1})
print(response)
3、通过相应获取服务器返回的数据
a、获取字符串类型的数据
print(response.text)
b、获取json的数据
print(response.json)
c、获取二进制格式的数据
print(response.content)
d、获取响应头(了解)
print(response.headers)
post类似,但是需要有对应的post接口。