Symcall插件

symcall插件 (modifier 18) 是一个便利的插件,允许你在不需要开发一个完整的uWSGI插件的情况下编写原生uWSGI请求处理器。

你告诉它在启动时加载那个时候符号,然后它就会在每个请求上运行它。

注解

在标准的构建配置文件中,默认内建”symcall”插件。

第一步:准备环境

uWSGI二进制自身允许你在无需外部开发包或者头文件的情况下开发插件和库。

第一步是获取 uwsgi.h C/C++头文件:

  1. uwsgi --dot-h > uwsgi.h

现在,在当前目录下,我们有了一个准备被包含的新鲜的uwsgi.h。

第二步:第一个请求处理器:

我们的C处理器将会打印REMOTE_ADDR值以及一对HTTP头。

(称其为mysym.c或者随便你)

  1. #include "uwsgi.h"
  2.  
  3. int mysym_function(struct wsgi_request *wsgi_req) {
  4.  
  5. // read request variables
  6. if (uwsgi_parse_vars(wsgi_req)) {
  7. return -1;
  8. }
  9.  
  10. // get REMOTE_ADDR
  11. uint16_t vlen = 0;
  12. char *v = uwsgi_get_var(wsgi_req, "REMOTE_ADDR", 11, &vlen);
  13.  
  14. // send status
  15. if (uwsgi_response_prepare_headers(wsgi_req, "200 OK", 6)) return -1;
  16. // send content_type
  17. if (uwsgi_response_add_content_type(wsgi_req, "text/plain", 10)) return -1;
  18. // send a custom header
  19. if (uwsgi_response_add_header(wsgi_req, "Foo", 3, "Bar", 3)) return -1;
  20.  
  21. // send the body
  22. if (uwsgi_response_write_body_do(wsgi_req, v, vlen)) return -1;
  23.  
  24. return UWSGI_OK;
  25. }

第三步:将我们的代码作为共享库进行构建

uwsgi.h文件是一个ifdef地狱 (所以可能最好不要看得太深入)。

幸运的是,uwsgi二进制通过–cflags选项公开了所有所需的CFLAGS。

我们可以一次到位构建我们的库:

  1. gcc -fPIC -shared -o mysym.so `uwsgi --cflags` mysym.c

现在,你准备好了在uWSGI中加载的mysym.so库了

最后一步:映射symcall插件到 mysym_function 符号

  1. uwsgi --dlopen ./mysym.so --symcall mysym_function --http-socket :9090 --http-socket-modifier1 18

通过 —dlopen ,我们在uWSGI进程地址空间中加载了一个共享库。

—symcall 选项允许我们当有modifier1 18的时候,指定调用哪个符号

我们绑定实例到HTTP socket 9090,强制modifier1 18。

钩子和symcall释放:一个TCL处理器

我们想要编写一个每次运行以下TCL脚本 (foo.tcl) 的请求处理器:

  1. # call it foo.tcl
  2. proc request_handler { remote_addr path_info query_string } {
  3. set upper_pathinfo [string toupper $path_info]
  4. return "Hello $remote_addr $upper_pathinfo $query_string"
  5. }

我们将定义一个初始化TCL解析器和传递脚本的函数。将会在启动时,于移除权限之后立即调用这个函数。

最后,我们定义引用这个TCL过程并传递参数的请求处理器

  1. #include <tcl.h>
  2. #include "uwsgi.h"
  3.  
  4. // global interpreter
  5. static Tcl_Interp *tcl_interp;
  6.  
  7. // the init function
  8. void ourtcl_init() {
  9. // create the TCL interpreter
  10. tcl_interp = Tcl_CreateInterp() ;
  11. if (!tcl_interp) {
  12. uwsgi_log("unable to initialize TCL interpreter\n");
  13. exit(1);
  14. }
  15.  
  16. // initialize the interpreter
  17. if (Tcl_Init(tcl_interp) != TCL_OK) {
  18. uwsgi_log("Tcl_Init error: %s\n", Tcl_GetStringResult(tcl_interp));
  19. exit(1);
  20. }
  21.  
  22. // parse foo.tcl
  23. if (Tcl_EvalFile(tcl_interp, "foo.tcl") != TCL_OK) {
  24. uwsgi_log("Tcl_EvalFile error: %s\n", Tcl_GetStringResult(tcl_interp));
  25. exit(1);
  26. }
  27.  
  28. uwsgi_log("TCL engine initialized");
  29. }
  30.  
  31. // the request handler
  32. int ourtcl_handler(struct wsgi_request *wsgi_req) {
  33.  
  34. // get request vars
  35. if (uwsgi_parse_vars(wsgi_req)) return -1;
  36.  
  37. Tcl_Obj *objv[4];
  38. // the proc name
  39. objv[0] = Tcl_NewStringObj("request_handler", -1);
  40. // REMOTE_ADDR
  41. objv[1] = Tcl_NewStringObj(wsgi_req->remote_addr, wsgi_req->remote_addr_len);
  42. // PATH_INFO
  43. objv[2] = Tcl_NewStringObj(wsgi_req->path_info, wsgi_req->path_info_len);
  44. // QUERY_STRING
  45. objv[3] = Tcl_NewStringObj(wsgi_req->query_string, wsgi_req->query_string_len);
  46.  
  47. // call the proc
  48. if (Tcl_EvalObjv(tcl_interp, 4, objv, TCL_EVAL_GLOBAL) != TCL_OK) {
  49. // ERROR, report it to the browser
  50. if (uwsgi_response_prepare_headers(wsgi_req, "500 Internal Server Error", 25)) return -1;
  51. if (uwsgi_response_add_content_type(wsgi_req, "text/plain", 10)) return -1;
  52. char *body = (char *) Tcl_GetStringResult(tcl_interp);
  53. if (uwsgi_response_write_body_do(wsgi_req, body, strlen(body))) return -1;
  54. return UWSGI_OK;
  55. }
  56.  
  57. // all fine
  58. if (uwsgi_response_prepare_headers(wsgi_req, "200 OK", 6)) return -1;
  59. if (uwsgi_response_add_content_type(wsgi_req, "text/plain", 10)) return -1;
  60.  
  61. // write the result
  62. char *body = (char *) Tcl_GetStringResult(tcl_interp);
  63. if (uwsgi_response_write_body_do(wsgi_req, body, strlen(body))) return -1;
  64. return UWSGI_OK;
  65. }

你可以这样构建它:

  1. gcc -fPIC -shared -o ourtcl.so `./uwsgi/uwsgi --cflags` -I/usr/include/tcl ourtcl.c -ltcl

与前一个例子唯一的差异在于,-I和-l用于添加TCL头文件和库。

所以,让我们允许它:

  1. uwsgi --dlopen ./ourtcl.so --hook-as-user call:ourtcl_init --http-socket :9090 --symcall ourtcl_handler --http-socket-modifier1 18

这里,唯一新的用户是 —hook-as-user call:ourtcl_init ,它在移除特权后引用指定的函数。

注解

代码非线程安全的!如果你想改进这个tcl库来支持多线程,那么最好的方法将是对每个pthread而非对全局使用一个TCL解析器。

注意事项

自uWSGI 1.9.21起,多亏了 —build-plugin 选项,开发uWSGI插件变得相当简单。

symcall插件是用于小的代码库/片段,对于更大的需求,考虑开发一个完整的插件。

我们前面已经看到的tcl例子或许是“错误”使用的正确例子 ;)