mina通信服务器端客户端源码.rar

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