1.position
例:
position()
第一次使用返回值为当前位置:0
position(8) 返回第8个字节以后的数据(包括第8个)可以和 limit 联合使用
如:
buffer.position(3);
buffer.limit(7);
ByteBuffer slice = buffer.slice();
再次调用 position() 返回:8
2.remaining
例:
ByteBuffer byt = ByteBuffer.allocate(128,false);
第一次调用
byt.remaining(); 返回 128
A、使用:byt.putInt(5);或者byt.getInt()或者byt.get(字节数组)等方法
之后调用 byt.remaining(); 返回 124
B、但使用 byt.putInt(5,4);或者byt.getInt(0) 之后,调用方法
byt.remaining();返回 128
3.prefixedDataAvailable
prefixedDataAvailable(4) int
该方法很好用。判断前四字节的整型值是否大于等于整个缓冲区的数据。可以方便的判断一次
messageReceived 过来的数据是否完整。(前提是自己设计的网络通讯协议前四字节等于发送数据的长度)
prefixedDataAvailable(2) Short int
网上找到的例子:
protected boolean doDecode(IoSession session, IoBuffer in,
ProtocolDecoderOutput out) throws Exception {
if (in.prefixedDataAvailable(4, Constants.MAX_COMMAND_LENGTH)) {
int length = in.getInt();
byte[] bytes = new byte[length];
in.get(bytes);
int commandNameLength = Constants.COMMAND_NAME_LENGTH;
byte[] cmdNameBytes = new byte[commandNameLength];
System.arraycopy(bytes, 0, cmdNameBytes, 0, commandNameLength);
String cmdName = (new String(cmdNameBytes)).trim();
AbstractTetrisCommand command = TetrisCommandFactory
.newCommand(cmdName);
if (command != null) {
byte[] cmdBodyBytes = new byte[length - commandNameLength];
System.arraycopy(bytes, commandNameLength, cmdBodyBytes, 0,
length - commandNameLength);
command.bodyFromBytes(cmdBodyBytes);
out.write(command);
}
return true;
} else {
return false;
}
}
MINA中分段读取数据的方法:
2. ProtobufRPCRequestProtocolDecoder.java
package com.lizongbo.protobufrpc;
import org.apache.mina.filter.codec.ProtocolDecoder;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.filter.codec.ProtocolDecoderOutput;
import org.apache.mina.core.session.AttributeKey;
public class ProtobufRPCRequestProtocolDecoder implements ProtocolDecoder {
private static final AttributeKey BUF_BYTE = new AttributeKey(
ProtobufRPCRequestProtocolDecoder.class, "bufb");
public void decode(IoSession ioSession, IoBuffer ioBuffer,
ProtocolDecoderOutput protocolDecoderOutput) throws
Exception {
try {
IoBuffer bufTmp = null;
byte[] buf = (byte[]) ioSession.getAttribute(BUF_BYTE);
if (buf == null) {
System.out.println("没有尚未处理的数据" + ioBuffer.remaining());
bufTmp = ioBuffer;
} else {
System.out.println("合并尚未处理的数据" + ioBuffer.remaining());
bufTmp = IoBuffer.allocate(buf.length + ioBuffer.remaining());
bufTmp.setAutoExpand(true);
bufTmp.put(buf);
bufTmp.put(ioBuffer);
bufTmp.flip();
} while (bufTmp.remaining() >= 4
&& bufTmp.remaining() >= bufTmp.getInt(bufTmp.position())) { // 循环处理数据包
System.out.println("循环处理数据包");
int dataLen = bufTmp.getInt(bufTmp.position());
byte[] b = new byte[dataLen];
bufTmp.get(b);
ProtobufRPCRequest pak = new ProtobufRPCRequest();
pak.setReqByteLen(b.length);
pak.readFrom(b, 4);
System.out.println("往下传递");
protocolDecoderOutput.write(pak);
}
if (bufTmp.hasRemaining()) { // 如果有剩余的数据,则放入Session中
System.out.println("如果有剩余的数据,则放入Session中" + bufTmp.remaining());
byte[] tmpb = new byte[bufTmp.remaining()];
bufTmp.get(tmpb);
ioSession.setAttribute(BUF_BYTE, tmpb);
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
public void dispose(IoSession session) throws Exception {
System.out.println("dispose");
}
public void finishDecode(IoSession session, ProtocolDecoderOutput out) throws
Exception {
System.out.println("finishDecode");
}
}
分享到:
相关推荐
本代码主要针对于解决mina 断包,丢包问题,里面包含客户端,服务端,直接可以使用客户端可以进行测试
java mina组合包 非常齐全
项目包含有mina的服务端与客户端,客户端发送心跳包,服务端响应心跳包
apache-mina-2.0.4 mina框架的源码及jar包
Mina框架+常用JAR包 Mina框架+常用JAR包 Mina框架+常用JAR包 Mina框架+常用JAR包 Mina框架+常用JAR包 Mina框架+常用JAR包
Mina 实例 包含了所需要的jar包
Mina断包,粘包的处理。(完整实例,客户端,服务端)
mina运行最基本的demo,实现客户端输入数据的返回。其中还包含mina的jar包
mina2依赖jar包: commons-logging-1.2 log4j-1.2.17 mina-core-2.0.9 slf4j-api-1.7.7 slf4j-log4j12-1.7.21
MINA2所需要的所有JAR包 最近工作中要用的 不知道怎么把资源分设置为0
mina依赖所有jar包,2012年11月份整理最新资源
Java中使用Apache MINA框架所用的jar包,将其导入到项目中即可
该项目是本人真实项目中使用到的mina + spring+struts2 + mybatis框架,里面有详细的注释说明,以及一个完整的接收消息、入库、返回例子。对需要真实项目开发的人员来说,可以直接使用。 另外,如果需要更加详细的...
mina2源码
mina简单通信需要的包,博客地址http://blog.csdn.net/guozeming122/article/details/18552483
包含了官方例子中所有相关的jar包:log4j, mina-core, mina-integration-jmx, mina-statemachine, org.springframework.context, slf4j-api, slf4j-log4j12等
Mina2的中文用户手册,仅供互相学习参考,如有侵权立删
最新的 mina相关jar包 合集,里边有apache-mina-2.0.7-bin.zip,apache-mina-2.0.7-src.zip,log4j-1.2.17.zip,slf4j-api-1.6.6.jar,slf4j-api-1.6.6-sources.jar,slf4j-log4j12-1.6.6.jar,mina-example-2.0.7....
学习研究 mina 1.17 。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。。
mina.jar 包,内涵mina所需的所有jar包, 解压即可,测试可用。mina.jar 包,内涵mina所需的所有jar包, 解压即可,测试可用。