网关服务器从redis中取其它服务器列表

center_svr/center-handler.js

@@ -17,6 +17,7 @@ const packet = require('../protocol/packet');
 //      type
 //      ip
 //      port
+//      activeTime
 //      ext
 // }
 function registerServer(serverInfo) {
@@ -46,6 +47,8 @@ function process(socket, data) {
     switch (subCmd) {
         case cmdDefine.SUB_CENTER_UPDATE:
             let serverInfo = jObj.body;
+            serverInfo.ip = socket.remoteAddress;
+            serverInfo.activeTime = Math.floor(new Date().getTime()/1000);
             registerServer(serverInfo);
             break;
         case cmdDefine.SUB_CENTER_GET:

gate_svr/gate.js

@@ -3,9 +3,11 @@ const wsServer = require('./ws-server');
 const sysConfig = require('./config/sys-config.json');
 const logger = require('./logger');
 const registerCenter = require('./register-center');
+const sysCache = require('./sys-cache');
 
 logger.debug(sysConfig);
 
+sysCache.readCached();
 setInterval(registerCenter.registerSelf, 5*1000);
 
 wsServer.startServer(sysConfig);

gate_svr/redis-oper.js

@@ -1,20 +1,26 @@
 
 const sysConfig = require('./config/sys-config.json');
 const redis = require('redis');
-//const redisPool = require('redis-pool-connection');
+const redisKey = require('../lib/rds-key');
 
 var host = sysConfig.redisHost;
 var port = sysConfig.redisPort;
 var password = sysConfig.redisPassword;
 
-function readCachedServers() {
+function readCachedServers(cb) {
     var rds = null;
     if (!!password && password.length > 0) {
         rds = redis.createClient({host:host,port:port,password:password});
     } else {
         rds = redis.createClient({host:host,port:port});
     }
 
-    conn.hget
+    for (let v of redisKey.SERVER_TYPE_LIST) {
+        let key = redisKey.KEY_SERVER_TYPE + v;
+        rds.get(key, function (error,reply) {
+            cb (v, reply);
+        });
+    }
 }
 
+exports.readCachedServers = readCachedServers;

gate_svr/register-center.js

@@ -25,6 +25,7 @@ function registerSelf() {
         let serverInfo = {};
         serverInfo.type = constDefine.SERVER_TYPE_GATE;
         serverInfo.port = sysConfig.svrPort;
+        serverInfo.name = "gate_svr";
 
         jObj.body = serverInfo;
 

gate_svr/sys-cache.js

@@ -1,11 +1,25 @@
 
+const redisOper = require('./redis-oper');
 
-var cached = {}
+var cached = {};
+
+function saveServerInfo(type,serverList) {
+    let jArray = JSON.parse(serverList);
+    cached[type] = jArray;
+}
 
 // read servers info from redis
 function readCached() {
 
+    redisOper.readCachedServers(saveServerInfo);
+}
+
+function getServerList(type) {
+
+    return cached[type];
 }
 
+setInterval(readCached, 60*1000);
 
-setInterval(readCached, 60*1000);
+exports.getServerList = getServerList;
+exports.readCached = readCached;

login_svr/register-center.js

@@ -23,8 +23,9 @@ function registerSelf() {
         let jObj = packet.getPacket(cmdDefine.CENTER, cmdDefine.SUB_CENTER_UPDATE);
 
         let serverInfo = {};
-        serverInfo.type = constDefine.SERVER_TYPE_GATE;
+        serverInfo.type = constDefine.SERVER_TYPE_LOGIN;
         serverInfo.port = sysConfig.svrPort;
+        serverInfo.name = "login_svr";
 
         jObj.body = serverInfo;