Netty中ChannelId是否会随时间变化？Player注销异常求助

咱先直接给你个准信：Netty里一个Channel的ChannelId在它整个生命周期里是绝对固定的，不会因为时间推移、连接状态变化（比如断连）就变来变去。所以你怀疑ChannelId变了是错的，问题得从别的地方找。

先把你的场景和代码摆出来，方便大伙分析：

你的场景与代码 #

核心逻辑 #

你把Netty的Channel包装进Player对象，用ChannelId.asLongText()作为HashMap的key来管理所有在线玩家。但快速断开多个客户端后，执行unregisterPlayer时，用传入的ChannelId拿不到Player，返回null。

GameEngine中的Player管理代码 #

private HashMap<String, Player> players = new HashMap<String, Player>();

public void registerPlayer(Channel c, String name, String password) {
    Player p = new Player(c, name, password);
    players.put(c.id().asLongText(), p);
    try {
        Future<CredentialCheckResult> future = workerTasks.submit(new AuthenticateCredentialsTask(context.getDatabase().getConnection(), c.id().asLongText(), name, password));
        loginFutures.add(future);
    } catch (SQLException e) {
        System.out.println("["+Thread.currentThread().getName()+"] "+e.getMessage());
        return;
    }
    System.out.println("["+Thread.currentThread().getName()+"] Registered and added worker for logging in "+name+" ("+c.id().asLongText()+") 		 total players = "+players.size());
}

public void unregisterPlayer(String id) {
    System.out.println("["+Thread.currentThread().getName()+"] Unregistering player ("+id+") 		 total players = "+(players.size()-1));
    Player p = players.get(id);
    players.remove(id);
    if (p == null) {
        System.out.println("["+Thread.currentThread().getName()+"] P WAS NULL ("+id+") 		 total players = "+players.size());
    }
    if (p.getChannel().isActive()) {
        p.getChannel().close();
    }
}

ServerHandler的Channel事件处理 #

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    GameEngine game = context.getGameService();
    Packet p = (Packet) msg;
    if (p instanceof NewConnectionPacket) {
        NewConnectionPacket packet = (NewConnectionPacket) msg;
        game.queueLogic(new Runnable() {
            @Override
            public void run() {
                game.registerPlayer(ctx.channel(), packet.getUsername(), packet.getPassword());
            }
        });
    }
}

@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
    context.getGameService().queueLogic(new Runnable() {
        @Override
        public void run() {
            context.getGameService().unregisterPlayer(ctx.channel().id().asLongText());
        }
    });
    System.out.println("["+Thread.currentThread().getName()+"] " + " Kicked for inactive channel: "+ctx.channel().id().asLongText());
}

@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    System.err.println("["+Thread.currentThread().getName()+"] "+cause.getMessage());
    ctx.close();
}

关键前提 #

• 注册、注销都只在GameEngine线程执行，HashMap只有这个线程碰
• queueLogic是线程安全的，所有任务都提交给GameEngine线程
• 测试时用同一个账号登多个客户端，快速断开就会出现null问题

问题根源分析（和ChannelId无关！） #

既然ChannelId不会变，那为啥拿不到Player？主要有两个可能：

1. 同一个Channel被多次注销 #

快速断连时，很容易触发多次注销操作：

• 比如channelInactive触发一次注销，同时exceptionCaught里的ctx.close()又会触发一次channelInactive，导致同一个ChannelId被两次提交到GameEngine的任务队列
• 第一次注销已经把Player从HashMap里删了，第二次再拿自然就是null

怎么改？
先改unregisterPlayer的逻辑，先移除再判断，避免重复操作：

public void unregisterPlayer(String id) {
    System.out.println("["+Thread.currentThread().getName()+"] Unregistering player ("+id+") 		 total players = "+players.size());
    // 先remove再拿，逻辑更严谨，也避免重复移除的问题
    Player p = players.remove(id); 
    if (p == null) {
        System.out.println("["+Thread.currentThread().getName()+"] Player already unregistered ("+id+") 		 total players = "+players.size());
        return;
    }
    if (p.getChannel().isActive()) {
        p.getChannel().close();
    }
}

然后在exceptionCaught里加个判断，避免重复关闭Channel：

@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    System.err.println("["+Thread.currentThread().getName()+"] "+cause.getMessage());
    if (ctx.channel().isActive()) {
        ctx.close();
    }
}

2. 注销任务比注册任务先执行 #

客户端快速连了又断，可能出现：

• 客户端发完NewConnectionPacket就立刻断开，channelInactive的注销任务被先放到GameEngine的队列里
• 此时注册任务还没执行，HashMap里根本没这个ChannelId对应的Player，所以拿出来就是null

怎么改？
一是修复registerPlayer里的小bug：如果SQL异常，已经put进去的Player没被移除，会导致HashMap里有无效数据：

public void registerPlayer(Channel c, String name, String password) {
    String channelId = c.id().asLongText();
    Player p = new Player(c, name, password);
    players.put(channelId, p);
    try {
        Future<CredentialCheckResult> future = workerTasks.submit(new AuthenticateCredentialsTask(context.getDatabase().getConnection(), channelId, name, password));
        loginFutures.add(future);
    } catch (SQLException e) {
        System.out.println("["+Thread.currentThread().getName()+"] "+e.getMessage());
        players.remove(channelId); // 异常时把刚加的Player删掉
        return;
    }
    System.out.println("["+Thread.currentThread().getName()+"] Registered and added worker for logging in "+name+" ("+channelId+") 		 total players = "+players.size());
}

二是在Channel上绑定Player对象，注销时先从Channel拿，没有就不提交注销任务：
先定义个AttributeKey（可以放在GameEngine的常量里）：

public static final AttributeKey<Player> PLAYER_ATTR = AttributeKey.valueOf("PLAYER");

然后在registerPlayer里绑定：

players.put(channelId, p);
c.attr(GameEngine.PLAYER_ATTR).set(p); // 绑定到Channel上

最后修改channelInactive：

@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
    Player p = ctx.channel().attr(GameEngine.PLAYER_ATTR).get();
    if (p != null) {
        context.getGameService().queueLogic(new Runnable() {
            @Override
            public void run() {
                context.getGameService().unregisterPlayer(p.getChannel().id().asLongText());
            }
        });
    }
    System.out.println("["+Thread.currentThread().getName()+"] " + " Kicked for inactive channel: "+ctx.channel().id().asLongText());
}

这样如果注册任务还没执行，p就是null，不会提交无效的注销任务，自然就不会出现null的情况了。

总结 #

ChannelId真的不会变，你的问题就是重复注销或者注册注销任务顺序颠倒导致的。按照上面的方案调整代码，应该就能解决这个问题了。

内容的提问来源于stack exchange，提问作者MadsPH