mina 实例(转载)

mina:http://mina.apache.org/

原文: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);