历史总是惊人的相似 2015-02-02 10:11 采纳率: 100%
浏览 5747

怎么样调用mina的messageReceived中得到的返回值

 public void messageReceived(IoSession session, Object packet) throws Exception {
        System.out.println("Received == " + packet.toString());
    }

mina中有个messageReceived方法,我已经从客户端把消息发送给服务器,也成功收到了服务器返回的数据,但是我现在想在另一个类中用这个返回的数据packet,怎么能调用它呢?

求懂的人告诉一下方法,编程新人不是很懂,卡在这不知道怎么继续了。

  • 写回答

2条回答 默认 最新

  • 三湿地 2015-02-25 09:01
    关注

    ConnectFuture future = getConnector().connect(new InetSocketAddress(PORT));
    future.awaitUninterruptibly(5, TimeUnit.SECONDS);
    session = future.getSession();
    session.getConfig().setUseReadOperation(true);

    Object message = session.read().awaitUninterruptibly().getMessage();
    byte[] bytes = (byte[]) message;
    System.out.println(new String(bytes));

    handle其实就是一个拦截器,你可以直接new IoHandlerAdapter(),不做任何处理都可以。

    session.read().awaitUninterruptibly()就是等待服务端返回消息。

    其实就是把读消息变成同步阻塞的了。其实大多数客户端都是阻塞的情况。

    评论

报告相同问题?

悬赏问题

  • ¥20 ML307A在使用AT命令连接EMQX平台的MQTT时被拒绝
  • ¥20 腾讯企业邮箱邮件可以恢复么
  • ¥15 有人知道怎么将自己的迁移策略布到edgecloudsim上使用吗?
  • ¥15 错误 LNK2001 无法解析的外部符号
  • ¥50 安装pyaudiokits失败
  • ¥15 计组这些题应该咋做呀
  • ¥60 更换迈创SOL6M4AE卡的时候,驱动要重新装才能使用,怎么解决?
  • ¥15 让node服务器有自动加载文件的功能
  • ¥15 jmeter脚本回放有的是对的有的是错的
  • ¥15 r语言蛋白组学相关问题