//服務(wù)端主類
public class MyServer
{
  public static List<Socket> socketList = Collections.synchronizedList(new ArrayList<Socket>());
  public static void main(String[] args) throws IOException
  {
    ServerSocket ss = new ServerSocket(30000);
    while (true)
    {
      //此行代碼會(huì)阻塞，將一直等待別人的連接
      Socket s = ss.accept();
      socketList.add(s);
      //每當(dāng)客戶端連接后啟動(dòng)一個(gè)ServerThread線程為該客戶端服務(wù)
      new Thread(new ServerThread(s)).start();
    }
  }
}

public class ServerThread implements Runnable
{
  //定義當(dāng)前線程所處理的Socket
  Socket s = null;
  //該線程所處理的Socket對(duì)應(yīng)的輸入流
  BufferedReader br = null;
  public ServerThread(Socket s) throws IOException
  {
    this.s = s;
    //初始化該Socket對(duì)應(yīng)的輸入流
    br = new BufferedReader(new InputStreamReader(s.getInputStream()));
  }

  @Override
  public void run()
  {
    try
    {
      String content = null;
      //采用循環(huán)不斷地從Socket中讀取客戶端發(fā)送來的數(shù)據(jù)
      while ((content = readFromClient()) != null)
      {
        //遍歷socketList中的每個(gè)Socket
        //將讀到的內(nèi)容向每個(gè)Socket發(fā)送一次
        for (Socket s : MyServer.socketList)
        {
          PrintStream ps = new PrintStream(s.getOutputStream());
          ps.println(content);
        }
      }
    }
    catch (IOException e)
    {
      e.printStackTrace();
    }
  }

  //定義讀取客戶端數(shù)據(jù)的方法
  private String readFromClient()
  {
    try
    {
      return br.readLine();
    }
    //如果捕獲到異常，則表明該Socket對(duì)應(yīng)的客戶端已經(jīng)關(guān)閉
    catch (IOException e)
    {
      //刪除該Socket
      MyServer.socketList.remove(s);
    }
    return null;
  }
}

//用戶界面Activity
public class MainActivity extends Activity
{
  private EditText mReceiverMsg;
  private Button mSendBtn;
  private EditText mSendMsg;
  Handler handler = new Handler()
  {
    @Override
    public void handleMessage(Message msg)
    {
      Log.d("mainActivity" , "okk");
      mReceiverMsg.append(msg.obj.toString());
    }
  };
  private Socket s;
  @Override
  protected void onCreate(Bundle savedInstanceState)
  {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.main_activity);

    initView();
    initSocket();
    mSendBtn.setOnClickListener(new View.OnClickListener()
    {
      @Override
      public void onClick(View view)
      {
        sendData();
      }
    });
  }

  private void initSocket()
  {
    new Thread()
    {
      @Override
      public void run()
      {
        try
        {
          s = new Socket("192.168.1.101" , 30000);
          new Thread(new ClientThread(s , handler)).start();
        }
        catch (IOException e)
        {
          e.printStackTrace();
        }
      }
    }.start();
  }

  private void initView()
  {
    mReceiverMsg = (EditText) findViewById(R.id.receiver_message);
    mSendMsg = (EditText) findViewById(R.id.send_message);
    mSendBtn = (Button) findViewById(R.id.send_button);
  }

  private void sendData()
  {
    try
    {
      //獲取該Socket對(duì)應(yīng)的輸出流
      PrintStream ps = new PrintStream(s.getOutputStream());
      if (TextUtils.isEmpty(mSendMsg.getText()))
      {
        Toast.makeText(this , "請(qǐng)輸入信息" , Toast.LENGTH_LONG).show();
        return;
      }
      ps.println(mSendMsg.getText().toString());
    }
    catch (IOException e)
    {
      e.printStackTrace();
    }
  }
}

public class ClientThread implements Runnable
{
  //該線程負(fù)責(zé)處理的Socket
  private Socket ss;
  //該線程所處理的Socket對(duì)應(yīng)的輸入流
  BufferedReader br = null;
  Handler handler;
  public ClientThread(Socket s , Handler handler) throws IOException
  {
    this.ss = s;
    this.handler = handler;
    br = new BufferedReader(new InputStreamReader(ss.getInputStream()));
  }

  @Override
  public void run()
  {
    try
    {
      String content = null;
      while ((content = br.readLine()) != null)
      {
        Message msg = new Message();
        msg.obj = content;
        handler.sendMessage(msg);
      }

    }
    catch (IOException e)
    {
      e.printStackTrace();
    }
  }
}