msgencoder.java

apache.mina网络开源框架的例子

package com.yidatone.sms.mina.mccenter.codec;

import java.util.Collections;
import java.util.HashSet;
import java.util.Set;
import org.apache.mina.common.ByteBuffer;
import org.apache.mina.common.IoSession;
import org.apache.mina.filter.codec.ProtocolEncoderOutput;
import org.apache.mina.filter.codec.demux.MessageEncoder;

public class MsgEncoder implements MessageEncoder 
{
	protected Set types;
	
	public MsgEncoder()
	{
		Set tp = new HashSet();
		tp.add(String.class);
		this.types=Collections.unmodifiableSet(tp);
	}
	
	public Set getMessageTypes() 
	{
		return types;
	}
	
	public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception 
	{
		ByteBuffer bf = ByteBuffer.allocate(message.toString().getBytes().length);
		bf.put(message.toString().getBytes());
		bf.flip();
		out.write(bf);
	}
}