request.java

java NIO源代码,初学者学习java NIO技术的基础代码

package org.Arios.XWrap;

import java.io.IOException;
import java.net.InetAddress;
import java.net.SocketException;
import java.nio.channels.SelectionKey;
import java.nio.channels.SocketChannel;

/**
 * 客户端请求处理类
 * 
 * @author Arios
 * 
 */
public class Request {
	private SocketChannel sc;
	private byte[] dataInput;
	private Object obj;
	private SelectionKey key;

	/**
	 * 构造子
	 * 
	 * @param sc
	 */
	public Request(SocketChannel sc) {
		this.sc = sc;
	}

	public SelectionKey getRegisterKey() {
		return key;
	}
	
	public SocketChannel getSocketChannel(){
		return sc;
	}

	/*
	 * 获取客户端地址
	 */
	public 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();
	}

	/*
	 * 判断客户端的socket是不是已经断开或者出现异常
	 */
	public boolean getKeepAlive() throws SocketException {
		return sc.socket().getKeepAlive();
	}

	/*
	 * 返回 SO_TIMEOUT 的设置。返回 0 意味着禁用了选项（即无穷大的超时值）。
	 */
	public int getSoTimeout() throws SocketException {
		return sc.socket().getSoTimeout();
	}

	/*
	 * 测试是否启用 TCP_NODELAY。是否开启tcp延迟
	 */
	public boolean getTcpNoDelay() throws 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;
	}
	
	public void cancel() throws IOException{
		sc.socket().close();
		sc.close();
	}
}