Python socket 基础- Foundations of Python Socket
建立socket - establish socket
import socket
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
# s = 通信类型(type) + 协议家族(protocol)
# AF_INET = IPV4 ; AF_INET6 = IPV6
# SOCK_STREAM = TCP ; SOCK_DGRAM UDP s.connect(("www.zzyzz.top",80))
# s.connect((IP,PORT))
# python 中 socket 对象的 connect()方法会利用 DNS 把域名解析成 IP 寻找端口号 - detect the port
port = socket.getservbyname('http','TCP')
# 查询系统特定服务的端口号, 小于1024 由 IANA(Internet Assigned Numbers Authority)分配.
# socket.getservbyname( protocol name, port name) 从 socket 获取信息 - get info. from socket
sname = s.getsockname()
# 返回一个 tuple (client IP, client port), 对于客户端, 端口号由操作系统分配
pname = s.getpeername()
# 得到一个 tuple (sever IP, server port) socket 通信 - communication via socket
python 提供了 2 种通信方式：socket 对象 和 文件类对象
socket 对象的方法,
send()
sendto()
recv()
recvfrom() 文件类对象对应的方法,
read()
write()
readline() 异常处理 - process exceptions
python 的 socket 模块定义了 4 种可能出现的异常,
socket.error , 与 I/O 和 通信 有关的异常
socket.gaierror , 与 查询地址信息有关的异常
socket.herror , 与其他地址错误相关的异常
socket.timeout , 超时有关的异常(在一个 socket 对象上调用 settimeout()) 例子,
try:
s.connect(("www.zzyzz.top", 80))
except socket.gaierror as e:
print("Address related error : %s" % e)
except socket.error as e:
print("Connection error : %s" % e) output,
#1 Address related error : [Errno 11001] getaddrinfo failed -> socket.gaierror
#2 Connection error : [WinError 10060] A connection attempt -> socket.error
failed because the connected party did not properly respond
after a period of time, or established connection failed
because connected host has failed to respond
socket 模块可以把域名转换成IP地址(DNS), 有可能看到两中错误,
一种是域名错误,会得到 socket.gaierror , 另一种是链接远程 server 的 socket.error. 完整的 socket 建立的例子,
socket 对象类通信示例,
import socket try:
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
except socket.error as e:
print("Error at creating socket : %s" % e) try:
s.connect(("www.zzyzz.top", 80))
except socket.gaierror as e:
print("Address related error : %s" % e)
except socket.error as e:
print("Connection error : %s" % e) try:
s.send("HELLO THERE!".encode())
except socket.error as e:
print("Error at sending data : %s" % e) try:
s.shutdown(1)
except socket.error as e:
print("Error at sending data(shutdown) : %s" % e) #数据只有在调用了 shutdown() 方法后才能确保被发送. while 1:
try:
recv = s.recv(1024)
except socket.error as e:
print("Error at receiving data : %s" % e)
if not len(recv):
print("Data received")
break 文件类对象通信示例,
可以通过 makefile() 方法从 socket 对象得到一个文件类对象,实际上这个文件类对象调用的还是 socket,
所以由文件类对象产生的异常和 socket 对象的 send() 和 recv() 方法是一样的.
import socket
try:
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
except socket.error as e:
print("Error at creating socket : %s" % e) try:
s.connect(("www.zzyzz.top", 80))
except socket.gaierror as e:
print("Address related error : %s" % e)
except socket.error as e:
print("Connection error : %s" % e) FH = s.makefile('rwb',0) # 第一参数是 模式：读,写,读写; 第二个参数是 buffer size
try:
FH.write("HELLO THERE!".encode())
except socket.error as e:
print("Error at sending data : %s" % e) try:
FH.flush() # 由于在 makefile() 方法指定了 buffer size 是 0,
# 所以这例的 flush() 方法的调用时非必须地
except socket.error as e:
print("Error at sending data(flush) : %s" % e) try:
s.shutdown(1) # 即使调用 makefile(), 也要保存 socket 对象.
# makefile() 返回的文件类对象并不提供对 shutdown() 的调用
# 所以要保存原始 socket 对象, 并在其上调用 shutdown()
# 数据只有在调用了 shutdown() 方法后才能确保被发送.
s.close()
except socket.error as e:
print("Error at sending data(shutdown) : %s" % e) while 1:
try:
recv = FH.read(1024)
except socket.error as e:
print("Error at receiving data : %s" % e)
if not len(recv):
print("Data received")
break
Summarize,
对于客户端来说,建立一个 TCP 链接的过程分两步,
1, 建立 socket 对象
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
2, 调用 connect() 方法, 建立跟服务断(server)的链接.
s.connect(("www.zzyzz.top", 80))