zwproxy

ZWProxy(node.js)

使用

// Init
var ZWProxy = require('zwproxy');
var proxy = new ZWProxy();

proxy.front(8090, function(connection, data){
    // process websocket client request
});

proxy.backend(5566, function(data){
    // process backend mq request
});

API说明

ZWProxy.front(wsPort, wsListener, opts)

• port WebSocket监听端口；
• wsListener(connection, data) WebSocket消息处理接口；
• opts 可选配置参数：
  • filter(connection) WebSocket客户端连接过滤处理。返回false时，拒绝客户端连接；
  • close(code, desc) 客户端连接断开时回调；

ZWProxy.backend(mqPort, mqConsumer)

• mqPort MQ监听端口；
• mqConsumer(data) MQ消息处理接口。MQ内部使用REQ-REP模式，在此函数中必须返回一个响应数据。