public boolean send(long sessionId, byte[] msg) { try { IoSession session = getSession(sessionId); if (session != null && session.isConnected()) { WriteFuture wf = session.write(msg); wf.awaitUninterruptibly(1000); if(wf.isWritten()) return true; else { Throwable tr = wf.getException(); if(tr != null) { logger.error(tr.getMessage(), tr); } return false; } } } catch (Exception ex) { logger.error(ex.getMessage(), ex); } return false; }
时间: 2024-01-06 12:06:56 浏览: 147
这段代码是一个发送消息的方法,它接收一个长整型的 sessionId 和一个字节数组 msg 作为参数,返回一个布尔值。它首先通过 getSession(sessionId) 方法获取一个 IoSession 实例,如果 session 不为 null 且已连接,就将 msg 写入 session 中,并等待写入完成,最后返回写入结果的布尔值。
如果写入成功,返回 true;如果写入失败,返回 false,并记录日志。如果写入过程中发生异常,捕获异常并记录日志,最后返回 false。
阅读全文