android socket 聊天实现与调试
1.废话不多说，附主要的Client类[ package com.boyaa.push.lib.service; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.InetSocketAddress; import java.net.Socket; import java.net.SocketException; import java.util.Iterator; import java.util.concurrent.LinkedBlockingQueue; import android.content.Context; import android.util.Log; import com.boyaa.push.lib.util.NetworkUtil; /** * * @author Administrator * */ public class Client { private final int STATE_OPEN=1;//socket打开 private final int STATE_CLOSE=1<<1;//socket关闭 private final int STATE_CONNECT_START=1<<2;//开始连接server private final int STATE_CONNECT_SUCCESS=1<<3;//连接成功 private final int STATE_CONNECT_FAILED=1<<4;//连接失败 private final int STATE_CONNECT_WAIT=1<<5;//等待连接 private String IP="192.168.1.100"; private int PORT=60000; private int state=STATE_CONNECT_START; private Socket socket=null; private OutputStream outStream=null; private InputStream inStream=null; private Thread conn=null; private Thread send=null; private Thread rec=null; private Context context; private ISocketResponse respListener; private LinkedBlockingQueue<Packet> requestQueen=new LinkedBlockingQueue<Packet>(); private final Object lock=new Object(); public int send(Packet in) { requestQueen.add(in); synchronized (lock) { lock.notifyAll(); } return in.getId(); } public void cancel(int reqId) { Iterator<Packet> mIterator=requestQueen.iterator(); while (mIterator.hasNext()) { Packet packet=mIterator.next(); if(packet.getId()==reqId) { mIterator.remove(); } } } public Client(Context context,ISocketResponse respListener) { this.context=context; this.respListener=respListener; } public boolean isNeedConn() { return !((state==STATE_CONNECT_SUCCESS)&&(null!=send&&send.isAlive())&&(null!=rec&&rec.isAlive())); } public void open() { reconn(); } public void open(String host,int port) { this.IP=host; this.PORT=port; reconn(); } private long lastConnTime=0; public synchronized void reconn() { if(System.currentTimeMillis()-lastConnTime<2000) { return; } lastConnTime=System.currentTimeMillis(); close(); state=STATE_OPEN; conn=new Thread(new Conn()); conn.start(); } public synchronized void close() { if(state!=STATE_CLOSE) { try { if(null!=socket) { socket.close(); } } catch (Exception e) { e.printStackTrace(); }finally{ socket=null; } try { if(null!=outStream) { outStream.close(); } } catch (Exception e) { e.printStackTrace(); }finally{ outStream=null; } try { if(null!=inStream) { inStream.close(); } } catch (Exception e) { e.printStackTrace(); }finally{ inStream=null; } try { if(null!=conn&&conn.isAlive()) { conn.interrupt(); } } catch (Exception e) { e.printStackTrace(); }finally{ conn=null; } try { if(null!=send&&send.isAlive()) { send.interrupt(); } } catch (Exception e) { e.printStackTrace(); }finally{ send=null; } try { if(null!=rec&&rec.isAlive()) { rec.interrupt(); } } catch (Exception e) { e.printStackTrace(); }finally{ rec=null; } state=STATE_CLOSE; } requestQueen.clear(); } private class Conn implements Runnable { public void run() { while(state!=STATE_CLOSE) { try { state=STATE_CONNECT_START; socket=new Socket(); socket.connect(new InetSocketAddress(IP, PORT), 15*1000); state=STATE_CONNECT_SUCCESS; } catch (Exception e) { e.printStackTrace(); state=STATE_CONNECT_FAILED; } if(state==STATE_CONNECT_SUCCESS) { try { outStream=socket.getOutputStream(); inStream=socket.getInputStream(); } catch (IOException e) { e.printStackTrace(); } send=new Thread(new Send()); rec=new Thread(new Rec()); send.start(); rec.start(); break; } else { state=STATE_CONNECT_WAIT; //如果有网络没有连接上，则定时取连接，没有网络则直接退出 if(NetworkUtil.isNetworkAvailable(context)) { try { Thread.sleep(15*1000); } catch (InterruptedException e) { e.printStackTrace(); break; } } else { break; } } } } } private class Send implements Runnable { public void run() { try { while(state!=STATE_CLOSE&&state==STATE_CONNECT_SUCCESS&&null!=outStream) { Packet item; while(null!=(item=requestQueen.poll())) { outStream.write(item.getPacket()); outStream.flush(); item=null; } synchronized (lock) { lock.wait(); } } }catch(SocketException e1) { e1.printStackTrace();//发送的时候出现异常，说明socket被关闭了(服务器关闭)java.net.SocketException: sendto failed: EPIPE (Broken pipe) reconn(); } catch (Exception e) { e.printStackTrace(); } } } private class Rec implements Runnable { public void run() {补充：移动开发 , Android ,
