python网络平台_python学习(九) 网络编程学习--简易网站服务器

python `网络编程`和其他语言都是一样的,服务器这块步骤为:

`1. 创建套接字`

`2. 绑定地址`

`3. 监听该描述符的所有请求`

`4. 有新的请求到了调用accept处理请求`

Python Web服务器网关接口(Python Web Server Gateway Interface,简称`“WSGI”`),可以保证同一个服务器响应不同应用框架的请求,WSGI的出现,让开发者可以将网络框架与网络服务器的选择分隔开来,例如,你可以使用Gunicorn或Nginx/uWSGI或Waitress服务器来运行Django、Flask或Pyramid应用。下面简单实现一个机遇WSGI协议的服务器。

import socket

from io import StringIO

import sys

class WSGIServer(object):

address_family = socket.AF_INET

socket_type = socket.SOCK_STREAM

request_queue_size = 1

def __init__(self, server_address):

# Create a listening socket

self.listen_socket = listen_socket = socket.socket(

self.address_family,

self.socket_type

)

# Allow to reuse the same address

listen_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

# Bind

listen_socket.bind(server_address)

# Activate

listen_socket.listen(self.request_queue_size)

# Get server host name and port

host, port = self.listen_socket.getsockname()[:2]

self.server_name = socket.getfqdn(host)

self.server_port = port

# Return headers set by Web framework/Web application

self.headers_set = []

定义了一个WSGIServer类,并且在类的init函数完成了套接字的创建、绑定、监听等。

下面实现WSGIServer的轮询检测新的连接并处理连接:

defset_app(self, application):

self.application=applicationdefserve_forever(self):

listen_socket=self.listen_socketwhileTrue:#New client connection

self.client_connection, client_address =listen_socket.accept()#Handle one request and close the client connection. Then#loop over to wait for another client connection

self.handle_one_request()

实现处理请求的函数

defhandle_one_request(self):

self.request_data= request_data = self.client_connection.recv(1024)#Print formatted request data a la 'curl -v'

print(''.join('< {line}\n'.format(line=line)for line inrequest_data.splitlines()

))

self.parse_request(request_data)#Construct environment dictionary using request data

env =self.get_environ()#It's time to call our application callable and get#back a result that will become HTTP response body

result =self.application(env, self.start_response)#Construct a response and send it back to the client

self.finish_response(result)

解析请求

defparse_request(self, text):

request_line=text.splitlines()[0]

request_line= request_line.rstrip('\r\n')#Break down the request line into components

(self.request_method, #GET

self.path, #/hello

self.request_version #HTTP/1.1

) = request_line.split()

返回当前服务器wsgi版本等信息

defget_environ(self):

env={}

env['wsgi.version'] = (1, 0)

env['wsgi.url_scheme'] = 'http'env['wsgi.input'] =StringIO.StringIO(self.request_data)

env['wsgi.errors'] =sys.stderr

env['wsgi.multithread'] =False

env['wsgi.multiprocess'] =False

env['wsgi.run_once'] =False#Required CGI variables

env['REQUEST_METHOD'] = self.request_method #GET

env['PATH_INFO'] = self.path #/hello

env['SERVER_NAME'] = self.server_name #localhost

env['SERVER_PORT'] = str(self.server_port) #8888

return env

填写app所需的回调函数

def start_response(self, status, response_headers, exc_info=None):#Add necessary server headers

server_headers =[

('Date', 'Tue, 31 Mar 2015 12:54:48 GMT'),

('Server', 'WSGIServer 0.2'),

]

self.headers_set= [status, response_headers +server_headers]#To adhere to WSGI specification the start_response must return

#a 'write' callable. We simplicity's sake we'll ignore that detail

#for now.

#return self.finish_response

发送数据并且关闭连接

deffinish_response(self, result):try:

status, response_headers=self.headers_set

response= 'HTTP/1.1 {status}\r\n'.format(status=status)for header inresponse_headers:

response+= '{0}: {1}\r\n'.format(*header)

response+= '\r\n'

for data inresult:

response+=data#Print formatted response data a la 'curl -v'

print(''.join('> {line}\n'.format(line=line)for line inresponse.splitlines()

))

self.client_connection.sendall(response)finally:

