一.什么是socket？
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'')那也要有。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
