发表更新 雾非雾的情思 5 分钟读完 (大约693个字)

nginx-clojure安装使用

安装配置

环境要求

jdk1.6+
nginx1.4+

安装

下载nginx和nginx-clojure源码，分别去他们的官网下载就可以，然后将他们解压、编译、安装。编译安装nginx时，加上nginx-clojure模块，具体安装脚本如下：

1
2
3
./configure --prefix=/usr/local/nginx --add-module=nginx-clojure模块解压路径
make
sudo make install

配置

### 建议这里查看官方文档，比较详细
### 官方文档地址：http://nginx-clojure.github.io/configuration.html#21-jvm-path--class-path--other-jvm-options
jvm_path auto;
# classpath：需要加载nginx-clojure自己的jar包，并加载自己开发的jar包
jvm_classpath "/usr/local/nginx/libs/nginx-clojure-0.4.4/jars/*:/Users/gaoyoubo/work/dianping-service/dianping-nginx/target/dianping-nginx-2.0.1-SNAPSHOT.jar";

使用

rewrite handler

rewrite handler可用于请求的转发。

Java handler类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
package my.test;

import static nginx.clojure.java.Constants.*;

public static class MyRewriteProxyPassHandler implements NginxJavaRingHandler {
	@Override
		public Object[] invoke(Map<String, Object> req) {
		String myhost = computeMyHost(req);
		((NginxJavaRequest)req).setNGXVariable("myhost", myhost);
		return PHASE_DONE;
	}

	private String computeMyHost(Map<String, Object> req) {
		//compute a upstream name or host name;
	}
}

nginx.conf配置

set $myhost "";
location /myproxy {
    ### 这里指定handle_type
    rewrite_handler_type 'java';
    ### 这里指定处理类
    rewrite_handler_name 'my.test.MyRewriteProxyPassHandler';
    proxy_pass $myhost;
}

access handler

可做请求的权限校验

Java handler类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
/**
     * This is an  example of HTTP basic Authentication.
     * It will require visitor to input a user name (xfeep) and password (hello!) 
     * otherwise it will return 401 Unauthorized or BAD USER & PASSWORD 
     */
    public  class BasicAuthHandler implements NginxJavaRingHandler {

        @Override
        public Object[] invoke(Map<String, Object> request) {
            String auth = (String) ((Map)request.get(HEADERS)).get("authorization");
            if (auth == null) {
                return new Object[] { 401, ArrayMap.create("www-authenticate", "Basic realm=\"Secure Area\""),
                        "<HTML><BODY><H1>401 Unauthorized.</H1></BODY></HTML>" };
            }
            String[] up = new String(DatatypeConverter.parseBase64Binary(auth.substring("Basic ".length())), DEFAULT_ENCODING).split(":");
            if (up[0].equals("xfeep") && up[1].equals("hello!")) {
                return PHASE_DONE;
            }
            return new Object[] { 401, ArrayMap.create("www-authenticate", "Basic realm=\"Secure Area\""),
            "<HTML><BODY><H1>401 Unauthorized BAD USER & PASSWORD.</H1></BODY></HTML>" };
        } 
    }

nginx.conf配置

location /basicAuth {
    access_handler_type 'java';
    access_handler_name 'my.BasicAuthHandler';
    ....
}

header filter

可拦截头信息，并作出相应的处理

Java handler类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
package my;

import nginx.clojure.java.NginxJavaRingHandler;
import nginx.clojure.java.Constants;

public  class RemoveAndAddMoreHeaders implements NginxJavaHeaderFilter {
	@Override
		public Object[] doFilter(int status, Map<String, Object> request, Map<String, Object> responseHeaders) {
		responseHeaders.remove("Content-Type");
		responseHeaders.put("Content-Type", "text/html");
		responseHeaders.put("Xfeep-Header", "Hello2!");
		responseHeaders.put("Server", "My-Test-Server");
		return Constants.PHASE_DONE;
	}
}

nginx.conf配置

location /javafilter {
    header_filter_type 'java';
    header_filter_name 'my.RemoveAndAddMoreHeaders ';
    ..................
}

body filter

可修改返回数据

Java handler类

