android使用Socket通信实现多人聊天应用

package scoket.activity; 
 
import java.io.BufferedReader; 
import java.io.IOException; 
import java.io.InputStreamReader; 
import java.io.OutputStream; 
import java.io.UnsupportedEncodingException; 
import java.net.ServerSocket; 
import java.net.Socket; 
import java.util.ArrayList; 
import java.util.List; 
 
public class ScoketDemo { 
 public static List<Socket> clients = new ArrayList<Socket>();// 创建一个集合存放所有的客户端 
 
 /** 
  * @param args 
  * @throws IOException 
  */ 
 public static void main(String[] args) throws IOException { 
  // TODO Auto-generated method stub 
  ServerSocket ss; 
  while (true) { 
   ss = new ServerSocket(2019); 
   Socket s = ss.accept();// 使服务端处于监听状态 
 
   clients.add(s); 
   // 为每一个客户端开设一个单个线程 
   new ChatThread(s).start(); 
 
   // OutputStream os=client.getOutputStream(); 
   // os.write("Nice to meet you!".getBytes("utf-8")); 
   // os.close();//网络编程流的关闭是按栈的方式关闭的 
   // client.close(); 
  } 
  // No enclosing instance of type ScoketDemo is accessible. Must qualify 
  // the allocation 
  // with an enclosing instance of type 
  // ScoketDemo (e.g. x.new A() where x is an instance of ScoketDemo). 
 } 
 
 public static class ChatThread extends Thread { 
 
  Socket client; 
  BufferedReader br; 
 
  public ChatThread(Socket c) { 
   super(); 
   this.client = c; 
 
   try { 
    br = new BufferedReader(new InputStreamReader( 
      client.getInputStream(), "UTF-8"));// 将客户端对象封装一下 
   } catch (UnsupportedEncodingException e) { 
    // TODO Auto-generated catch block 
    e.printStackTrace(); 
   } catch (IOException e) { 
    // TODO Auto-generated catch block 
    e.printStackTrace(); 
   } 
 
  } 
 
  @Override 
  public void run() { 
   // TODO Auto-generated method stub 
   super.run(); 
   String content = null; 
   // 获取客户端传递过来的数据 
   try { 
    while ((content = br.readLine()) != null) { 
     // 再将服务端的数据返回给客户端 
     OutputStream os = client.getOutputStream(); 
     os.write(content.getBytes("utf-8")); 
    } 
   } catch (UnsupportedEncodingException e) { 
    // TODO Auto-generated catch block 
    e.printStackTrace(); 
   } catch (IOException e) { 
    // TODO Auto-generated catch block 
    e.printStackTrace(); 
   } 
  } 
 
 } 
} 

package com.scoket.activity; 
 
import java.io.BufferedReader; 
import java.io.IOException; 
import java.io.InputStream; 
import java.io.InputStreamReader; 
import java.net.Socket; 
import java.net.UnknownHostException; 
 
import android.app.Activity; 
import android.os.Bundle; 
import android.os.Handler; 
import android.os.Message; 
import android.view.View; 
import android.view.View.OnClickListener; 
import android.widget.Button; 
import android.widget.EditText; 
 
public class ChatScoketDemoActivity extends Activity implements OnClickListener { 
 /** Called when the activity is first created. */ 
 private EditText name, setence, show; 
 private Button btn; 
 Socket client; 
 Handler myHandler = new Handler() { 
  public void handleMessage(android.os.Message msg) { 
   if (msg.what==123) { 
    String str = show.getText().toString(); 
    show.setText(str +"\n"+ msg.getData().getString("chat")); 
   } 
    
  }; 
 }; 
 
 public void onCreate(Bundle savedInstanceState) { 
  super.onCreate(savedInstanceState); 
  setContentView(R.layout.main); 
  btn = (Button) findViewById(R.id.button1); 
  name = (EditText) findViewById(R.id.name); 
  setence = (EditText) findViewById(R.id.setence); 
  show = (EditText) findViewById(R.id.show); 
 
  btn.setOnClickListener(this); 
  new Thread(new Runnable() { 
 
   @Override 
   public void run() { 
    // TODO Auto-generated method stub 
    try { 
     client = new Socket("172.20.52.26", 2019);// 网络访问最好放在线程中 
     new chatThread(client).start();// 启动子线程 
    } catch (UnknownHostException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } catch (IOException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 
   } 
  }).start(); 
   
 } 
 
 @Override 
 public void onClick(View arg0) { 
  // TODO Auto-generated method stub 
  String s1 = name.getText().toString(); 
  String s2 = setence.getText().toString(); 
  String s3 = s1 + ":" + s2+"\n"; 
  if (client != null) { 
   try { 
    client.getOutputStream().write(s3.getBytes("utf-8"));// 获取从客户端得到的数据 
   } catch (IOException e) { 
    // TODO Auto-generated catch block 
    e.printStackTrace(); 
   } 
  } //setence.setText("");//相当于刷新 
 } 
 
 class chatThread extends Thread { 
  Socket s; 
 
  public chatThread(Socket s) { 
   super(); 
   this.s = s; 
  } 
 
  @Override 
  public void run() { 
 
   try { 
    BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream())); 
    while (true) { 
     String content = br.readLine(); 
     if (content != null) { 
      Bundle bundle = new Bundle(); 
      bundle.putString("chat", content); 
      Message msg = new Message(); 
      msg.setData(bundle); 
      msg.what=123; 
      myHandler.sendMessage(msg); 
     } 
 
    } 
   } catch (IOException e) { 
    // TODO Auto-generated catch block 
    e.printStackTrace(); 
   } 
  } 
 
 } 
}