标签:
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 框架
?是一个完全时间驱动的网络框架,允许使用和开发完全异步的网络应用程序和协议
标签:
原文地址:http://www.cnblogs.com/ohmydenzi/p/5617840.html