serverhandler.java

使用JAVA NIO异步socket的多线程源代码

/**
 * Created at Nov 10, 2008
 */
package com.jdev.net.event;

/**
 * <p>Title: ServerHandler</p>
 * <p>Description: 处理服务器端受理客户请示的各类事件, 在这里实现具体应用</p>
 * @author Lawrence
 * @version 1.0
 */
public class ServerHandler extends EventAdapter {

	/**
	 * 
	 */
	public ServerHandler() {

	}

	/* (non-Javadoc)
	 * @see com.jdev.net.event.EventAdapter#onAccept()
	 */
	@Override
	public void onAccept() throws Exception {
		System.out.println("#onAccept()");
	}

	/* (non-Javadoc)
	 * @see com.jdev.net.event.EventAdapter#onAccepted(com.jdev.net.event.Request)
	 */
	@Override
	public void onAccepted(Request request) throws Exception {
		System.out.println("#onAccepted()");
	}

	/* (non-Javadoc)
	 * @see com.jdev.net.event.EventAdapter#onClosed(com.jdev.net.event.Request)
	 */
	@Override
	public void onClosed(Request request) throws Exception {
		System.out.println("#onClosed()");
	}

	/* (non-Javadoc)
	 * @see com.jdev.net.event.EventAdapter#onError(java.lang.String)
	 */
	@Override
	public void onError(String error) {
        System.out.println("#onAError(): " + error);

	}

	/* (non-Javadoc)
	 * @see com.jdev.net.event.EventAdapter#onRead(com.jdev.net.event.Request)
	 */
	@Override
	public void onRead(Request request) throws Exception {
        //byte[] rspData = data;
        //if (new String (data).equalsIgnoreCase("query")) {
        //    rspData = new java.util.Date().toString().getBytes();
        //}
        //request.attach(rspData);
        //System.out.println("#onRead()");
	}

	/* (non-Javadoc)
	 * @see com.jdev.net.event.EventAdapter#onWrite(com.jdev.net.event.Request, com.jdev.net.event.Response)
	 */
	@Override
	public void onWrite(Request request, Response response) throws Exception {
        //System.out.println("#onWrite()");
        //response.send((byte[])request.attachment());
        //response.send("OK".getBytes());
	}

}