想升级PHP框架phalcon到3.x, 但是发现升级后与老版本基本不兼容, 也就意味着代码基本要重写了。考虑到不可能一下把所有的接口切换到新的框架上去（不能短时间内全部迁移所有的接口，新的框架提供的接口需要测试时间）。想到的方案是， 一方面提供新的接口使用新的框架编写，然后网关判断， 如果是新的接口就路由到新的框架部署的服务器上。空闲的时间，慢慢的把老的接口往新的框架上迁移。一下简单的实现了一个demo案列。

环境以及依赖软件

  • window 10。
  • openresty/1.13.6.1 提供网关服务。
  • redis-server 提供新路由存储。
  • golang 模拟提供web服务。

这里不对openresty, golang做介绍了。

openresty配置

编辑nginx.conf文件, 默认使用phalcon1upstream,当rewrite_by_lua_file执行完后, 如果是新的路由, 会重写phalcon1到phalcon3。

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
upstream phalcon1 {
    server 127.0.0.1:8088 fail_timeout=53 weight=4 max_fails=100;
}
upstream phalcon3 {
    server 127.0.0.1:8089 fail_timeout=53 weight=10 max_fails=100;
}
server {
    listen       80;
    server_name  localhost;
    #charset koi8-r;
    access_log  logs/host.access.log  main;
    error_page   500 502 503 504  /50x.html;
    location / {
        root   html;
        index  index.html index.htm;
    }
    location /api/user {
        default_type text/html;
        set $upstream "phalcon1";
        # set_by_lua_file $upstream "lualib/zq/chrbyuri.lua"; # set_by_lua_file 关闭了 resty_redis API
        rewrite_by_lua_file "lualib/zq/chrbyuri.lua";
        proxy_pass http://$upstream;
    }
    location = /50x.html {
        root   html;
    }
}

chrbyuri.lua

从redis中查找是否是新的路由, 新的话重写phalcon1到phalcon3, 这里有个小规则, 框架中有的路由是 /api/user/{page}/{num}.json 由于这些路由是动态, 不好固化存在redis中, 这列只做了简单的处理, 就是替换成 {num}, 比如请求路由: /api/user/100/10/post.json => /api/user/{num}/{num}/post.json, 对应的在redis存替换的key就好了。

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
local newupstream = "phalcon3"
local redis_host = "127.0.0.1"
local redis_port = 6379
local redis = require "resty.redis"
local uri = ngx.var.uri
local r = uri:gsub("/%d+", "/{num}")
ngx.log(ngx.INFO, "origin document_uri:", uri)
ngx.log(ngx.INFO, "replace document_uri:", r)


local route_redis = redis:new()
local ok, err = route_redis:connect(redis_host, redis_port)
if not ok then
    ngx.log(ngx.ERR, "connect to redis error", err)
    return
end
-- query document_uri is exists or not
local newsrv, err = route_redis:get(r)
if newsrv == ngx.null then
  ngx.log(ngx.INFO, string.format("route %s is not new route", r))
  return
end

-- override upstream
ngx.var.upstream = newupstream

golang实现的web服务

端口8088为老的接口服务器，提供 /api/user/user.info1 /api/user/user.info2 2个接口。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
# filename: phalcon1.go
package main

import (
	"net/http"
	"log"
)

func ()  {
	http.HandleFunc("/api/user/user.info1", func(rw http.ResponseWriter, r *http.Request) {
		rw.Write([]byte("phalcon1:8088 handle route: {api/user/user.info2}"))
	})
	http.HandleFunc("/api/user/user.info2", func(rw http.ResponseWriter, r *http.Request) {
		rw.Write([]byte("phalcon1:8088 handle route: {api/user/user.info2}"))
	})
	log.Fatalf("server exception: %+v n", http.ListenAndServe(":8088", nil))
}

端口8089为新的接口服务器，提供 /api/user/user.info3 1个接口。

1
2
3
4
5
6
7
8
9
10
11
12
13
package main
# filename: phalcon3.go
import (
	"net/http"
	"log"
)

func ()  {
	http.HandleFunc("/api/user/user.info3", func(rw http.ResponseWriter, r *http.Request) {
		rw.Write([]byte("phalcon1:8089 handle route: {api/user/user.info2}"))
	})
	log.Fatalf("server exception: %+v n", http.ListenAndServe(":8089", nil))
}

测试

  1. 启动openresty cd /path/to/openresty/nginx.exe。
  2. 启动redis-server cd /path/to/redis-server/redis-server -c /path/to/redis-server.conf。
  3. 启动phalcon2 go run phalcon3.go。

  4. 启动phalcon1 go run phalcon1.go。

  5. 将新的路由写入到redis中 redis-cli set /api/user/user.info3 1。

  6. 访问 http://localhost/api/user/user.info1 http://localhost/api/user/user.info2 还是代理到了phalcon1上。

  7. 访问 http://localhost/api/user/user.info3 就代理到了phalcon3上了。

后续

当有新的接口发布时候, 记得往redis写入新的路由标识即可了。