实现线上高性能接口方案nginx负载tornado后端lua数据

本文涉及的产品
RDS AI 助手,专业版
RDS MySQL DuckDB 分析主实例,集群系列 4核8GB
RDS MySQL DuckDB 分析主实例,基础系列 4核8GB
简介:

101638437.jpg


最近实现了一个http的接口 ~ http的方式,访问结果为json

nginx做负载,web分离,url转发 ~

tornado做数据操作和异步调用lua的接口 ~

memcached做session的共享 (为啥不用redis做session,一方面是为了不和redis有kv冲突,服务器的中断冗余,更主要的方面是用redis存储session我没有做出来,郁闷呀。。。。)

redis做kv数据库和队列系统

后端的nginx lua是mysql的http方式的json展现接口



nginx 的配置大家都懂的,就是利用upstream负载。


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
worker_processes  4 ;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
error_log / var /log/nginx/error.log;
pid / var /run/nginx.pid;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
events {
     worker_connections  30000 ;
     useepoll;
}
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
http {
     charset utf- 8 ;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
     # Enumerate all the Tornado servers here
     upstream frontends {
         server  127.0 . 0.1 : 8000 ;
         server  127.0 . 0.1 : 8001 ;
         server  127.0 . 0.1 : 8002 ;
         server  127.0 . 0.1 : 8003 ;
     }
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
     include /path/to/nginx.mime.types;
     default_type application/octet-stream;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
     access_log / var /log/nginx/access.log;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
     keepalive_timeout  65 ;
     proxy_read_timeout  200 ;
     sendfile on;
     tcp_nopush on;
     tcp_nodelay on;
     gzip on;
     gzip_min_length  1000 ;
     gzip_proxied any;
     gzip_types text/plain text/css text/xml
                application/x-javascript application/xml
                application/atom+xml text/javascript;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
     # Only retry ifthere was a communication error, not a timeout
     # on the Tornado server (to avoid propagating  "queries of death"
     # to all frontends)
     proxy_next_upstream error;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
     server {
         listen  80 ;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
         location ^~ / static / {
             root /path/to/app;
             if ($query_string) {
                 expires max;
             }
         }
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
         location / {
             proxy_pass_header Server;
             proxy_set_header Host $http_host;
             proxy_redirect off;
             proxy_set_header X-Real-IP $remote_addr;
             proxy_set_header X-Scheme $scheme;
             proxy_pass http: //frontends;
         }
     }
}


对于后端节点,监控的检查请用nginx的check模块 ~

模块下载地址:https://github.com/cep21/healthcheck_nginx_upstreams;模块名称:ngx_http_healthcheck_module

