doukk 2012-04-24 17:57
浏览 247
已采纳

Mina客户端问题

Mina客户端问题

服务端是 C 写,客户端使用 Main

[code="java"]
public class MainClient {

/**
 * @param args
 * @throws InterruptedException 
 */
public static void main(String[] args) throws InterruptedException {
    //创建 tcp/ip 连接
    NioSocketConnector connector = new NioSocketConnector();

    //创建接收数据的过滤器
    DefaultIoFilterChainBuilder chin = connector.getFilterChain();

    //设定这个过滤器将一行一行的读取数据
    chin.addLast("mychin", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));

    //设定客户端消息处理器
    connector.setHandler(new SamplMinaClientHandler());
    //设置连接超时时间
    connector.setConnectTimeout(30);

    //连接到服务器
    ConnectFuture future = connector.connect(new InetSocketAddress("192.168.2.201",31024));

    future.awaitUninterruptibly();
    future.getSession().getCloseFuture().awaitUninterruptibly();
    connector.dispose();
}

}
[/code]

客户端处理器 SamplMinaClientHandler

[code="java"]
public class SamplMinaClientHandler extends IoHandlerAdapter {
//当客户端连接进入时
@Override
public void sessionOpened(IoSession session) throws Exception {

    System.out.println("incomming 客户端: "+session.getRemoteAddress());

    byte[] param = new byte[]{(byte)4,(byte)1,(byte)5};
    IoBuffer io = IoBuffer.wrap(getA(param));
    session.write(io);
}

//当客户端发送消息到达时
@Override
public void messageReceived(IoSession session, Object message)
        throws Exception {

    IoBuffer by = (IoBuffer)message;
    byte[] b = new byte[by.limit()]; 
    by.get(b);

    System.out.println("服务器返回的数据:"+new String(b));
}

}
[/code]

问题: byte数组发送出去了 从TCP监控软件可以看到发出去的报文及返回的数据,为什么客户端接收不到 一直处于阻塞状态?

  • 写回答

5条回答 默认 最新

  • iteye_13371 2012-04-27 18:47
    关注

    看一下mina自带的文档吧,有编码器解码器的例子,例如上面那个TextLineCodecFactory的源代码

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(4条)

报告相同问题?

悬赏问题

  • ¥15 进行基于用户的协同过滤推荐,使用准确率和召回率评价推荐模型的效果
  • ¥15 关于#cesium#的问题:cesium 根据经纬度、高度、方位角、俯仰角和距离求另一点高度
  • ¥15 word脚注设置不起空格符号
  • ¥15 为什么apriori的运行时间会比fp growth的运行时间短呢
  • ¥15 求解密json或者美化
  • ¥15 帮我解决一下膳食平衡的线性规划模型的数据实例
  • ¥40 万年历缺少农历,需要和阳历同时显示
  • ¥250 雷电模拟器内存穿透、寻基址和特征码的教学
  • ¥15 关于Java的学习问题
  • ¥15 如何使用chatgpt完成文本分类任务?