socket
概述
socket是网络连接端点,浏览器的网站和你(用户)两端使用各自的socket来发送和接收信息。
网络上的两个程序通过一个双向的通信连接实现数据的交换,这个连接的一端称为一个socket。
建立网络通信连接至少要一对端口号(socket)。socket本质是编程接口(API),对底层协议TCP/IP的封装,TCP/IP也要提供可供程序员做网络开发所用的接口,抽象化这就是Socket编程接口;
HTTP是轿车,提供了封装或者显示数据的具体形式;Socket是发动机,提供了网络通信的能力。
用于描述IP地址和端口,是一个通信链的句柄,可以用来实现不同虚拟机或不同计算机之间的通信。
在Internet上的主机一般运行了多个服务软件,同时提供几种服务。每种服务都打开一个Socket,并绑定到一个端口上,不同的端口对应于不同的服务。
Socket正如其英文原意那样,像一个多孔插座。一台主机犹如布满各种插座的房间,每个插座有一个编号,有的插座提供220伏交流电, 有的提供110伏交流电,有的则提供有线电视节目。
客户软件将插头插到不同编号的插座,就可以得到不同的服务。
套接字
源IP地址和目的IP地址以及源端口号和目的端口号的组合称为套接字。其用于标识客户端请求的服务器和服务。
它是网络通信过程中端点的抽象表示,包含进行网络通信必需的五种信息:连接使用的协议,本地主机的IP地址,本地进程的协议端口,远地主机的IP地址,远地进程的协议端口。
非常非常简单的举例说明下:Socket=Ip address+ TCP/UDP + port。
主要参数
Socket原意是 “插座”。通过将这3个参数结合起来,与一个“插座”Socket绑定,应用层就可以和传输层通过套接字接口,
区分来自不同应用程序进程或网络连接的通信,实现数据传输的并发服务。
Socket可以看成在两个程序进行通讯连接中的一个端点,是连接应用程序和网络驱动程序的桥梁,Socket在应用程序中创建,通过绑定与网络驱动建立关系。
此后,应用程序送给Socket的数据,由Socket交给网络驱动程序向网络上发送出去。
计算机从网络上收到与该Socket绑定IP地址和端口号相关的数据后,由网络驱动程序交给Socket,应用程序便可从该Socket中提取接收到的数据
网络应用程序就是这样通过Socket进行数据的发送与接收的。
套接字工作流程(基于tcp)
tcp是基于链接的,必须先启动服务端,然后再启动客户端去链接服务端
先从服务器端说起。服务器端先初始化Socket,然后与端口绑定(bind),对端口进行监听(listen),调用accept阻塞,等待客户端连接。
在这时如果有个客户端初始化一个Socket,然后连接服务器(connect),如果连接成功,这时客户端与服务器端的连接就建立了。
客户端发送数据请求,服务器端接收请求并处理请求,然后把回应数据发送给客户端,客户端读取数据,最后关闭连接,一次交互结束
#服务端
import socket
# 1.买手机
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)#获取tcp/ip套接字
#SOCKET socket(AF_INET,SOCK_STREAM,0)
# SOCKET 其实也就一个整数,宏定义了的
# socket()是一个函数,创建一个套接字,
# AF_INET 表示用IPV4地址族,
# SOCK_STREAM 是说是要是用流式套接字
# 0 是指不指定协议类型,系统自动根据情况指定
# 2.绑定手机卡
phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
#这里value设置为1,表示将SO_REUSEADDR标记为TRUE,
#操作系统会在服务器socket被关闭或服务器进程终止后马上释放该服务器的端口,
#否则操作系统会保留几分钟该端口。
phone.bind(('127.0.0.1',8080)) #绑定ip
#3.开机
phone.listen(5) #监听客户端连接,参数为连接数
#5代表最大链接挂起数,控制最多来5个链接
#4.等电话链接
print('starting...')
while True:
conn,addr=phone.accept()
print('IP:%s,PORT%s'%addr[0],addr[1])
# 5.收发消息
while True:
try:
data=conn.recv(1024) #最大收1024
if not data:break
conn.send(data.upper())
except Exception:
break
#6.挂电话
conn.close()
# 7.关机
phone.close(
服务端套接字函数
s.bind() 绑定(主机,端口号)到套接字
s.listen() 开始TCP监听
s.accept() 被动接受TCP客户的连接,(阻塞式)等待连接的到来
客户端套接字函数
s.connect() 主动初始化TCP服务器连接
s.connect_ex() connect()函数的扩展版本,出错时返回出错码,而不是抛出异常
公共用途的套接字函数
s.recv() 接收TCP数据
s.send() 发送TCP数据(send在待发送数据量大于己端缓存区剩余空间时,数据丢失,不会发完)
s.sendall() 发送完整的TCP数据(本质就是循环调用send,sendall在待发送数据量大于己端缓存区剩余空间时,数据不丢失,循环调用send直到发完)
s.recvfrom() 接收UDP数据
s.sendto() 发送UDP数据
s.getpeername() 连接到当前套接字的远端的地址
s.getsockname() 当前套接字的地址
s.getsockopt() 返回指定套接字的参数
s.setsockopt() 设置指定套接字的参数
s.close() 关闭套接字
面向锁的套接字方法
s.setblocking() 设置套接字的阻塞与非阻塞模式
s.settimeout() 设置阻塞套接字操作的超时时间
s.gettimeout() 得到阻塞套接字操作的超时时间
面向文件的套接字的函数
s.fileno() 套接字的文件描述符
s.makefile() 创建一个与该套接字相关的文件
#客户端
import socket
# 1.买手机
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#2.打电话
phone.connect(('127.0.0.1',8080))
# 3.发收消息
while True:#新增通信循环,客户端可以不断发收消息
msg=input('>>: ').strip()
if not msg:continue
phone.send(msg.encode('utf-8'))#发消息,说话(只能发送字节类型)
print('has send==>')
data=phone.recv(1024)#收消息,听电话
phone('has recv')
print(data.decode('utf-8'))
# 4.关机
phone.close() #挂电话