1
2
3
4
5
6
7
8
9
10
11
upstream myhttpd {
         server  127.0 . 0.1 :8800weight= 5 ;
         server  127.0 . 0.1 :8801weight= 5 ;
         healthcheck_enabled; 开启健康检查功能
         healthcheck_delay  1000 ;
对同一台后端服务器两次检测之间的时间间隔,单位毫秒,默认为 1000 。                healthcheck_timeout  1000 ;
进行一次健康检测的超时时间,单位为毫秒,默认值 2000
         healthcheck_failcount  3 ;
对一台后端服务器检测成功或失败多少次之后方才确定其为成功或失败,并实现启用或禁用此服务器
         healthcheck_send  "GET/.health HTTP/1.0" ;
对一台后端服务器检测成功或失败多少次之后方才确定其为成功或失败,并实现启用或禁用此服务器,只支持http  1.0 的协议


uwsgi tornado的对比:


有朋友问过我,uwsgi的性能也可以呀。。。

以前我用flask的时候,经常要和uwsgi配合一起用,但是我和群里的人多方面测试压力,uwsgi不是很稳定,经常出现访问错误的情况,看debug也是看不出啥东西来。


这么多的tornado进程该如何开启?

用screen ,用 >/dev/null,用nohup ? 太搓了点吧~

推荐大家用supervisord管理杂乱的tornado服务和别的python服务。

源地址 http://rfyiamcool.blog.51cto.com/1030776/1301410

这里是centos supervisord 的配置


配置supervisor

1
2
yum install supervisor
pip install supervisor


echo_supervisord_conf > /etc/supervisord.conf


vim /etc/supervisord.conf


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
[program:tornado8000]
command=python /ops/tornado8000.py
process_name=%(program_name)s
stdout_logfile=/ops/access.log
stderr_logfile=/ops/error.log
[program:tornado8001]
command=python /ops/tornado8001.py
process_name=%(program_name)s
stdout_logfile=/ops/access.log
stderr_logfile=/ops/error.log
[program:tornado8002]
command=python /ops/tornado8002.py
process_name=%(program_name)s
stdout_logfile=/ops/access.log
stderr_logfile=/ops/error.log
[program:tornado8003]
command=python /ops/tornado8003.py
process_name=%(program_name)s
stdout_logfile=/ops/access.log
stderr_logfile=/ops/error.log


保存完配置后,咱们启动下: run~


1
/usr/bin/supervisord -c /etc/supervisord.conf


Supervisord安装完成后有两个可用的命令行supervisor和supervisorctl,命令使用解释如下:

  • supervisord,初始启动Supervisord,启动、管理配置中设置的进程。

  • supervisorctl stop programxxx,停止某一个进程(programxxx),programxxx为[program:chatdemon]里配置的值,这个示例就是chatdemon。

  • supervisorctl start programxxx,启动某个进程

  • supervisorctl restart programxxx,重启某个进程

  • supervisorctl stop groupworker: ,重启所有属于名为groupworker这个分组的进程(start,restart同理)

  • supervisorctl stop all,停止全部进程,注:start、restart、stop都不会载入最新的配置文件。

  • supervisorctl reload,载入最新的配置文件,停止原有进程并按新的配置启动、管理所有进程。

  • supervisorctl update,根据最新的配置文件,启动新配置或有改动的进程,配置没有改动的进程不会受影响而重启。

  • 注意:显示用stop停止掉的进程,用reload或者update都不会自动重启。


114739607.png

然后用装饰器判断状态。。。

@tornado.web.authenticated


代码在这里 ,大家配置自己的系统搞一下。

https://github.com/mmejia27/tornado-memcached-sessions


关于lua的用法,大家可以看看我以前的博文,对于mysql有详细的用法的。


模块代码:

https://github.com/agentzh/lua-resty-mysql


实例代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
upstream nginxbackend
  {
  drizzle_server  127.0 . 0.1 : 3306  dbname=nginx password=youpassword user=yourdbname protocol=mysql charset=utf8;
  drizzle_keepalive max= 100  mode=single overflow=reject;
  }
                                                                                                                                                                                                                                                                                                                                                                  
  location = /getuser
  {
  internal ;
  set_unescape_uri $user $remote_user;
  set_unescape_uri $passwd $remote_passwd;
  set_quote_sql_str $user $user;
  set_quote_sql_str $passwd $passwd;
  drizzle_query  "select count(*) as count from user where user=$user and passwd=$passwd" ;
  drizzle_pass nginxbackend;
  rds_json on;
  }



总之,我们要多方面的测试压力,才能找到适合自己业务的框架。






 本文转自 rfyiamcool 51CTO博客,原文链接:http://blog.51cto.com/rfyiamcool/1301410,如需转载请自行联系原作者



相关文章
|
8月前
|
应用服务中间件 Linux 网络安全
使用Nginx免费版与Keepalived实现高可用性High Availablity方案
本文介绍了如何使用Nginx免费版与Keepalived实现高可用性(HA)方案,涵盖环境搭建、Keepalived安装配置、版本升级及主从模式设置。通过虚拟机测试,结合CentOS与宝塔,详细说明VIP配置与服务启动流程,助你构建稳定可靠的Web高可用架构。
|
9月前
|
JSON 前端开发 应用服务中间件
配置Nginx根据IP地址进行流量限制以及返回JSON格式数据的方案
最后,记得在任何生产环境部署之前,进行透彻测试以确保一切运转如预期。遵循这些战术,守卫你的网络城堡不再是难题。
370 3
|
10月前
|
开发框架 Java 关系型数据库
在Linux系统中安装JDK、Tomcat、MySQL以及部署J2EE后端接口
校验时,浏览器输入:http://[your_server_IP]:8080/myapp。如果你看到你的应用的欢迎页面,恭喜你,一切都已就绪。
648 17
|
10月前
|
Java 关系型数据库 MySQL
在Linux操作系统上设置JDK、Tomcat、MySQL以及J2EE后端接口的部署步骤
让我们总结一下,给你的Linux操作系统装备上最强的军队,需要先后装备好JDK的弓箭,布置好Tomcat的阵地,再把MySQL的物资原料准备好,最后部署好J2EE攻城车,那就准备好进军吧,你的Linux军团,无人可挡!
309 18
|
10月前
|
开发框架 关系型数据库 Java
Linux操作系统中JDK、Tomcat、MySQL的完整安装流程以及J2EE后端接口的部署
然后Tomcat会自动将其解压成一个名为ROOT的文件夹。重启Tomcat,让新“植物”适应新环境。访问http://localhost:8080/yourproject看到你的项目页面,说明“植物”种植成功。
308 10
|
SQL JSON 关系型数据库
17.6K star!后端接口零代码的神器来了,腾讯开源的ORM库太强了!
"🏆 实时零代码、全功能、强安全 ORM 库 🚀 后端接口和文档零代码,前端定制返回 JSON 的数据和结构"
251 1
|
负载均衡 监控 应用服务中间件
配置Nginx反向代理时如何指定后端服务器的权重?
配置Nginx反向代理时如何指定后端服务器的权重?
669 61
|
关系型数据库 MySQL 测试技术
记录一次后端接口抖动的排查过程
某天下午,测试新功能时发现页面接口偶尔变慢,平均十次调用中有三到四次出现3秒以上的延迟。排查了接口、数据库和服务器资源后未发现问题,最终锁定为K8s节点的负载均衡策略导致。测试环境仅有一个公网IP,SLB轮询四个Pod(其中三个为空),造成周期性延迟。移除空Pod后问题解决。
378 6
|
缓存 NoSQL 搜索推荐
【📕分布式锁通关指南 03】通过Lua脚本保证redis操作的原子性
本文介绍了如何通过Lua脚本在Redis中实现分布式锁的原子性操作,避免并发问题。首先讲解了Lua脚本的基本概念及其在Redis中的使用方法,包括通过`eval`指令执行Lua脚本和通过`script load`指令缓存脚本。接着详细展示了如何用Lua脚本实现加锁、解锁及可重入锁的功能,确保同一线程可以多次获取锁而不发生死锁。最后,通过代码示例演示了如何在实际业务中调用这些Lua脚本,确保锁操作的原子性和安全性。
707 6
【📕分布式锁通关指南 03】通过Lua脚本保证redis操作的原子性
|
NoSQL Redis 数据库
Redis 功能扩展 Lua 脚本 对Redis扩展 eval redis.call redis.pcall
通过本文的介绍,我们详细讲解了 Lua 脚本在 Redis 中的作用、`eval` 命令的使用方法以及 `redis.call` 和 `redis.pcall` 的区别和用法。通过合理使用 Lua 脚本,可以实现复杂的业务逻辑,确保操作的原子性,并减少网络开销,从而提高系统的性能和可靠性。
845 13

热门文章

最新文章