1、該socket聯(lián)網(wǎng)對象類會導(dǎo)致攫取辦事端的數(shù)據(jù)產(chǎn)生壅塞

public class ConnectToServer {
	private static boolean D=true;
	private static InputStream mInputStream;
	private static OutputStream mOutputStream;

	public ConnectToServer() {
		// TODO Auto-generated constructor stub
	}
	/**
	 * 建立TCP連接
	 * @param ip 辦事端ip
	 * @param port 端口
	 */
	public static Socket conn(String ip,int port){
		try {
			
			Socket	socket=new Socket(InetAddress.getByName(ip), port);
			if(D){
				Log.i("Socket", (socket==null)+"");
			}
			
					return socket;
			
			} catch (Exception e) {
				// TODO: handle exception
			}
			
			
		
		return null;
		
	}
	
	/**
	 *  把數(shù)據(jù)msg發(fā)送到辦事端
	 * @param socket 
	 * @param msg 待發(fā)送的數(shù)據(jù)
	 */
	public static void sendReq(Socket socket,byte[] msg){
		try {
			mOutputStream=socket.getOutputStream();
			mOutputStream.write(msg);
			mOutputStream.flush();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		
	}
	
	/**
	 * 大年夜辦事端返回的數(shù)據(jù)
	 * @param socket
	 * @return
	 */
	public static byte[] recData( Socket socket){
		int count = 0;
		try {
			mInputStream=socket.getInputStream();
			byte[] inDatas = null;
			while (count == 0) {
				count = mInputStream.available();
			}
			inDatas = new byte[count];
			mInputStream.read(inDatas);
			return inDatas;
			
		} catch (IOException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
		
		
		return null;
		
		
	}
	/**
	 *  封閉連接釋放資本
	 * @param socket
	 */
	public static void closeConn(Socket socket){
		if(mOutputStream!=null){
			try {
				mOutputStream.close();
				mOutputStream=null;
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
		
		if(mInputStream!=null){
			try {
				mInputStream.close();
				mInputStream=null;
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
		if(socket!=null){
			try {
				socket.close();
				socket=null;
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
		
	}

}

2、在攫取辦事端數(shù)據(jù)的時(shí)刻，如不雅一段時(shí)光后沒有攫取到數(shù)據(jù)，則封閉連接釋放資本。（本對象類以5秒為例）

public class ConnectToServer {
	private static boolean D=true;
	private static InputStream mInputStream;
	private static OutputStream mOutputStream;

	public ConnectToServer() {
		// TODO Auto-generated constructor stub
	}
	/**
	 * 建立TCP連接
	 * @param ip 辦事端ip
	 * @param port 端口
	 */
	public static Socket conn(String ip,int port){
		try {
			
			Socket	socket=new Socket(InetAddress.getByName(ip), port);
			
		
					return socket;
				
			} catch (Exception e) {
				Log.i("異常信息", e.toString());
			}
			
			
		
		return null;
		
	}
	
	/**
	 *  把數(shù)據(jù)msg發(fā)送到辦事端
	 * @param socket 
	 * @param msg 待發(fā)送的數(shù)據(jù)
	 */
	public static void sendReq(Socket socket,byte[] msg){
		try {
			mOutputStream=socket.getOutputStream();
			mOutputStream.write(msg);
			mOutputStream.flush();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		
	}
	
	/**
	 * 大年夜辦事端返回的數(shù)據(jù)
	 * @param socket
	 * @return
	 */
	public static byte[] recData( Socket socket){
		int count = 0;
		try {
			mInputStream=socket.getInputStream();
			
			byte[] inDatas = null;
			while (count == 0) {
				count = mInputStream.available();
				try {
					//5秒后無響應(yīng)
					Thread.sleep(5000);
					if(mInputStream.available()==0){
						//封閉連接釋放資本
						closeConn(socket);
						break;
					}
				} catch (Exception e) {
					// TODO: handle exception
				}
				if(D){
					Log.i("攫取辦事端數(shù)據(jù)", mInputStream.available()+"");
				}
			}
			if(count==0){
				return null;
			}else{
				inDatas = new byte[count];
				mInputStream.read(inDatas);
				return inDatas;
			}
			
			
		} catch (IOException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
		
		
		return null;
		
		
	}
	/**
	 *  封閉連接釋放資本
	 * @param socket
	 */
	public static void closeConn(Socket socket){
		if(mOutputStream!=null){
			try {
				mOutputStream.close();
				mOutputStream=null;
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
		
		if(mInputStream!=null){
			try {
				mInputStream.close();
				mInputStream=null;
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
		if(socket!=null){
			try {
				socket.close();
				socket=null;
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
		
	}

}