self.client_connection.close()

主函数和参数解析,创建服务器

SERVER_ADDRESS = (HOST, PORT) = '', 8888

defmake_server(server_address, application):

server=WSGIServer(server_address)

server.set_app(application)returnserverif __name__ == '__main__':if len(sys.argv) < 2:

sys.exit('Provide a WSGI application object as module:callable')

app_path= sys.argv[1]

module, application= app_path.split(':')

module= __import__(module)

application=getattr(module, application)

httpd=make_server(SERVER_ADDRESS, application)print('WSGIServer: Serving HTTP on port {port} ...\n'.format(port=PORT))

httpd.serve_forever()

将上面的文件保存为webserver.py

下面搭建虚拟环境,并且安装Pyramid、Flask和Django等框架开发的网络应用。

$ [sudo] pip install virtualenv

$ mkdir~/envs

$ virtualenv~/envs/lsbaws/$ cd~/envs/lsbaws/$ ls

bin include lib

$ source bin/activate

(lsbaws) $ pip install pyramid

(lsbaws) $ pip install flask

(lsbaws) $ pip install django

编写pyramidapp.py,主要是调用pyramidapp接口生成app

from pyramid.config importConfiguratorfrom pyramid.response importResponsedefhello_world(request):returnResponse('Hello world from Pyramid!\n',

content_type='text/plain',

)

config=Configurator()

config.add_route('hello', '/hello')

config.add_view(hello_world, route_name='hello')

app= config.make_wsgi_app()

可以通过自己开发的网络服务器来启动上面的Pyramid应用。

`python webserver.py pyramidapp:app`

a350108ee540450ed9195899cf112a7a.png

ec65a71711efc21f4af424f684a5b4c5.png

同样可以创建Flask应用

from flask import Flask

from flask import Response

flask_app = Flask('flaskapp')

@flask_app.route('/hello')

def hello_world():

return Response(

'Hello world from Flask!\n',

mimetype='text/plain'

)

app = flask_app.wsgi_app

3361e277ab43e29e82c3c368b75a73f8.png

上述代码的工作原理:

`1 网络框架提供一个命名为application的可调用对象`。

`2 服务器每次从HTTP客户端接收请求之后,调用application。它会向可调用对象传递一个名叫environ的字典作为参数,其中包含了WSGI/CGI的诸多变量,以及一个名为start_response的可调用对象`。

`3 框架/应用生成HTTP状态码以及HTTP响应报头(HTTP response headers),然后将二者传递至start_response,等待服务器保存。此外,框架/应用还将返回响应的正文。

服务器将状态码、响应报头和响应正文组合成HTTP响应,并返回给客户端`。

可以采用多进程的方式处理多个客户端请求,将上述代码稍作修改

import errno

import os

import signal

import socket

SERVER_ADDRESS = (HOST, PORT) = '', 8888

REQUEST_QUEUE_SIZE = 1024

def grim_reaper(signum, frame):

while True:

try:

pid, status = os.waitpid(

-1, # Wait for any child process

os.WNOHANG # Do not block and return EWOULDBLOCK error

)

except OSError:

return

if pid == 0: # no more zombies

return

def handle_request(client_connection):

request = client_connection.recv(1024)

print(request.decode())

http_response = b"""\

HTTP/1.1 200 OK

Hello, World!

"""

client_connection.sendall(http_response)

def serve_forever():

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

listen_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

listen_socket.bind(SERVER_ADDRESS)

listen_socket.listen(REQUEST_QUEUE_SIZE)

print('Serving HTTP on port {port} ...'.format(port=PORT))

signal.signal(signal.SIGCHLD, grim_reaper)

while True:

try:

client_connection, client_address = listen_socket.accept()

except IOError as e:

code, msg = e.args

# restart 'accept' if it was interrupted

if code == errno.EINTR:

continue

else:

raise

pid = os.fork()

if pid == 0: # child

listen_socket.close() # close child copy

handle_request(client_connection)

client_connection.close()

os._exit(0)

else: # parent

client_connection.close() # close parent copy and loop over

if __name__ == '__main__':

serve_forever()

