android studio多人聊天（带本地表情包、服务器）

import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.Socket; import java.util.ArrayList; import java.util.Collections; import java.util.Iterator; import java.util.List; public class Client implements Runnable { Socket socket; List<Client> clients ; public static final int SHOWMSG = 0x003; private DataInputStream mDataInputStream = null; private DataOutputStream mDataOutputStream = null; private boolean Conneted = false; public Client(Socket socket){ this.socket = socket; try { mDataInputStream = new DataInputStream(socket.getInputStream()); mDataOutputStream = new DataOutputStream(socket.getOutputStream()); Conneted = true; clients =new ArrayList<Client>(); } catch (IOException e) { e.printStackTrace(); } }; /** * 发送消息 */ public void send(String string){ try { mDataOutputStream.writeUTF(string);//向输入流中写入数据 System.out.println("向输入流中写入数据"); } catch (IOException e) { e.printStackTrace(); // Server.clients.remove(this);//出错时，客户端可能已断线，移除当前客户端 System.out.println("出错时，客户端可能已断线，移除当前客户端"); } } @Override public void run() { while(Conneted){ try { System.out.println("连接成功！"); //读取数据 String str = mDataInputStream.readUTF(); clients = Server.clients; synchronized (clients) { Iterator<Client> iterator =clients.iterator(); while (iterator.hasNext()) { Client client = iterator.next(); //将读取的数据发送回去 System.out.println("将读取的数据发送回去"+str); client.send(str); } // Conneted = false; } } catch (IOException e) { e.printStackTrace(); break； Server.clients.remove(this); System.out.println("线程出现异常"); }finally{ // try { //// mDataOutputStream.close(); //// mDataInputStream.close(); // } catch (IOException e) { // // TODO Auto-generated catch block // e.printStackTrace(); // } } } } }