在线人数优化

incubator-game/src/main/java/com/incubator/game/listener/PublicListener.java

@@ -32,13 +32,6 @@ public class PublicListener extends GameServerConnectionListener {
 		// 设置最后心跳时间
 		//connection.setAttribute(LastReadTimeMills, System.currentTimeMillis());
 		Log.info("链路打开 : {}", connection);
-		// 测试redis连接 key后期优化
-		WkServerStatus wkToRedis = RedisUtil.getWkToRedis(RedisKeyConstant.WK_SERVE, RedisKeyConstant.WK_SERVE_KEY);
-		//在线人数加1
-		assert wkToRedis != null;
-		int num = wkToRedis.getNum() + 1;
-		wkToRedis.setNum(num);
-		RedisUtil.saveWkToRedis(RedisKeyConstant.WK_SERVE, wkToRedis);
 	}
 
 	@Override

incubator-game/src/main/java/com/incubator/game/player/GPlayer.java

@@ -5,6 +5,9 @@ import com.incubator.common.net.Connection;
 import com.incubator.core.net.ws.Message;
 import com.incubator.core.player.GPlayerBase;
 import com.incubator.game.GGame;
+import com.incubator.game.constant.RedisKeyConstant;
+import com.incubator.game.constant.WkServerStatus;
+import com.incubator.game.data.jedis.RedisUtil;
 
 import java.time.LocalDateTime;
 import java.util.Date;
@@ -42,6 +45,13 @@ public abstract class GPlayer extends GPlayerBase {
 			this.session = session;
 			// 加入在线玩家集合
 			GGame.onlinePlayers.put(this.getId(), this);
+			// 测试redis连接 key后期优化
+			WkServerStatus wkToRedis = RedisUtil.getWkToRedis(RedisKeyConstant.WK_SERVE, RedisKeyConstant.WK_SERVE_KEY);
+			//在线人数加1
+			assert wkToRedis != null;
+			int num = wkToRedis.getNum() + 1;
+			wkToRedis.setNum(num);
+			RedisUtil.saveWkToRedis(RedisKeyConstant.WK_SERVE, wkToRedis);
 		}
 	}