基于redis和openresty實(shí)現(xiàn)一個(gè)http動(dòng)態(tài)路由

cjfeii

http://blog.csdn.net/cjfeii/article/details/51159496
http://openresty.org/cn/dynamic-routing-based-on-redis.html
本文的一個(gè)例子主要介紹如何利用redis實(shí)現(xiàn)對(duì)請(qǐng)求頭中User-Agent修改已達(dá)到路由到兩個(gè)不同的http后臺(tái)的目的。這個(gè)例子使用了這些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. }

復(fù)制代碼

2. 啟動(dòng)redis

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

復(fù)制代碼

在啟動(dòng)的redis中設(shè)置相關(guān)key：

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

復(fù)制代碼

3. 測(cè)試nginx應(yīng)用：

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>

復(fù)制代碼