1
2
3
4
5
6
7
8
9
10
public static class StringFacedUppercaseBodyFilter extends StringFacedJavaBodyFilter {
	@Override
		protected Object[] doFilter(Map<String, Object> request, String body, boolean isLast) throws IOException {
		if (isLast) {
			return new Object[] {200, null, body.toUpperCase()};
		}else {
			return new Object[] {null, null, body.toUpperCase()};
		}
	}
}

nginx.conf配置

location /hello {
  body_filter_type java;
  body_filter_name mytest.StringFacedUppercaseBodyFilter;
}

更多使用场景

nginx-clojure能够获取和修改请求数据、响应数据、header信息等（基本上java servlet中能够获取和修改的数据，他也都能获取和修改），所以基于他，我们能够完成很多servlet能够完成的数据，甚至他能够连接mysql，redis等。

可操作的请求数据

Server port
Server-name
Remote addr
Uri
Query String
Scheme
Request-method
Protocol
Content type
Content length
Character encoding
Headers
Body

可操作的相应数据

Status
Headers
Body
发表更新 雾非雾的情思 8 分钟读完 (大约1125个字)

使用nginx-clojure配置nginx负载均衡

使用背景

最近遇到一个很困扰的问题，系统请求量变大了一台服务器已经扛不住了。于是我基于mq升级了我的服务，让我的服务能够支持横向扩展，通过mq服务完成各节点之间的通信。于是我们将服务部署到两个节点上，然后通过nginx随机将请求平均分发到两个节点。那么问题来了，在随机分发到两个节点之后服务器的CPU占用有所下降，但是内存占用却没有降下来。于是我们分析了一下原因，因为是随机分发，那么同一条数据请求两台服务器都会随机到，那么在这两台服务器上就会有相同的数据缓存，那么这样就会造成内存的浪费。于是我们就想办法根据请求的参数进行分发，保证同一条数据请求只会到同一台服务器。
开始时我们用到了consistent_hash，但是我们客户端请求不规范有有些参数是放在POST请求中的，consistent_hash是无法根据POST请求中的参数进行hash，然后分发。于是在网上搜索了很多资料，直到我找到了nginx-clojure。选nginx-clojure是因为他可以用我熟悉的语言写插件：Java。
安装配置

安装nginx-clojure插件

下载nginx和nginx-clojure源码，分别去他们的官网下载就可以，然后将他们解压、编译、安装。脚本如下：

1
2
3
./configure --prefix=/usr/local/nginx --add-module=nginx-clojure安装模块
make
sudo make install

配置nginx-clojure

在nginx.conf中

1
2
3
4
5
### 建议这里查看官方文档，比较详细
### 官方文档地址：http://nginx-clojure.github.io/configuration.html#21-jvm-path--class-path--other-jvm-options
jvm_path auto;
# 这个是classpath需要用到的jar包都需要加入到classpath中。
jvm_classpath "/usr/local/nginx/libs/nginx-clojure-0.4.4/jars/*:/Users/gaoyoubo/work/dianping-service/dianping-nginx/target/dianping-nginx-2.0.1-SNAPSHOT.jar";

配置自己的location

1
2
3
4
5
6
7
8
9
10
11
12
13
set $node "";
location / {
    # 加上他会读取POST请求数据，不需要的时候建议关掉
    always_read_body on;
    # handler类型，nginx-clojure支持三种：clojure、groovy、java，这里主要讲解java
    rewrite_handler_type 'java';
    # 这里是处理类
    rewrite_handler_name 'cn.mucang.dianping.nginx.DianpingRewriteHandler';
    proxy_pass $node;
    proxy_set_header Host $host;
    proxy_set_header X-Real-IP   $remote_addr;
    proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
}

编写处理类

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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
package cn.mucang.dianping.nginx;

import nginx.clojure.NativeInputStream;
import nginx.clojure.NginxClojureRT;
import nginx.clojure.java.Constants;
import nginx.clojure.java.NginxJavaRequest;
import nginx.clojure.java.NginxJavaRingHandler;
import org.apache.commons.collections.MapUtils;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;

import java.io.IOException;
import java.net.URLDecoder;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;

