Python-socket总结

发布时间：2019-09-18 07:24:14编辑：auto阅读（1911）

socket是什么

什么是socket所谓socket通常也称作"套接字"，用于描述IP地址和端口，是一个通信链的句柄。

应用程序通常通过"套接字"向网络发出请求或者应答网络请求。说白了就是一种通信机制。

列入你和移动客服咨询问题时，会有一个客服为你解决问题一样，就是你和客服间的相互通信

在socket里就是“发送”和“接收”这两个动作就是socket通信方式

socket.gethostname()     # 获取主机名

from socket import *     # 避免 socket.socket()

s=socket()

s.bind()         # 绑定地址到套接字

s.listen()       # 开始TCP监听

s.accept()       # 被动接受TCP客户端连接，等待连接的到来

s.connect()      # 主动初始化TCP服务器连接

s.connect_ex()   # connect()函数的扩展版本，出错时返回出错码，而不是跑出异常

s.recv()         # 接收TCP数据

s.send()         # 发送TCP数据

s.sendall()      # 完整发送TCP数据

s.recvfrom()     # 接收UDP数据

s.sendto()       # 发送UDP数据

s.getpeername()  # 连接到当前套接字的远端的地址(TCP连接)

s.getsockname()  # 当前套接字的地址

s.getsockopt() # 返回指定套接字的参数

s.setsockopt()   # 设置指定套接字的参数

s.close()        # 关闭套接字

s.setblocking()  # 设置套接字的阻塞与非阻塞模式

s.settimeout()   # 设置阻塞套接字操作的超时时间

s.gettimeout()   # 得到阻塞套接字操作的超时时间

s.filen0()       # 套接字的文件描述符

s.makefile()     # 创建一个与该套接字关联的文件对象

socket.AF_UNIX # 只能够用于单一的Unix系统进程间通信

socket.AF_INET # 服务器之间网络通信

socket.AF_INET6 # IPv6

socket.SOCK_STREAM  # 流式socket , for TCP

socket.SOCK_DGRAM  # 数据报式socket , for UDP

socket.SOCK_RAW      # 原始套接字，普通的套接字无法处理ICMP、IGMP等网络报文，而SOCK_RAW可以；其次，SOCK_RAW也可以处理特殊的IPv4报文；此外，利用原始套接字，可以通过IP_HDRINCL套接字选项由用户构造IP头。

socket.SOCK_RDM  # 是一种可靠的UDP形式，即保证交付数据报但不保证顺序。SOCK_RAM用来提供对原始协议的低级访问，在需要执行某些特殊操作时使用，如发送ICMP报文。SOCK_RAM通常仅限于高级用户或管理员运行的程序使用。

socket.SOCK_SEQPACKET # 可靠的连续数据包服务

基础讲解

    # 创建socket对象

    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

    # 监听端口

    sock.bind(('127.0.0.1',8001))

    # 开始监听，

    sock.listen(5)




    while True:

        # 阻塞，deng 。。。。

        # 直到有请求连接

        print '....'

        connection, address = sock.accept()

        # connection，代表客户端socket对象，

        # address，客户端IP地址

        #handle_request(connection)

        buf = connection.recv(1024)

        print buf

        connection.send("HTTP/1.1 200 OK\r\n\r\n")

        connection.send("Hello, World")

        connection.close()

#服务端

import socket 

HOST=''  #空代表0.0.0.0

PORT= 6666  #监听端口

s= socket.socket(socket.AF_INET,socket.SOCK_STREAM) 

s.bind((HOST,PORT)) 

s.listen(1) 

while True:

    conn,addr= s.accept()   

    print'Connected by', addr 

    while  True:

        data = conn.recv(1024) #接收1024字节数据

        if not data: break     #如果收不到客户端数据了（代表客户端断开了），就断开

        conn.sendall(data.upper())    #将收到的数据全变成大写再发给客户端 

    conn.close() #关闭此客户端的连接实例

#客户端

import socket 

HOST='' 

PORT= 6666  #监听端口

s= socket.socket(socket.AF_INET,socket.SOCK_STREAM) 

s.bind((HOST,PORT)) 

s.listen(1) 

while True:

    conn,addr= s.accept()   

    print'Connected by', addr 

    while  True:

        data = conn.recv(1024) #接收1024字节数据

        if not data: break     #如果收不到客户端数据了（代表客户端断开了），就断开

        conn.sendall(data.upper())    #将收到的数据全变成大写再发给客户端 

    conn.close() #关闭此客户端的连接实例

    服务端socket在使用bind方法之后调用listen方法去监听一个给定的 地址。然后，客户端socket就可以通过使 用 connect方法（connect方法所使用的地址参数与bind相同）去连接服务端。listen方法 要求一个参数，这个参数就是等待连接队列中所能包含的连接数。

    一旦服务端socket调用了listen方法，就进入了临听状态，然后通 常使用一个无限的循环：1、开始接受客房端的连接，这通过调用accept方法来实现。调用了这个方法后将处于阻塞状态（等待客户端发起连接）直到一个客 户端连接，连接后，accept返回形如(client,address)的一个元组，其中client是一个用于与客户端通信的 socket，address是客户端的形如xxx.xxx.xxx.xxx:xxx的地址；2、然后服务端处理客户端的请求；3、处理完成之后又调用 1。







#以上例子是单线程的只能一对一的服务，即服务端只能处理一个链接，想要处理多线程怎么办，不用急多线程的Python已给我们写好直接调用就好




socket服务端

#用于处理多线程的模块

    import SocketServer

    import os

    class MyTCP(SocketServer.BaseRequestHandler):

        def handle(self):

            while True:

                self.data=self.request.recv(1024).strip() #接受数据

                if self.data == 'quit' or not self.data:break #如果没有数据或为quit 退出

                cmd_data=os.popen(self.data).read() #将命令结果存为字符串

                if cmd_data == '':cmd_data= self.data + ': Command not found' #如果命令结果为空或命令返回为空

                self.request.sendall(cmd_data) #发送所有的数据

    if __name__ == '__main__':

        HOST,PORT = '127.0.0.1',6666 #绑定端口和ip

        server = SocketServer.ThreadingTCPServer((HOST,PORT),MyTCP) #将写的类加入多线程处理

        server.serve_forever() #循环启动

socket客户端

    import socket

    HOST='127.0.0.1'

    PORT=6666

    s=socket.socket(socket.AF_INET,socket.SOCK_STREAM) #服务期间的TCP通信

    s.connect((HOST,PORT)) #绑定端口和ip

    while True:

        while True: #如果命令为空继续输入

            cmd=raw_input('CMD:').strip()

            if cmd != '':break

        s.sendall(cmd) #发送所有数据

        data=s.recv(1024).split('\n') #以换行符分割接收的数据

        print 'cmd:'

        for line in data:print line #循环打印数据

    s.close() #关闭套接字




用SocketServer创建一个服务器需要三步：

1、通过子类化BaseRequestHandler类和覆盖它的handle()方法来创建一个请求处理器类，用于处理进来

的请求；
2、实例化服务类如TCPServer，并传递给它参数：服务器地址和请求处理器类；
3、调用服务实例对象的handle_request()或serve_forever()方法去处理请求。

关键字：