Android实现简单C/S聊天室应用

import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import java.util.ArrayList;  public class MyServer{ //定义保存所有Socket的ArrayList public static ArrayList<Socket> socketList  = new ArrayList<Socket>();  public static void main(String[] args)  throws IOException  {    ServerSocket ss = new ServerSocket(8000); while(true) {  //此行代码会阻塞，将一直等待别人的连接  Socket s = ss.accept();  socketList.add(s);  //每当客户端连接后启动一条ServerThread线程为该客户端服务  new Thread(new ServerThread(s)).start();}

import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.Socket;   //负责处理每个线程通信的线程类public class ServerThread implements Runnable { //定义当前线程所处理的Socket Socket s = null; //该线程所处理的Socket所对应的输入流 BufferedReader br = null; public ServerThread(Socket s) throws IOException { this.s = s; //初始化该Socket对应的输入流 br = new BufferedReader(new InputStreamReader(  s.getInputStream() , "utf-8"));  //② } public void run() { try {  String content = null;  //采用循环不断从Socket中读取客户端发送过来的数据  while ((content = readFromClient()) != null)  {  //遍历socketList中的每个Socket，  //将读到的内容向每个Socket发送一次  for (Socket s : MyServer.socketList)  {   OutputStream os = s.getOutputStream();   os.write((content + "/n").getBytes("utf-8"));  }  } } catch (IOException e) {  e.printStackTrace(); } } //定义读取客户端数据的方法 private String readFromClient() { try {  return br.readLine();  } //如果捕捉到异常，表明该Socket对应的客户端已经关闭 catch (IOException e) {  //删除该Socket。  MyServer.socketList.remove(s);  //① } return null; }}

<?xml version="1.0" encoding="utf-8"?><LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" android:orientation="vertical" android:layout_width="fill_parent" android:layout_height="fill_parent" ><LinearLayout  android:orientation="horizontal" android:layout_width="fill_parent" android:layout_height="wrap_content" ><!-- 定义一个文本框，它用于接受用户的输入 --><EditText android:id="@+id/input"  android:layout_width="240px"  android:layout_height="wrap_content"  /><Button android:id="@+id/send"  android:layout_width="fill_parent"  android:layout_height="wrap_content"  android:paddingLeft="8px" android:text="@string/send" /></LinearLayout><!-- 定义一个文本框，它用于显示来自服务器的信息 --><EditText android:id="@+id/show"  android:layout_width="fill_parent"  android:layout_height="fill_parent"  android:gravity="top" android:editable="false"  android:cursorVisible="false"  /></LinearLayout>

package org.wwj.net; import java.io.OutputStream;import java.net.Socket; 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 MultiThreadClient extends Activity{ // 定义界面上的两个文本框 EditText input, show; // 定义界面上的一个按钮 Button send; OutputStream os; Handler handler;  @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.main); input = (EditText) findViewById(R.id.input); send = (Button) findViewById(R.id.send); show = (EditText) findViewById(R.id.show); Socket s; handler = new Handler() {  @Override  public void handleMessage(Message msg)  {  // 如果消息来自于子线程  if (msg.what == 0x123)  {   // 将读取的内容追加显示在文本框中   show.append("/n" + msg.obj.toString());  }  } }; try {  s = new Socket("183.30.181.228 ", 8000);  // 客户端启动ClientThread线程不断读取来自服务器的数据  new Thread(new ClientThread(s, handler)).start(); // ①  os = s.getOutputStream(); } catch (Exception e) {  e.printStackTrace(); } send.setOnClickListener(new OnClickListener() {  @Override  public void onClick(View v)  {  try  {   // 将用户在文本框内输入的内容写入网络   os.write((input.getText().toString() + "/r/n")   .getBytes("utf-8"));   // 清空input文本框   input.setText("");  }  catch (Exception e)  {   e.printStackTrace();  }  } }); }}

package org.wwj.net; import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.net.Socket; import android.os.Handler;import android.os.Message; public class ClientThread implements Runnable{ //该线程负责处理的Socket private Socket s; private Handler handler; //该线程所处理的Socket所对应的输入流 BufferedReader br = null; public ClientThread(Socket s , Handler handler) throws IOException { this.s = s; this.handler = handler; br = new BufferedReader(  new InputStreamReader(s.getInputStream())); } public void run() { try {  String content = null;  //不断读取Socket输入流中的内容。  while ((content = br.readLine()) != null)  {  // 每当读到来自服务器的数据之后，发送消息通知程序界面显示该数据  Message msg = new Message();  msg.what = 0x123;  msg.obj = content;  handler.sendMessage(msg);  } } catch (Exception e) {  e.printStackTrace(); } }}