网络上的两个程序通过一个双向的通信连接实现数据的交换,这个连接的一端称为一个socket。
建立网络通信连接至少要一对端口号(socket)。socket本质是编程接口(API),对TCP/IP的封装,TCP/IP也要提供可供程序员做网络开发所用的接口,这就是Socket编程接口;HTTP是轿车,提供了封装或者显示数据的具体形式;Socket是发动机,提供了网络通信的能力。
建立一个socket必须至少有2端,一个是服务器端,一个是客户端,服务端被动等待并接收请求,客户端主动发起请求,连接建立后,双方可以互发数据。
socket.socket()
创建套接字对象必须使用socket库的socket函数,返回一个套接字对象描述符
- TCP
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM) - UDP
s = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
套接字对象内置方法
- 服务器套接字
s.bind() 将地址(ip,port)绑定到套接字上
s.listen() 设置并启动TCP监听器
s.accept() 被动接受TCP客户端连接,一旦等待到连接到达(阻塞) - 客户端套接字方法
s.connect() 主动发起TCP服务器连接
s.connect_next() connect()的扩展版本,此时会以错误码的形式返回问题,而不是抛出一个异常 - 普通套接字方法
s.recv() 接收TCP消息
s.recv_into() 接收TCP消息到指定的缓冲区
s.send() 发送TCP消息
s.sendall() 完整的发送TCP消息
s.recvfrom() 接收UDP消息
s.recvfrom_into() 接收UDP消息到指定的缓冲区
s.sendto() 发送UDP消息
s.getpeername() 连接到套接字(TCP)的远程地址
s.getsockname() 当前套接字的地址
s.getsockopt() 返回给定套接字选项的值
s.setsockopt() 设置给定套接字的值
s.shutdown() 关闭连接
s.close() 关闭套接字
s.detach() 在未关闭文件描述符的情况下关闭套接字,返回文件描述符
s.ioctl() 控制套接字的模式 - 面向阻塞的套接字方法
s.setbloking() 设置套接字的阻塞或非阻塞模式
s.settimeout() 设置阻塞套接字操作的超时时间
s.gettimeout() 获取阻塞套接字操作的超时时间 - 面向文件的套接字方法
s.fileno() 套接字的文件描述符
s.makefile() 创建与套接字关联的文件对象 - 数据属性
s.family 套接字家族
s.type 套接字类型
s.proto 套接字协议
操作实例
UDP通信
#server
from socket import *
from time import ctime
HOST = ''
PORT = 8888
BUFSIZ = 1024
ADDR = (HOST,PORT)
udpServSock = socket(AF_INET,SOCK_DGRAM)
udpServSock.bind(ADDR)
while True:
print("waiting for message...")
data,addr = udpServSock.recvfrom(BUFSIZ)
print("收到数据:",data.decode("utf-8"))
data =data.decode("utf-8")
content = '[%s] %s'%(bytes(ctime(),'utf-8'),data)
udpServSock.sendto(content.encode('utf-8'),addr)
print(".........received form and return to:",addr)
#client
from socket import *
HOST = '192.168.14.52'
PROT = 8888
BUFSIZ = 1024
ADDR = (HOST,PROT)
udpcliSOCK = socket(AF_INET,SOCK_DGRAM)
while True:
data =input(">")
if not data:
break
udpcliSOCK.sendto(data.encode('utf-8'),ADDR)
data,ADDR = udpcliSOCK.recvfrom(BUFSIZ)
if not data:
break
print(data.decode('utf-8'))
udpcliSOCK.close()
TCP通信
#server
from socket import *
server_address = ('',9000)
server_sock = socket(AF_INET,SOCK_STREAM)
server_sock.bind(server_address)
print("服务器监听端口%s中:"%server_address[1])
server_sock.listen(5)
try:
while True:
print("等待连接。。。")
client_sock,client_addr = server_sock.accept()
print("客户端{}已连接".format(client_addr))
while True:
data = client_sock.recv(2048)
if data:
print("接受数据:%s"%data.decode())
client_sock.send(data)
else:
client_sock.close()
finally:
server_sock.close()
#client
from socket import *
HOST = '192.168.14.52'
PROT = 9000
BUFSIZ = 1024
ADDR = (HOST,PROT)
socket_client = socket(AF_INET,SOCK_STREAM)
socket_client.connect(ADDR)
while True:
data = input(">")
socket_client.send(data.encode('utf-8'))
msg = socket_client.recvfrom(BUFSIZ)
print("响应:",msg[0].decode())