亚洲欧美日韩久久精品,国产亚洲精品免费视频播放 ,亚洲欧洲无卡二区视頻

mina encode

package org.upeng.mail.net.util;

import org.apache.mina.core.buffer.IoBuffer;

import org.apache.mina.core.session.IoSession;

import org.apache.mina.filter.codec.CumulativeProtocolDecoder;

import org.apache.mina.filter.codec.ProtocolDecoderOutput;

public class MessageDecoder extends CumulativeProtocolDecoder

{

public static final int MAX_IMAGE_SIZE = 1024 * 1024 * 5;

private static final String DECODER_STATE_KEY = getKey();

protected boolean doDecode(IoSession session, IoBuffer in,

ProtocolDecoderOutput out) throws Exception

{

System.out.println("decode-開始");

Context context = (Context) session.getAttribute(DECODER_STATE_KEY);

if(context == null)

{

context = new Context();

session.setAttribute(DECODER_STATE_KEY, context);

}

while(true)

{

if (in.prefixedDataAvailable(4, MAX_IMAGE_SIZE))

{

int pieceLength = in.getInt();

int totalLength = in.getInt();

context.setTotalLength(totalLength);

byte[] bytes = new byte[pieceLength - 4];

in.get(bytes);

context.addPiece(bytes);

if (context.isComplete())

{

Message message = new Message(context.getTotalData());

out.write(message);

session.removeAttribute(DECODER_STATE_KEY);

return true;

}

else

{

return false;

}

//System.out.println("decode-結束");

//return false;

}

/**

* <ul>

* <li>Description:[得到鍵值]</li>

* <li>Created by [Huyvanpull] [2011-9-5]</li>

* <li>Midified by [modifier] [modified time]</li>

* </ul>

* @return

private static String getKey()

{

return MessageDecoder.class.getName() + ".STATE";

}

package org.upeng.mail.net.util;

import java.util.List;

import org.apache.mina.core.buffer.IoBuffer;

import org.apache.mina.core.session.IoSession;

import org.apache.mina.filter.codec.ProtocolEncoderAdapter;

import org.apache.mina.filter.codec.ProtocolEncoderOutput;

public class MessageEncoder extends ProtocolEncoderAdapter

{

public void encode(IoSession session, Object message,

ProtocolEncoderOutput out) throws Exception

{

System.out.println("encode-開始");

Message msg = (Message) message;

IoBuffer buffer = IoBuffer.allocate(1024).setAutoExpand(true);

// 定義上下文

Context context = new Context(msg.getDataBody());

List<byte[]> pieceLst = context.getPieceLst();

for (int i=0; i<pieceLst.size(); i++)

{

byte[] temp = pieceLst.get(i);

buffer.putInt(temp.length + 4);

buffer.putInt(msg.getDataBody().length);

buffer.put(temp);

}

buffer.flip();

out.write(buffer);

out.flush();

System.out.println("decode-結束");

}

posted on 2011-09-05 19:17 HUIKK 閱讀(959) 評論(0) 編輯收藏所屬分類: Java

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: PP代碼生成器(四) 使用解決方案生成代碼 PP代碼生成器(三) 設計freemarker模板, 創建解決方案 PP代碼生成器(二) 解決方案, 生成任務, 輔助設計面板 PP代碼生成器(一) 簡介, 下載, 運行 PP持久層代碼生成器 eclipse maven 平衡二叉樹,java實現數據結構復習萬能分頁標簽優化Servlet配置為web.xml瘦身

夢幻之旅

公告

常用鏈接

留言簿(21)

隨筆分類(644)

隨筆檔案(669)

文章檔案(6)

最新隨筆

積分與排名

最新評論

閱讀排行榜

評論排行榜