一.什么是socket?
创新互联公司是一家从事企业网站建设、做网站、成都做网站、行业门户网站建设、网页设计制作的专业网站设计公司,拥有经验丰富的网站建设工程师和网页设计人员,具备各种规模与类型网站建设的实力,在网站建设领域树立了自己独特的设计风格。自公司成立以来曾独立设计制作的站点上1000+。socket就是为了实现C/S架构而生的,socket位于应用层和传输层之间,是传输层和应用层之间的一组接口,它把复杂的TCP/IP协议族隐藏在Socket接口后面,对用户来说,一组简单的接口就是全部,让Socket去组织数据,以符合指定的协议,所以,我们无需深入理解tcp/udp协议,socket已经为我们封装好了,我们只需要遵循socket的规定去编程,写出的程序自然就是遵循tcp/udp标准的。
也有人将socket说成ip+port,ip是用来标识互联网中的一台主机的位置,而port是用来标识这台机器上的一个应用程序,ip地址是配置到网卡上的,而port是应用程序开启的,ip与port的绑定就标识了互联网中独一无二的一个应用程序。
补充:有人会把socket和程序的pid弄混,程序的pid是同一台机器上不同进程或者线程的标识。
二.socket种类。
基于文件型套接字。
AF_UNIX:基于文件型的套接字,就是通过底层的文件系统来取数据,两个套接字进程运行在同一台机器,可以通过访问同一个文件系统来实现两个程序之间的通信。
基于网络型套接字。
三.socket工作流程。
tcp服务端建立连接流程:
socket()实例化出一个套接字对象→bind()绑定ip地址和端口→listen()开始监听之前绑定的ip地址和端口→accept()开始被动接收tcp客户端发来的连接,会一直等连接的到来(如果没有连接,就会一直等,直到有客户端连过来。
tcp客户端建立连接流程:
socket()客户端也初始化一个套接字对象→connect()主动去连接服务端(主动初始化与tcp服务器的连接)如果连接成功,客户端和服务器之间就可以互相收发数据了。(其实connect就相当于去回应服务端的accept,服务端的accept一直在等待客户端去connect)
客户端发送数据请求,服务器端接收请求并处理请求,然后把回应数据发送给客户端,客户端读取数据,最后关闭连接,一次交互结束。
四.socket模块的用法。
import socket
socket.socket(socket_family,socket_type,protocal=0)
socket_family 可以是 AF_UNIX 或 AF_INET。socket_type 可以是 SOCK_STREAM 或 SOCK_DGRAM。protocol 一般不填,默认值为 0。
获取tcp/ip套接字
tcpSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
获取udp/ip套接字
udpSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
由于 socket 模块中有太多的属性。我们在这里破例使用了'from module import *'语句。使用 'from socket import *',我们就把 socket 模块里的所有属性都带到我们的命名空间里了,这样能 大幅减短我们的代码。
例如tcpSock = socket(AF_INET, SOCK_STREAM)
服务端常用专属套接字方法:
s.bind():绑定(主机,端口号)到套接字。
s.listen():开始进行tcp监听。#listen方法中可以指定一个backlog参数,这个参数用于设置tcp连接池的大小(关于tcp连接池和三次握手的知识后面会做补充。)
s.accept():被动接受TCP客户的连接,(阻塞式)等待连接的到来。
客户端常用专属套接字方法:
s.connect():主动初始化TCP服务器连接
s.connect_ex() : connect()函数的扩展版本,出错时返回出错码,而不是抛出异常。
客户端和服务端共同具有的常用套接字方法:
s.recv():接收tcp数据。#需要指定每次收多少字节。
s.send(): 发送tcp数据,#发送TCP数据(send在待发送数据量大于对端缓存区剩余空间时,数据丢失,不会发完)
s.sendall(): 发送tcp数据,发送完整的TCP数据(本质就是循环调用send,sendall在待发送数据量大于对端缓存区剩余空间时,数据不丢失,循环调用send直到发完)(个人分析,本质上是调用了循环)
s.recvfrom():接收UDP数据
s.sendto() : 发送UDP数据
s.getpeername() : 连接到当前套接字的远端的地址
s.getsockname() : 当前套接字的地址
s.getsockopt() :返回指定套接字的参数
s.setsockopt() : 设置指定套接字的参数
s.close() :关闭套接字
五.socket用法示例。
服务端:
#!/usr/bin/python2.7
# -*- coding:utf-8 -*-
import socket
address_and_port = ('127.0.0.1',8888)
s1 = socket.socket(family=socket.AF_INET,type=socket.SOCK_STREAM)
s1.bind(address_and_port)
s1.listen(3)
conn,addr = s1.accept() #执行了socket的accept方法后,开始阻塞,等待客户端的连接.
#执行了accept方法后,会返回一个元祖,这个元祖里面包含了一个客户端的连接对象,还有客户端的ip地址和端口.
while True:
data = conn.recv(1024) #用于接收tcp数据,后面的1024表示,recv一次最多可以接收1024字节.(执行到recv,如果对端没有发来数据,或者内容为空,程序会阻塞住,不继续向下执行。)
print data
conn.send(data.upper())
conn.close() #关闭与客户端的连接
s1.close() #关闭服务端套接字连接
客户端:
#!/usr/bin/python2.7
# -*- coding:utf-8 -*-
import socket
s1 = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s1.connect(('127.0.0.1',8888))
while True:
msg = raw_input(">>>").strip()
s1.send(msg.encode(('utf-8')))
print "客户端已发送数据!"
data = s1.recv(1024)
print data
#上面两个代码,可以简单理解下socket的工作流程。
六.解决sockt 通信客户端断开服务端崩溃等问题的解决方法(连接循环,通信循环,以及异常捕捉)
服务端:
#!/usr/bin/python2.7
# -*- coding:utf-8 -*-
import socket
address_and_port = ('127.0.0.1',8888)
s1 = socket.socket(family=socket.AF_INET,type=socket.SOCK_STREAM)
s1.bind(address_and_port)
s1.listen(3)
while True: #此处问连接循环,会循环等连接。
conn,addr = s1.accept() #执行了socket的accept方法后,开始阻塞,等待客户端的连接.
#执行了accept方法后,会返回一个元祖,这个元祖里面包含了一个客户端的连接对象,还有客户端的ip地址和端口.
while True: #数据传输循环
try: #防止客户端断开导致的服务断抛异常。
data = conn.recv(1024) #用于接收tcp数据,后面的1024表示,recv一次最多可以接收1024字节.
if not data:
break
print data
conn.send(data.upper())
except Exception:
break
conn.close() #关闭与客户端的连接
s1.close() #关闭服务端套接字连接
客户端:
#!/usr/bin/python2.7
# -*- coding:utf-8 -*-
import socket
s1 = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s1.connect(('127.0.0.1',8888))
while True:
msg = raw_input(">>>").strip()
if not msg: #防止客户端发送空数据
continue
s1.send(msg.encode(('utf-8')))
print "客户端已发送数据!"
data = s1.recv(1024)
print data
s1.close()
#以上是防止服务端崩溃的一些解决方法。
七.关于udp套接字。
服务端大概操作流程:
ss = socket() #创建一个服务器的套接字
ss.bind() #绑定服务器套接字
inf_loop: #服务器无限循环
cs = ss.recvfrom()/ss.sendto() # 对话(接收与发送)
ss.close() # 关闭服务器套接字
客户端大概的操作流程:
cs = socket() # 创建客户套接字
comm_loop: # 通讯循环
cs.sendto()/cs.recvfrom() # 对话(发送/接收)
cs.close() # 关闭客户套接字
下面是udp套接字的一个简单的示例:
示例1:
服务端:
import socket
udp_server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
udp_server.bind(('127.0.0.1',8888))
while True:
msg,addr = udp_server.recvfrom(1024)
print msg ,addr
udp_server.sendto(msg.upper(),addr)
客户端:
import socket
udp_client = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
while True:
msg = raw_input(">>:").strip()
if not msg:
continue
udp_client.sendto(msg.encode('utf-8'),("127.0.0.1",8888))
back_msg,addr = udp_client.recvfrom(1024)
print back_msg.decode('utf-8') ,addr
八.关于tcp套接字和udp套接字你需要知道的。
首先有几点必须明确!
1.1 所有的收发消息,都是在操作自己的tcp/udp缓冲区,发消息是将数据发送到自己的缓冲区中,收消息同样也是从缓冲区中收取。
1.2 tcp 使用send发消息,使用recv收消息
1.3udp 使用sendto发消息,使用recvfrom收消息
tcp与udp
2.1 tcp是基于流的,udp是基于报的
2.2 使用send发送数据流的时候,若数据流为空,那么tcp buffer(缓冲区)也为空,操作系统不会控制tcp发包。
sendinto(bytes_data,ip_port):发送数据报,bytes_data为空,还有ip_port,所有即便是发送空的bytes_data,数据报其实也不是空的,自己这端的缓冲区收到内容,操作系统就会控制udp协议发包。
3.关于tcp的补充
tcp基于链接通信:
基于链接,则需要listen(backlog),指定半连接池的大小
基于链接,必须先运行的服务端,然后客户端发起链接请求
对于mac系统:如果一端断开了链接,那另外一端的链接也跟着完蛋recv将不会阻塞,收到的是空(解 决方法是:服务端在收消息后加上if判断,空消息就break掉通信循环)
对于windows/linux系统:如果一端断开了链接,那另外一端的链接也跟着完蛋recv将不会阻塞,收到 的是空(解决方法是:服务端通信循环内加异常处理,捕捉到异常后就break掉通讯循环)
udp通信。
无链接,因而无需listen(backlog),更加没有什么连接池之说了
无链接,udp的sendinto不用管是否有一个正在运行的服务端,可以己端一个劲的发消息,只不过数据丢失
recvfrom收的数据小于sendinto发送的数据时,在mac和linux系统上数据直接丢失,在windows系统上发送的比接收的大直接报错
只有sendinto发送数据没有recvfrom收数据,数据丢失。
注意:
1.你单独运行上面的udp的客户端,你发现并不会报错,相反tcp却会报错,因为udp协议只负责把包发出去,对方收不收,我根本不管,而tcp是基于链接的,必须有一个服务端先运行着,客户端去跟服务端建立链接然后依托于链接才能传递消息,任何一方试图把链接摧毁都会导致对方程序的崩溃。
2.上面的udp程序,你注释任何一条客户端的sendinto,服务端都会卡住,为什么?因为服务端有几个recvfrom就要对应几个sendinto,哪怕是sendinto(b'')那也要有。
另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。