Moduel ProxyHTTP 反向代理中间件-技术圈

Module Proxy是一款HTTP反向代理中间件，突出的靓点是将HTTP协议代理为TCP Socket协议，特别适合Web前后台分离的编程架构项目，使用Module Proxy可以让后端编程从HTTP技术体系中抽身出来，这将带来两个重要的改变：

无Web编程经验的程序员，可以轻松进行B/S后端的编程工作。

几乎所有的现代编程语言，都可以被使用进行B/S后端的编程工作，使用中不需要这些编程语言有HTTP的实现。

Module Proxy中间件由Rust语言实现，使用了优秀的异步运行时Tokio和HTTP底层库hyper，具有高效、稳定、简单的特性。

Demo 程序示例

Ajax客户端：

<!DOCTYPE HTML>

<html>

<head>

<meta charset="UTF-8">

<script src="http://libs.baidu.com/jquery/2.0.0/jquery.js"></script>

<script type="text/javascript">

$(function(){

	// method是和后端服务的约定，这里表示调用后端的hello方法，data是前后端约定的业务数据

	var req_json =  {

                       "head":{"method":"hello"},

                       "data":{"hello":"world!!!", "list":[1,2,3,4]}

                    };

	$("#btn").click(function(){

		$.ajax({

			type: "POST",       //传输方式POST

			url: "/socket1/",   //提交URL, socket1是模块名

			contentType : "application/json; charset=utf-8",  //Socket转发的固定格式

			data: JSON.stringify(req_json),

			success: function(rsp_json){

				$("#myDiv").html('<h3>'+JSON.stringify(rsp_json)+'</h3>');

			}

		});		

	 });

});

</script>    

</head>

    <body>

        <button id="btn" type="button">submit</button>

        <div id="myDiv"></div>

    </body>

</html>

Go语言实现的Socket端：

package main



import (

	"encoding/json"

	"fmt"

	"net"

	"strconv"

	"strings"

	"time"

)



func main() {

	listener, err := net.Listen("tcp", "0.0.0.0:21231") //侦听端口21231

	if err != nil {

		fmt.Println("listen error:", err)

		return

	}

	fmt.Println("server start...")



	for {

		conn, err := listener.Accept()

		if err != nil {

			fmt.Println("accept error:", err)

			break

		}



		go process(conn) //协程

	}

}



func process(conn net.Conn) {



	defer conn.Close()



	//读取req json长度，长度行是Module Proxy转发时在Json数据前补充的

	buf := make([]byte, 12) //长度行总是12字节

	n, _ := conn.Read(buf)

	lenStr := string(buf[:n])

	lenStr = strings.Trim(lenStr, "\r\n") //去除行尾的回车换行

	lenStr = strings.Trim(lenStr, " ")    //去除行左的空格

	len, _ := strconv.Atoi(lenStr)        //string转int



	//读取req json

	jsonBuf := make([]byte, len)

	n, _ = conn.Read(jsonBuf)



	//解析req json

	m := make(map[string]interface{}) //map

	json.Unmarshal(jsonBuf, &m)       //json转map

	method := m["head"].(map[string]interface{})["method"]

	data := m["data"]

	fmt.Println("method: ", method)

	fmt.Println("data: ", data)



	//调用业务函数

	var rspJson []byte

	var rsplen int

	switch method {

	case "hello":

		rspJson, rsplen = hello(data.(map[string]interface{})) //只传入Json中的data数据部分

	default:

		rspJson, rsplen = foo()

	}



	//返回 rsp json

	lenRsp := fmt.Sprintf("%10d\r\n", rsplen) //构建12字节长度行（左补空格，右补\r\n）

	conn.Write([]byte(lenRsp)) //socket返回 长度行

	conn.Write(rspJson)        //socket返回 rsp json

}



func hello(m map[string]interface{}) ([]byte, int) {

	m["time"] = time.Now().Format("2006-01-02 15:04:05")

	m["module"] = "golang"

	b, _ := json.Marshal(m) //map转json

	return b, len(b)

}



func foo() ([]byte, int) {

	b := []byte("{}")

	return b, len(b)

}

说明：因篇幅原因，以上代码省略了必要的错误和异常处理，只起到示范说明作用。