grim_reaper 函数为捕捉子进程退出的回调函数,父进程等待所有子进程退出后再退出,避免僵尸进程。由于子进程退出父进程捕获到消息,调用grim_reaper处理,由于父进程之前阻塞在accept上,捕获子进程销毁消息后,父进程accept失败,所以增加了errno.EINTR错误判断,如果是由于信号中断导致accept失败,就让父进程继续调用accept即可。

aa6bf746036dfe5887a51bf407880af9.png

谢谢关注我的微信公众平台:

25dab2d57b567a5bc38df51ea7d1f334.png

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/572827.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

LeetCode 451. Sort Characters By Frequency

Mediocre solution is O(nlgn) by using max-heap - but, remember bucket sort? it is O(n)转载于:https://www.cnblogs.com/tonix/p/6269000.html

rabbit和mysql事务_分布式事务原理及SpringBoot整合RabbitMQ实现可靠事件,TCC事务模型及接口幂等性...

分布式事务我们知道在单数据库系统中&#xff0c;实现数据的一致性&#xff0c;通过数据库的事务来处理比较简单。在微服务或分布式系统中&#xff0c;各个独立的服务都会有自己的数据库&#xff0c;而不是在同一个数据库中&#xff0c;所以当一组事务(如商品交易中&#xff0c…

rhel Linux 网络配置

--网络配置 vi /etc/sysconfig/network-scripts/ifcfg-eth0 1)DHCPDEVICEeth0BOOTPROTOdhcpONBOOTyes2)静态IP DEVICEeth0 BOOTPROTOnone IPADDR192.168.0.22 NETMASK255.255.255.0GATEWAY192.168.0.254DNS11…

如何下载php-5.5.38.tar.gz_搭建PHP服务器php-5.3.28.tar.gz

构建PHP运行环境PHP所用的软件 &#xff1a;php-5.3.28.tar.gz优化模块 &#xff1a;ZendGuardLoader-php-5.3-linux-glibc23-x86_64.tar.gz(两者之间版本一样)准备工作&#xff1a;卸载RPM安装的PHP[rootlocalhost php]# rpm -e php php-cli php-ldap php-common php-mysql --…

004-全局应用程序类Global.asax

服务器对象&#xff1a;Request、Response、Server、Session、Application、Cookie //功能1&#xff1a;为服务器对象注册Start、End处理 protected void Application_Start(object sender, EventArgs e){} protected void Application_End(object sender, EventArgs e){} 管道…

mysql创建表的时候日期给个默认值_mysql 创建表时 日期字段默认值为当前时间...

mysql 创建表时 日期字段默认值为当前时间mysql version 5.1在mysql创建表的时候经常会遇到创建日期字段需要设置当前时间为默认值的时候&#xff0c;就如sqlserver2000一样&#xff0c;把默认值设为getdate()即可&#xff0c;我在网上查了N久都没有查到使用有效的方法&#xf…

Android onKeyDown、onKeyUp、dispatchKeyEvent的区别

1. onKeyDown、onKeyUp、dispatchKeyEvent的区别和使用场景 区别&#xff1a;   1.1 onKeyDown、onKeyUp是按键事件的回调接口&#xff08;冒泡式调用&#xff09;&#xff0c;dispatchKeyEvent是按键分发&#xff08;隧道式分发&#xff09; 1.2 onKeyDown接口的回调只…

python pandas 数据库_Python中pandas函数操作数据库

一&#xff1a;创建链接数据库引擎Pythonfrom sqlalchemy import create_engineengine create_engine(postgresql://user58.251.157.179:port/database,echo True)echo True &#xff0c;会显示在加载数据库所执行的SQL语句。12345fromsqlalchemyimportcreate_engineenginecr…

策略模式,工厂模式,单例模式编写身份证的验证算法

策略模式&#xff1a;它定义算法家族&#xff0c;分别封装起来&#xff0c;让他们之间互相替换&#xff0c;此模式让算法的变化&#xff0c;不会影响使用算法的客户。 1 /// <summary>2 /// 策略模式3 /// </summary>4 public interface IidCheck5 …

mysql引擎模式_mysql引擎,完整的见表语句,数据库模式, 常用数据类型,约束条件...

