package?edu.hbmy.taotao.mina;

import?java.io.File;
import?java.io.FileNotFoundException;
import?java.io.FileOutputStream;
import?java.io.IOException;
import?java.net.InetSocketAddress;

import?org.apache.mina.core.future.ConnectFuture;
import?org.apache.mina.core.future.IoFuture;
import?org.apache.mina.core.future.IoFutureListener;
import?org.apache.mina.core.future.ReadFuture;
import?org.apache.mina.core.future.WriteFuture;
import?org.apache.mina.core.service.IoService;
import?org.apache.mina.core.session.IoSession;

import?org.apache.mina.filter.codec.ProtocolCodecFilter;
import?org.apache.mina.filter.codec.serialization.objectSerializationCodecFactory;
import?org.apache.mina.transport.socket.nio.NioSocketConnector;
import?org.slf4j.Logger;
import?org.slf4j.LoggerFactory;
import?net.sf.json.JSONobject;

public?class?MinaClient?{

	private?static?final?Logger?log?=?LoggerFactory.getLogger（MinaClient.class）;
	/**
	?*?服務器IP地址
	?*/
	private?String?serverIp?=?“127.0.0.1“;
	/**
	?*?服務端口號
	?*/
	private?int?PORT?=?9898;
	/**
	?*?服務器地址信息
	?*/
	private?InetSocketAddress?serverAddres?=new?InetSocketAddress（serverIpPORT）;
	/**
	?*?連接對象
	?*/
	private??NioSocketConnector?connector;
	/**
	?*?futuer對象
	?*/
	private?ConnectFuture?future;
	/**
	?*?session對象
	?*/
	private?IoSession?session;
	/**
	?*?單例模式
	?*/
	private?static?MinaClient?instance?=?new?MinaClient（）;
	public?static?MinaClient?getInstance（）?{
		return?instance;
	}
	
	public?boolean?connect（）{
		if?（connector!=null&&connector.isActive（））?{
			System.out.println（“服務器已連接“）;
			return?true;
		}
		connector?=?new?NioSocketConnector（）;
		connector.getSessionConfig（）.setUseReadOperation（true）;
		connector.setHandler（new?objectHandler（））;
		connector.getFilterChain（）.addLast（“codec“
				new?ProtocolCodecFilter（new?objectSerializationCodecFactory（）））;
		
		future?=?connector.connect（serverAddres）;
		//future.awaitUninterruptibly（）;//線程阻塞，等待連接服務器
		future.addListener（new?IoFutureListener（）?{

			@Override
			public?void?operationComplete（IoFuture?future）?{
				//?TODO?Auto-generated?method?stub
				if?（MinaClient.this.future.isConnected（））?{
					session?=?future.getSession（）;
				}
				else?{
					System.out.println（“連接服務器失敗“）;
				}
			}
		}）;
//		if?（future.isConnected（））?{
//			session?=?future.getSession（）;
//			System.out.println（“服務器連接成功!“）;
//		}else?{
//			session?=?null;
//			System.out.println（“服務器連接失敗！“）;
//		}
		return?true;
	}
	
	public?void?closeClient（）
	{
		if?（null?!=?session）?{
			IoService?ioService?=?session.getService（）;
			ioService.dispose（）;
			System.out.println（“客戶端關閉“）;
		}
		
	}
	
	public?void?sendPacket（Packet?packetSendPacketResult?result）{
		if?（session?!=null）?{
			WriteFuture?writeFuture?=??session.write（packet）;
			writeFuture.addListener（new?IoFutureListener（）?{
				@Override
				public?void?operationComplete（WriteFuture?future）?{
					//?T