Socket 编程

Sock简介
TCP：可靠性数据连接
（1）校验码
（2）接收方反馈
（3）信息包附带序号

UPD:不可靠性的数据连接
 (1) 不需要花费时间建立和关闭连接
（2）偶尔丢失一两个消息包无所谓，但是TCP会严格检查
（3）UDP的限制是一个信息包不超过64KB的数据

TCP和UDP区别就是UDP不建立连接，只保证数据的完整性，数据传输快，但是不保证数据是否真的被接收，也不保证数据是只接收一次，也不保证次序。

服务端是用来给一个或者多个客户端提供服务的，当客户端发起请求，开始等待服务端的返回结果，服务端接收完请求以后，根据自己的逻辑进行处理请求，并返回个客户端，客户端接收到返回结果以后，关闭和服务端的连接。

最常于客户端和服务端有两种模式 c/s(mysql)模式和b/s模式（网站）




Socket 常用函数讲解
创建套接字
s=socket.socket(address family,socket type)
address family:
   socket.AF INET     默认ipv4
   socket.AF UNIX    只能用于单一的unix 系统间进行通信
socket type:
   socket.SOCK STREAM        流式 socket,TCP
   socket.SOCK DGRAM         数据报是socket UDP

绑定地址： bind(address)
address = ('0.0.0.0',8009)
s.bind(address) 或者s.bind(('0.0.0.0',8009))
address 必须是一个元组，容易错误，address = (host,port)
host : 服务器端ip,字符串类型，如果为 0.0.0.0 代表本机的任意一个ip
port : 服务器端提供的端口，整型 0-1024为系统保留

监听消息：
s.listen(badklog)
backlog 代表可以同时接受多少个socket连接

接受连接
conn,addr = s.accept()
接受连接变返回元组（conn, addr）期中conn是最新的套接字对象，每个新的连接就创建一个新的对象。 可以用来接受和发送数据，addr是客户端的地址。
发送数据：
s.send(string) 发送字符串到连接的套接字，可能未将指定内容全部发送
s.sendall(string) 内部递归调用send ，将所有内容发送出去，建议使用。

接收数据
data = s.recv(bufsize)
接收套接字数据，数据以字符串形式返回，bufsize指定最多接收的数据量，可以是1024,2048
如果不最多接收的数量有多少，可能几个字节，可能机M 一般通过循环接收。

通用：
s.close()                     关闭socket套接字
s.getsocketname()       获取套接字的名字
s.settimeout(timeout)  设置套接字超时时间，timeout为float 类型，单位为秒。
s.gettimeout （）        活动套接字超时时间
s.setblocking(flag)
flage  为bool值
setblocking(True)  相当于不设置超时时间一直阻塞在那里

s.fileno()
返回套接字的文件描述符（一个小整数）这对于select.select()是有用的。

下面以实际示例说明：

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time : 2017/12/29 22:11
# @Author : alvin
# @File : util.py
import socket

import time


class InitSocketTest(object):
    def __init__(self, host, port, type):
        self.host = host
        self.port = port
        self.address = (host, port)
        self.type = type
        self.s = None
        self.creatsocket()

    def creatsocket(self):
        if self.type.upper() == "TCP":
            self.s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        elif self.type.upper == "UDP":
            self.s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        else:
            print("you must input the InitSocket(type) is 'UDP|TCP' ")

class SocketServerTest(InitSocketTest):
    def __init__(self, host, port, type, backlog):
        self.backlog = backlog
        super(SocketServerTest, self).__init__(host, port, type)
        self.clientAddress = None

    def run(self):
        self.s.bind(self.address)
        self.s.listen(self.backlog)
        print("server starting…………")
        conn, self.clientAddress = self.s.accept()
        print("accept connect from {0}".format(self.clientAddress))
        for i in range(1, 10):
            conn.sendall("i = {0}".format(str(i)).encode("utf-8"))
        self.s.close()

class ClientSocketTest(InitSocketTest):
    def run(self):
        self.s.connect(self.address)
        stat = 1
        while 1:
            data = self.s.recv(2048)
            if len(data)>0:
                stat = 1
                print(data.decode("utf-8"))
            else:
                stat += 1
                time.sleep(1)
                if stat == 5:
                    break

客户端：

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time : 2017/12/29 22:47
# @Author : alvin
# @File : testclient.py
from test.sockettest.util import ClientSocketTest

if __name__ == '__main__':
    socketClient = ClientSocketTest(host="127.0.0.1", port=9999, type="tcp")
    socketClient.run()

服务器端：

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time : 2017/12/29 22:57
# @Author : alvin
# @File : testserver.py
from test.sockettest.util import SocketServerTest

if __name__ == '__main__':
    socketServer = SocketServerTest(host="0.0.0.0", port=9999, type="tcp", backlog=5)
    socketServer.run()

测试结果如下：
i = 1
i = 2
i = 3
i = 4
i = 5
i = 6
i = 7
i = 8
i = 9