/**
 * @author Gao Youbo
 * @since 2016-03-17 15:02
 */
public class DianpingRewriteHandler implements NginxJavaRingHandler {
    public static final String KEY_URI = "uri";
    public static final String KEY_BODY = "body";
    public static final String KEY_REQUEST_METHOD = "request-method";
    public static final String KEY_QUERY_STRING = "query-string";
    public static final String ENCODING = "UTF-8";

    public static final Map NODES = new HashMap();
    public static final int NODE_SIZE = 2;
    public static final String MASTER_NODE = "node1";
    public static final String SALVE_NODE = "node2";

    private static final Random R = new Random();

    static {
        NODES.put(0, MASTER_NODE);
        NODES.put(1, SALVE_NODE);
    }

    public Object[] invoke(Map requestMap) throws IOException {
        long start = System.currentTimeMillis();
        Map params = getParams(requestMap);   // 所有的请求参数包括GET和POST
        String node = getNode(requestMap);

        NginxJavaRequest request = (NginxJavaRequest) requestMap;
        request.setVariable("node", normalizeNode(node));

        long elasped = System.currentTimeMillis() - start;
        NginxClojureRT.log.info(String.format("[gaoyoubo] elasped:%s ms, node=%s, uri:%s, elasped, node, uri));

        return Constants.PHASE_DONE;
    }

    /**
     * 计算当前请求应该走哪个节点
     *
     * @param requestMap
     * @return
     */
    private String getNode(Map requestMap) {
        // 业务逻辑
    }

    private String normalizeNode(String node) {
        return "http://" + node;
    }

    /**
     * 获取请求参数, 包括GET和POST
     *
     * @param requestMap
     * @return
     */
    private Map getParams(Map requestMap) {
        Map params = new HashMap<>();
        try {
            params.putAll(getGetParams(requestMap));
            params.putAll(getPostParams(requestMap));
        } catch (Exception e) {
            NginxClojureRT.log.error("获取请求参数失败", e);
        }
        return params;
    }

    /**
     * 获取GET请求参数
     *
     * @param requestMap
     * @return
     */
    private Map getGetParams(Map requestMap) {
        String queryString = MapUtils.getString(requestMap, KEY_QUERY_STRING);
        return buildQuerys(queryString);
    }

    /**
     * 获取POST请求参数
     *
     * @param requestMap
     * @return
     */
    private Map getPostParams(Map requestMap) throws IOException {
        String requestMethod = MapUtils.getString(requestMap, KEY_REQUEST_METHOD);
        if (StringUtils.equalsIgnoreCase(requestMethod, "POST")) { // 如果是POST请求,那么处理下POST参数
            Object bodyObj = requestMap.get(KEY_BODY);
            if (bodyObj != null) {
                NativeInputStream nis = (NativeInputStream) bodyObj;
                String body = IOUtils.toString(nis, ENCODING);
                return buildQuerys(body);
            }
        }
        return new HashMap<>();
    }

    /**
     * 将字符串格式的参数转换成Map
     *
     * @param queryString
     * @return
     */
    private Map buildQuerys(String queryString) {
        Map params = new HashMap<>();
        if (StringUtils.isBlank(queryString)) {
            return params;
        }
        String[] kvs = queryString.split("&");
        if (kvs != null) {
            for (String kv : kvs) {
                String[] pair = kv.split("\\=", 2);
                if (pair.length == 2) {
                    params.put(pair[0], urlDecode(pair[1], ENCODING));
                }
            }
        }
        return params;
    }

    private String urlDecode(String s, String encoding) {
        try {
            return URLDecoder.decode(s, encoding);
        } catch (Exception ex) {
            NginxClojureRT.log.error(null, ex);
        }
        return s;
    }
}
关注我

分类

最新文章

归档

标签

Android2
ElasticSearch1
Electron1
Go16
Hadoop1
Hexo10
HexoClient17
Java22
JavaCV1
Linux5
Nginx2
Python1
docker1
ffmpeg1
git4
html1
js2
mac3
mariadb3
markdown1
mysql3
node1
ocr2
php1
python1
shadowsocks2
springboot1
tesseract2
代码笔记1
推荐系统2
碎碎念38
程序员48
×