这篇文章中,提到了Master进程对信号的处理函数,其中有两个信号比较有意思。
SIGHUP:用来热更新(Reload)应用
SIGUSR2:用来在线升级(upgrade on the fly)gunicorn
 
下面来详细看一下:
 
SIGHUP
    Reload the configuration, start the new worker processes with a new configuration and gracefully shutdown older workers. 
SIGUP对应的信号处理函数是Arbiter.reload。简化后的核心代码如下:
     def reload(self):
old_address = self.cfg.address # reload conf,重新加载配置
self.app.reload()
self.setup(self.app) # reopen log files
self.log.reopen_files() # do we need to change listener ?,处理监听端口变化的情况
if old_address != self.cfg.address:
# close all listeners
[l.close() for l in self.LISTENERS]
# init new listeners
self.LISTENERS = create_sockets(self.cfg, self.log)
listeners_str = ",".join([str(l) for l in self.LISTENERS])
self.log.info("Listening at: %s", listeners_str) # spawn new workers,启动新的Worker(数量和类型来自新的配置)
for i in range(self.cfg.workers):
self.spawn_worker() # manage workers,这里会kill掉原来的Worker
self.manage_workers()
  在上面的引用中提到,会“优雅”(graceful)地kill掉老的worker进程。实现也很简单,Arbiter为每一个fork出的worker进程设置一个自增的“worker_age”,worker中这个属性越小,表明这个worker越老。在manage_workers中,如果已经启动的worker进程数量大于配置中的数量,那么会kill掉比较老的worker进程。代码如下
     def manage_workers(self):
"""\
Maintain the number of workers by spawning or killing
as required.
"""
if len(self.WORKERS.keys()) < self.num_workers:
self.spawn_workers() workers = self.WORKERS.items()
workers = sorted(workers, key=lambda w: w[1].age) # 按worker的age顺序排序
while len(workers) > self.num_workers: # num_workers是配置的worker数量
(pid, _) = workers.pop(0)
self.kill_worker(pid, signal.SIGTERM)
SIGUSR2
Upgrade the Gunicorn on the fly. A separate TERM signal should be used to kill the old process.
  对应的信号处理函数是Arbiter.reexec,该函数会重新fork出新的master-workers进程,但不会影响到原来的master,worker进程,所以上面提到需要将原来的进程kill掉。
     def reexec(self):
"""\
Relaunch the master and workers.
"""
if self.reexec_pid != 0:
self.log.warning("USR2 signal ignored. Child exists.")
return if self.master_pid != 0:
self.log.warning("USR2 signal ignored. Parent exists")
return master_pid = os.getpid()
self.reexec_pid = os.fork()
if self.reexec_pid != 0:
return self.cfg.pre_exec(self) environ = self.cfg.env_orig.copy()
fds = [l.fileno() for l in self.LISTENERS]
environ['GUNICORN_FD'] = ",".join([str(fd) for fd in fds]) # 设置了一些环境变量,用来区分是正常启动gunicorn还是通过fork重新启动。
environ['GUNICORN_PID'] = str(master_pid) os.chdir(self.START_CTX['cwd']) # exec the process using the original environnement
os.execvpe(self.START_CTX[0], self.START_CTX['args'], environ)
下面做一下实验,两个终端,1号终端运行代码,2号终端发送信号。
step1
1号终端启动gunirorn: gunicorn -w 2 gunicorn_app:app ,
2号终端查看python进程: ps -ef | grep python,
 
1号终端输出
[2017-01-19 15:21:23 +0000] [6166] [INFO] Starting gunicorn 19.6.0
[2017-01-19 15:21:23 +0000] [6166] [INFO] Listening at: http://127.0.0.1:8000 (6166)
[2017-01-19 15:21:23 +0000] [6166] [INFO] Using worker: sync
[2017-01-19 15:21:23 +0000] [6171] [INFO] Booting worker with pid: 6171
[2017-01-19 15:21:23 +0000] [6172] [INFO] Booting worker with pid: 6172
 
2号终端输出
hzliumi+  6166  5721  0 15:21 pts/0    00:00:00 /usr/bin/python /usr/local/bin/gunicorn -w 2 gunicorn_app:app
hzliumi+  6171  6166  0 15:21 pts/0    00:00:00 /usr/bin/python /usr/local/bin/gunicorn -w 2 gunicorn_app:app
hzliumi+  6172  6166  0 15:21 pts/0    00:00:00 /usr/bin/python /usr/local/bin/gunicorn -w 2 gunicorn_app:app
 
可以看到,master进程的PID是6166,然后两个worker进程的pid分别是6171、6172. 下面需要用到master进程的PID
 
step2
2号终端发送信号:kill -SIGUSR2 6166 , 然后查看python进程
 
