testappprocessor.java

一个java的server模版程序

package com.ec.generalserver;

import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;

public class TestAppProcessor extends AppProcessor
{

	public void doProcess(Connection conn) throws ConnectionProcessException
	{
		// TODO Auto-generated method stub
		try
		{
			ByteBuffer buf = ByteBuffer.allocate(1024);
		
			SocketChannel sock = conn.getSocket();
			sock.read(buf);
			buf.flip();
			sock.write(buf);
		}
		catch(Exception e)
		{
			e.printStackTrace();
			throw new ConnectionProcessException(conn,"exception occur"+e.getLocalizedMessage());
		}
	}
}