引擎show engines : 查看引擎innodb(默认引擎)&#xff1a;支持事务&#xff0c;行级锁&#xff0c;外键myisam:查询效率由于innodb,不需要支持事务&#xff0c;行级锁&#xff0c;外键&#xff0c;可以选用myisam来优化数据库mysql> create table t1(id int)engineinnodb;m…

testng连接MySQL_Selenium+TestNG实战-8-连接数据库方法去验证文章是否发布

原标题&#xff1a;SeleniumTestNG实战-8-连接数据库方法去验证文章是否发布记得之前群里&#xff0c;有人说举例一下连接数据库在Selenium自动化测试中的应用。本篇刚好来举例一个&#xff0c;前面我们都是通过发布后文章的详情页的标题来判断文章是否已经发布成功&#xff0c…

凸包 poj 1113

求一个多边形 拐弯的地方用圆弧补上 距离>l 求他的周长 求一个凸包的周长 加2*pi*l #include<stdio.h> #include<string.h> #include<algorithm> #include<vector> #include<stack> #include<math.h> using namespace std;#define MA…

武汉mysql ocp考点_MySQL OCP考试复习系列–开篇:了解MySQL考试

MySQL OCP考试复习系列–开篇&#xff1a;了解MySQL考试嗯&#xff0c;那个决定去考MySQL OCP了&#xff0c;事实上最近工作一直围绕着DB2&#xff0c;MySQL要去考的话需要好好的复习的啊。150分钟&#xff0c;100道多选&#xff0c;答对60道题可以通过&#xff0c;费用1077。L…

java文件服务器_JavaWeb项目架构之NFS文件服务器

NFS简介NFS(Network File System)即网络文件系统。主要功能&#xff1a;通过网络(局域网)让不同的主机系统之间可以共享文件或目录。主要用途&#xff1a;NFS网络文件系统一般被用来存储共享视频&#xff0c;图片&#xff0c;附件等静态资源文件。NFS存储服务无NFS文件共享存储…

【bzoj】3224: Tyvj 1728 普通平衡树

3224: Tyvj 1728 普通平衡树 Time Limit: 10 Sec Memory Limit: 128 MBSubmit: 10097 Solved: 4302[Submit][Status][Discuss]Description 您需要写一种数据结构&#xff08;可参考题目标题&#xff09;&#xff0c;来维护一些数&#xff0c;其中需要提供以下操作&#xff1a…

java 修改 referer_看好你的门-客户端传数据-用java修改referer

1、简单说明Referer、origin用来表明&#xff0c;浏览器向WEB服务器表明自己来自哪里。但是就它本身而言&#xff0c;并非完全安全。写一个例子&#xff0c;可以任意修改http信息头中的referer、origin2、准备&#xff1a;用httpClient4.0来具体实现3、Java修改http信息头refer…

table 样式详解

1.table 中css样式控制border 只能控制外边框&#xff0c;内边框需要写<table border"1"> 2.table 会自动撑大&#xff0c;即使td 设置了 width和height这与div 是不同的 3.只有一个table的时候 &#xff0c;高度自适应全屏 <style type"text/css"…

libsvm java 实例_LibSVM Java API调用示例程序

【实例简介】LibSVM Java API调用示例程序Eclipse 完整工程可以运行相关详情见http://blog.csdn.net/yangliuy/article/details/8041343#comments3行程序搞定SVM分类-用JAVA程序调用LibSVM API 最简单的示例欢迎关注我的博客blog.csdn.net/yangliuy【实例截图】【核心代码】326…

关于H3 BPM数据库如何实现排序取数据的问题

问题&#xff1a; 在打印模板中获取子表内容&#xff0c;可从数据库中取数据&#xff0c;而当前项目数据库里面数据按年度录入&#xff0c;但是只需要显示近3年的数据&#xff0c;插件如何实现排序取数据&#xff1f; 解决方法&#xff1a; 1、先直接写一个SQL语句&#xff0c;…

java 将pdf转换成word_java如何实现pdf转word?

Atitit pdf转文本 pdfutiljava -jar C:\Users\attilax\Pictures\pdfbox-app-2.0.9.jar ExtractText "C:\atibeks517\l4 doc v3 r7a ori exted\_0index\一种简单的基于字符形状的验证码识别技术.pdf" c:\logs\识别技术.pdf.txt转html-consolefalseSend text to consol…