1号终端追加输出
[2017-01-19 15:27:08 +0000] [6166] [INFO] Handling signal: usr2
[2017-01-19 15:27:08 +0000] [6629] [INFO] Starting gunicorn 19.6.0
[2017-01-19 15:27:08 +0000] [6629] [INFO] Listening at: http://127.0.0.1:8000 (6629)
[2017-01-19 15:27:08 +0000] [6629] [INFO] Using worker: sync
[2017-01-19 15:27:08 +0000] [6634] [INFO] Booting worker with pid: 6634
[2017-01-19 15:27:08 +0000] [6635] [INFO] Booting worker with pid: 6635
 
2号终端输出
hzliumi+  6166  5721  0 15:21 pts/0    00:00:00 /usr/bin/python /usr/local/bin/gunicorn -w 2 gunicorn_app:app
hzliumi+  6171  6166  0 15:21 pts/0    00:00:00 /usr/bin/python /usr/local/bin/gunicorn -w 2 gunicorn_app:app
hzliumi+  6172  6166  0 15:21 pts/0    00:00:00 /usr/bin/python /usr/local/bin/gunicorn -w 2 gunicorn_app:app
hzliumi+  6629  6166  3 15:27 pts/0    00:00:00 /usr/bin/python /usr/local/bin/gunicorn -w 2 gunicorn_app:app
hzliumi+  6634  6629  0 15:27 pts/0    00:00:00 /usr/bin/python /usr/local/bin/gunicorn -w 2 gunicorn_app:app
hzliumi+  6635  6629  0 15:27 pts/0    00:00:00 /usr/bin/python /usr/local/bin/gunicorn -w 2 gunicorn_app:app
 
从1号终端可以看出,基本是重新启动了gunicorn,不过从2号终端输出可以看到,新的master进程(pid 6629)是老的master进程(pid 6166)的子进程
 
step3
    2号终端发送信号:kill -SIGTERM 6166 , 稍等几秒后查看python进程:
 
1号终端追加输出
[2017-01-19 15:29:42 +0000] [6166] [INFO] Handling signal: term
[2017-01-19 15:29:42 +0000] [6171] [INFO] Worker exiting (pid: 6171)
[2017-01-19 15:29:42 +0000] [6172] [INFO] Worker exiting (pid: 6172)
[2017-01-19 15:29:42 +0000] [6166] [INFO] Shutting down: Master
[2017-01-19 15:29:42 +0000] [6629] [INFO] Master has been promoted.
 
2号终端输出
hzliumi+  6629     1  0 15:27 pts/0    00:00:00 /usr/bin/python /usr/local/bin/gunicorn -w 2 gunicorn_app:app
hzliumi+  6634  6629  0 15:27 pts/0    00:00:00 /usr/bin/python /usr/local/bin/gunicorn -w 2 gunicorn_app:app
hzliumi+  6635  6629  0 15:27 pts/0    00:00:00 /usr/bin/python /usr/local/bin/gunicorn -w 2 gunicorn_app:app
 
可以看到,老的master进程(6166)及其fork出的worker子进程(pid分别是6171、6172)已经被kill掉了
 
 
 
references:

最新文章

  1. C# webBrowser控件禁用alert,confirm之类的弹窗解决方案
  2. ROS学习(三)—— ROS文件系统
  3. 树莓派Odroid等卡片式电脑上搭建NAS教程系列6-miniDLNA
  4. SpringMvc的创建流程以及2种加载配置文件的方式
  5. SqlServer 笔记二 获取汉字的拼音首字母
  6. 网页细分图结果分析(Web Page Diagnostics)
  7. poj1785 Binary Search Heap Construction
  8. phonegap 附件下载及打开附件
  9. PHP之图形处理
  10. dom4j中对xml的查增
  11. php unset 数组陷阱
  12. 2015 ACM/ICPC Asia Regional Shenyang Online
  13. Hadoop之HDFS原理及文件上传下载源码分析(上)
  14. 【原创开源】网络版二代双通道示波器开源发布,支持电脑,手机和Pad等各种OS平台访问
  15. unity 中UGUI制作滚动条视图效果(按钮)
  16. Nginx代理与负载均衡
  17. [NIO-4]选择器
  18. spring重要知识点总结
  19. 微信小程序 scroll-view 实现锚点跳转
  20. 图解Fiddler如何抓取Android数据包

热门文章

  1. python进阶------进程线程(一)
  2. 移动端自适应rem 布局篇
  3. flask + Python3 实现的的API自动化测试平台---- IAPTest接口测试平台
  4. 【魅族Pro7】——BootStrap/JQuery/Canvas/PHP/MySQL/Ajax爬坑之项目总结(一)
  5. 理解MVC入门基础原理
  6. selenium 执行js,实现滚动条
  7. python_day05(去爬登录的豆瓣)
  8. J2SE-反射
  9. 问题记录-运行Tomcat,项目程序没有响应
  10. 随机生成N个字符(包含数字和字母)