网络编程socket-SocketServer

Posted 2020-07-30 ohmydenzi

16章 网络编程
？应该是讲网络之间如何编程来进行通信的章节

16.1.1 客户端/服务器架构
？客户端请求访问，服务器端监听请求，处理请求，进行相应的模式
16.1.2 客户端/服务器编程
？服务器端：创建通讯端点，以用来监听。并将自身位置确定，既URL
  客户端：创建通讯端点，建立到服务器的连接

16.2  套接字：通讯断点
？是一种通讯必需的网络数据结构，就像电话接口，它是一种数据接口
套接字地址：套接字要有主机地址和端口（0-65535）
套接字类型：
面向连接：通信前要建立一条连接：实现的协议时TCP
无连接：实现的协议时UDP
它们这些套接字都是使用IP协议来在网络中寻找主机。

16.3 使用python来实现网络编程通信
16.3.1 socket()模块
？socket.socket()函数可以创建套接字
分别建立TCP/IP，UDP/IP的套接字
tcpSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 第一个是家族协议，它们都是网络的。第二个是面向类型
udpSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
16.3.2 套接字方法
？创建套接字后，要用它具有的方法来进行通信
16.3.3 创建一个TCP服务器
思路：创建套接字---绑定套接字到一个本地地址---监听连接---无限循环接听TCP客户端请求（接收到后会返回客户端套接字）---接受TCP数据---发送TCP数据---关闭子套接字---关闭服务器套接字
from socket import *
from time import ctime

HOST = ‘‘ # 表示可以绑定任何有效地址
PORT = 2157
BUFSIZ = 1024 # 关键字，大小为1k
ADR= (HOST, PORT)

tcpSerSock = socket(AF_INET, SOCK_STREAM) # 创建基于网络的、TCP服务器套接字
tcpSerSock.bind(ADR)
tcpSerSock.listen(5) # 只允许5个连接同时

while True: # 无限循环接听
    print ‘waiting for connecttion....‘
    tcpCliSock, addr = tcpSerSock.accept() # 接收，并将客户端套接字、客户端地址保存
    print ‘...conneted from:‘, addr

    while True:
        data = tcpCliSock.recv(BUFSIZ) # 读取缓冲区的数据
        if not data:
            break
        tcpCliSock.send(‘{0} {1}‘ .format(ctime(), data)) #发送给客户端信息
    tcpCliSock.close()
tcpSerSock.close()

16.3.4 创建TCP客户端
思路：创建客户端套接字---进行连接---发送数据（发送为空就退出）---从缓冲区接收数据（接收失败就退出）---关闭客户端套接字
from socket import *

HOST = ‘localhost‘
PORT = 21567
BUFSIZ = 1024
ADDR = (HOST, PORT)

tcpCliSock = socket(AF_INET, SOCK_STREAM)
tcpCliSock.connect(ADDR)

while True:
    data = raw_input(‘>‘)
    if not data:
        break
    tcpCliSock.send(data)
    data = tcpCliSock.recv(BUFSIZ)
    if not data:
        break
    print data
tcpCliSock.close()

16.3.6 创建一个UDP服务器
思路：创建套接字---绑定套接字到一个本地地址--接收数据---发送数据
from socket import *
from time import ctime

HOST = ‘‘ # 表示可以绑定任何有效地址
PORT = 2157
BUFSIZ = 1024 # 关键字，大小为1k
ADR= (HOST, PORT)

udpSerSock = socket(AF_INET, SOCK_DGRAM)
udpSerSock.bind(ADR)

while True:
    print ‘waiting for message...‘
    data, addr = udpSerSock.recvfrom(BUFSIZ)
    udpSerSock.sendto(‘{0} {1}‘ .format(ctime(), data), addr)
    print ‘...received from and returned to:‘, addr
udpSerSock.close()

16.3.7 创建一个UDp客户端
思路：创建客户端套接字---发送数据---接收数据
from socket import *
from time import ctime

HOST = ‘localhost‘ # 表示可以绑定任何有效地址
PORT = 2157
BUFSIZ = 1024 # 关键字，大小为1k
ADDR= (HOST, PORT)

udpCliSock = socket(AF_INET, SOCK_DGRAM)

while True:
    data = raw_input(‘>‘)
    if not data:
        break
    udpCliSock.sendto(data, ADDR)
    data, ADDR = udpCliSock.recvfrom(BUFSIZ)
    if not data:
        break
    print data
udpCliSock.close()

16.4 SocketServer 模块
？是标准库中用于简化实现网络客户端与服务器所需的大量样版代码，将很多需要的代码封装好

164.1 创建一个基于SocketServer 的TCP服务器
思路：先继承StreamRequestHandler创建请求处理类，重写handle函数---调用TCPServer使用参数“请求处理类”生成TCP服务器---服务器无限循环
from SocketServer import (TCPServer as TCP, StreamRequestHandler as SRH)
from time import ctime

HOST = ‘‘
PORT = 21567
ADDR = (HOST, PORT)

class MyRequestHandler(SRH): #  定义继承StreamRequestHandler的请求类，重写handle函数（默认是pass）
    def handle(self):
        print ‘...connected from:‘, self.client_address
        self.wfile.write(‘{0} {1}‘ .format(ctime(), self.rfile.readline()))  # 分别读，写
tcpServ = TCP(ADDR, MyRequestHandler)  # 调用TCPServer要求参数addr和请求处理类
print ‘waiting for connection...‘
tcpServ.serve_forever()  # 这个服务器进入无限循环

16.4.2 创建一个基于SocketServer的TCP客户端
思路：创建客户端套接字---发送数据---接收数据---关闭套接字
from socket import *

HOST = ‘localhost‘
PORT = 21567
BUFSIZ = 1024
ADDR = (HOST, PORT)

while True:
    tcpCliSock = socket(AF_INET, SOCK_STREAM)  # 与之前的区别在这里，SocketServer的请求处理器的默认行为是接受连接，得到请求，就关闭连接，所以要每次都要创建一个套接字
    tcpCliSock.connect(ADDR)
    data = raw_input(‘>‘)
    if not data:
        break
    tcpCliSock.send(‘%s\r\n‘ % data)
    data = tcpCliSock.recv(BUFSIZ)
    if not data:
        break
    print data.strip()
    tcpCliSock.close()

16.5 Twisted 框架
？是一个完全时间驱动的网络框架，允许使用和开发完全异步的网络应用程序和协议