package com.dy.common.mw.channel.tcp;

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;

public class TcpIoHandler extends IoHandlerAdapter {

	private TcpUnitAdapter adapter ;

	private boolean stop = false ;//为true时，停止TCP服务，并把已经TCP连接断连接

	public TcpIoHandler(TcpUnitAdapter adapter){
		this.adapter = adapter ;
	}

	public void stop(){
		stop = true ;
	}

	public void recover(){
		this.stop = false ;
	}

	/**
	 * 创建了会话
	 */
	@Override
	public void sessionCreated(IoSession session) throws Exception {
		if(stop){
			session.closeNow() ;
		}else{
			super.sessionCreated(session);
		}
	}
   
	/**
     * 会话open时回调的方法 
     */
    public void sessionOpened(IoSession session) throws Exception {
		if(stop){
			session.closeNow() ;
		}else{
			this.adapter.newSessionEventCallback().sessionOpened(session);
		}
    }
    
	/**
	 * 会话空闲
	 */
	@Override
	public void sessionIdle(IoSession session, IdleStatus status)
			throws Exception {
		super.sessionIdle(session, status);
	}
	
    /**
     * 输入关闭
     */
	@Override
	public void inputClosed(IoSession session) throws Exception {
		super.inputClosed(session);
	}
	
    /**
    * 网络关闭
    */
   @Override
	public void sessionClosed(IoSession session) throws Exception {
      	this.adapter.newSessionEventCallback().sessionClosed(session);
		super.sessionClosed(session);
	}

   /**
     * 发生异常
     */
   @Override
   public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
		this.adapter.newSessionEventCallback().exceptionCaught(session, cause);
    }
    
	/**
	 * 消息发送了
	 */
	@Override
	public void messageSent(IoSession session, Object message) throws Exception {
		super.messageSent(session, message);
		this.adapter.newSessionEventCallback().messageSended(session, message);
	}

    /**
     * 接收到数据后，回调的方法，进行数据处理
     */
	@Override
    public void messageReceived(IoSession session, Object message) throws Exception {
		if(stop){
			session.closeNow() ;
		}else{
			this.adapter.newSessionEventCallback().messageReceived(session, message);
		}
    }

}