mina 实例(转载)
原文:http://maosheng.iteye.com/blog/1891665
for(int j=0;j<5;j++){ // 发送两遍
byte[] bts = new byte[20];
for (int i = 0; i < 20; i++) {
bts[i] = (byte) i;
}
IoBuffer buffer = IoBuffer.allocate(20);
// 自动扩容
buffer.setAutoExpand(true);
// 自动收缩
buffer.setAutoShrink(true);
buffer.put(bts);
buffer.flip();
session.write(buffer);
Thread.sleep(2000);
}
// 关闭会话,待所有线程处理结束后
connector.dispose(true);
}
}