request.java

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

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

import java.nio.channels.SocketChannel;

/**
 * <p>Title: Request</p>
 * <p>Description: 客户端请求信息</p>
 * @author Lawrence
 * @version 1.0
 */
public class Request {
	/**
	 * SelecableChannel 实现
	 */
	private SocketChannel sc;
	private byte[] dataInput = null;;
	Object obj;

	public Request(SocketChannel sc) {
		this.sc = sc;
	}

	public java.net.InetAddress getAddress() {
		return sc.socket().getInetAddress();
	}

	public int getPort() {
		return sc.socket().getPort();
	}

	public boolean isConnected() {
		return sc.isConnected();
	}

	public boolean isBlocking() {
		return sc.isBlocking();
	}

	public boolean isConnectionPending() {
		return sc.isConnectionPending();
	}

	public boolean getKeepAlive() throws java.net.SocketException {
		return sc.socket().getKeepAlive();
	}

	public int getSoTimeout() throws java.net.SocketException {
		return sc.socket().getSoTimeout();
	}

	public boolean getTcpNoDelay() throws java.net.SocketException {
		return sc.socket().getTcpNoDelay();
	}

	public boolean isClosed() {
		return sc.socket().isClosed();
	}

	public void attach(Object obj) {
		this.obj = obj;
	}

	public Object attachment() {
		return obj;
	}

	public byte[] getDataInput() {
		return dataInput;
	}

	public void setDataInput(byte[] dataInput) {
		this.dataInput = dataInput;
	}

}