MINA 线程安全问题

wodeanglea 发布于 2016/05/10 13:16
阅读 740
收藏 0

自己写了一个mina单工长连接,(new了4个NioSocketAccepter,4根线),自定义decoder 继承CumulatieProtocolDecoder类,发现Iobuffer里get到的数据有的时候会串,感觉像线程不安全,不知怎么解决?

protected boolean doDecode(IoSession ioSession, IoBuffer in, ProtocolDecoderOutput out) throws Exception { if (in.remaining() > 4){
        in.mark();  byte[] l = new byte[4];  in.get(l);   int len = Integer.valueOf(new String(l)).intValue();  System.out.println("received len = " + len);   if (in.remaining() < len){
            in.reset();  return false;  }else{
            in.reset();  int sumlen = 4 + len;  byte[] packArr = new byte[sumlen];  in.get(packArr, 0, sumlen);   out.write(packArr);   if(in.remaining() > 0){ return true;  }

        }


    } return false; }
加载中
返回顶部
顶部