現(xiàn)在nginx的版本已經(jīng)到了1.9.12,不過在1.9.0的時候,就開始了對TCP代理服務(wù)器的支持。
之前也有一些早期的做法,比如就有寫了nginx_tcp_module模塊的
https://github.com/yaoweibin/nginx_tcp_proxy_module,
以及nginx_stream_lua模塊的
https://github.com/openresty/stream-lua-nginx-module本來就想著用這兩個的,后來發(fā)現(xiàn)已經(jīng)有支持了,就先來試試看看這個了。
默認(rèn)的話,nginx是沒有開啟對tcp的支持的.如果要支持的話,需要用--with-stream去指定。
我這邊只要需要三個IP,一個是nginx進(jìn)程所在的機(jī)器,我這邊用192.168.1.4表示,
另外兩臺就是TCP上游業(yè)務(wù)服務(wù)器,我們分別用192.168.1.5和192.168.1.21來表示,
基于這樣的考慮是因?yàn)閚ginx充當(dāng)tcp代理服務(wù)器后,自身也會占用一個端口。
并且從目前來說,貌似一個nginx進(jìn)程也就只能listen一個端口。
我用的版本是nginx 1.9.9.
我在/usr/local/nginx/conf下面新建了nginx_stream_tcp.conf作為本次的測試。
worker_processes auto;
2 error_log /usr/local/nginx/logs/error.log info;
3 events {
4 worker_connections 1024;
5 }
6
7 stream {
8 upstream loadbalance {
9 # Specifies a load balancing method for a server group where client-server mapping is based on the hashed key value
10 hash $remote_addr consistent;
11 # sets the weight of the server, by default, 1.
12 server 192.168.1.21:8001 weight=5;
13 # by default, the parameter is set to 10 seconds.
14 server 192.168.1.5:9001 max_fails=3 fail_timeout=30s;
15
16
17 }
18
19 server {
20 # listen 8001.
21 listen 8001;
22 # Defines a timeout for establishing a connection with a proxied server.
23 proxy_connect_timeout 1s;
24 # Sets the timeout between two successive read or write operations on client or proxied server connections
25 proxy_timeout 3s;
26 # Sets the address of a proxied server
27 proxy_pass loadbalance;
28 }
29
30 }
這個大部分是官網(wǎng)支持的,所以其實(shí)我也沒有修改太多,就設(shè)置了幾個IP和端口。
在編譯好nginx后,可以用/usr/local/nginx/sbin/nginx -c /usr/local/nginx/conf/nginx_stream_tcp.conf
就可以起來了,可以通過netstat -tlnp查看是否起來,大致顯示這樣的:
tcp 0 0 0.0.0.0:8001 0.0.0.0:* LISTEN 7744/nginx_stream_t
當(dāng)然也可以通過telnet來查看。
接下來,寫個簡單的cs程序來驗(yàn)證下吧.
server端:
if __name__ == '__main__':
import socket
import commands
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.bind(('192.168.1.21', 8001))
sock.listen(5)
while True:
connection,address = sock.accept()
print "connected by",address
while 1:
buf = connection.recv(1024)
if buf != "" :
print "connection buffer", buf
connection.sendall(buf)
connection.close()
client端:
if __name__ == '__main__':
import socket
HOST='192.168.1.4'
PORT=8001
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect((HOST, PORT))
while 1:
cmd = raw_input("please input cmd:")
sock.sendall(cmd)
data = sock.recv(1024)
print data
sock.close()
在client向192.168.1.4發(fā)起一個TCP連接時,接下來192.168.1.4會連接到192.168.1.21,
192.168.1.21的server端會顯示, connected by ('192.168.1.4',58559)
后面的端口應(yīng)該是隨機(jī)的臨時端口。
其實(shí)它的確起到了轉(zhuǎn)發(fā)作用,這個nginx進(jìn)程相當(dāng)于一個通用網(wǎng)關(guān),如果有兩個client向nginx進(jìn)程發(fā)起連接,一旦nginx那邊調(diào)度到同一個上游TCP服務(wù)器,那么只需要從NGINX進(jìn)程建立一個TCP連接到上游TCP服務(wù)器即可。
之前我自己設(shè)計(jì)網(wǎng)關(guān)的時候,不是依賴于用戶的,而是通過靜態(tài)配置來建立連接的,比如上游邏輯服務(wù)器跟網(wǎng)關(guān)有連接,那都是在啟動服務(wù)器的時候,就建立起來了。
這樣有個好處就是可以省事,不過也可以采用這種方式,有玩家連接進(jìn)某個上游TCP服務(wù)器才讓網(wǎng)關(guān)跟這個TCP服務(wù)器建立連接,否則無需處理。因?yàn)椴簧贂r候還是會有不少服務(wù)器處于空閑的.