基于redis和openresty实现一个http动态路由

cjfeii

http://blog.csdn.net/cjfeii/article/details/51159496
http://openresty.org/cn/dynamic-routing-based-on-redis.html
本文的一个例子主要介绍如何利用redis实现对请求头中User-Agent修改已达到路由到两个不同的http后台的目的。这个例子使用了这些openresty组件： Redis2 Nginx Module, Lua Nginx Module, Lua Redis Parser Library, 和 Set Misc Nginx Module。

1. 配置nginx

下面是完整的nginx.conf

1. worker_processes  1;
   
2. error_log logs/error.log info;
   
3. 
   
4. events {
   
5.     worker_connections 1024;
   
6. }
   
7. 
   
8. http {
   
9.     upstream apache.org {
   
10.         server apache.org;
    
11.     }
    
12. 
    
13.     upstream nginx.org {
    
14.         server nginx.org;
    
15.     }
    
16. 
    
17.     server {
    
18.         listen 8080;
    
19. 
    
20.         location = /redis {
    
21.             internal;
    
22.             set_unescape_uri $key $arg_key;
    
23.             redis2_query get $key;
    
24.             redis2_pass 127.0.0.1:6379;
    
25.         }
    
26. 
    
27.         location / {
    
28.             set $target '';
    
29.             access_by_lua '
    
30.                 local key = ngx.var.http_user_agent
    
31.                 local res = ngx.location.capture(
    
32.                     "/redis", { args = { key = key } }
    
33.                 )
    
34. 
    
35.                 print("key: ", key)
    
36. 
    
37.                 if res.status ~= 200 then
    
38.                     ngx.log(ngx.ERR, "redis server returned bad status: ",
    
39.                         res.status)
    
40.                     ngx.exit(res.status)
    
41.                 end
    
42. 
    
43.                 if not res.body then
    
44.                     ngx.log(ngx.ERR, "redis returned empty body")
    
45.                     ngx.exit(500)
    
46.                 end
    
47. 
    
48.                 local parser = require "redis.parser"
    
49.                 local server, typ = parser.parse_reply(res.body)
    
50.                 if typ ~= parser.BULK_REPLY or not server then
    
51.                     ngx.log(ngx.ERR, "bad redis response: ", res.body)
    
52.                     ngx.exit(500)
    
53.                 end
    
54. 
    
55.                 print("server: ", server)
    
56. 
    
57.                 ngx.var.target = server
    
58.             ';
    
59. 
    
60.             proxy_pass http://$target;
    
61.         }
    
62.     }
    
63. }

复制代码

2. 启动redis

1. $ ./redis-server  # default port is 6379

复制代码

在启动的redis中设置相关key：

1. $ ./redis-cli
   
2. redis> set foo apache.org
   
3. OK
   
4. redis> set bar nginx.org
   
5. OK

复制代码

3. 测试nginx应用：

1. $ curl --user-agent foo localhost:8080
   
2. <apache.org home page goes here>
   
3. 
   
4. $ curl --user-agent bar localhost:8080
   
5. <nginx.org home page goes here>

复制代码