Python-socket

网络上的两个程序通过一个双向的通信连接实现数据的交换，这个连接的一端称为一个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())

Python-socket

socket.socket（）

套接字对象内置方法

操作实例

推荐阅读更多精彩内容