android實現簡單的聊天室

練習android網絡知識。先介紹一下大概流程。首先是建立一個java工程，並創建兩個java類，一個用於接收到客戶端的連接，並把連接添加list中，第二類實現線程runnable接口，專門用來接收發送客戶發送的信息。其次，建立android工程，並創建兩個類，一個用於顯示聊天界面，另一個負責接收服務器端返回的信息。這個例子肯定會有考慮不周的地方但是只是為了學習android中網絡相關api的使用，所以請大家謹慎拍磚。
首先還是android的內容
[html] 
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android" 
    xmlns:tools="http://schemas.android.com/tools" 
    android:layout_width="match_parent" 
    android:layout_height="match_parent" > 
 
    <EditText 
        android:id="@+id/et_show" 
        android:layout_width="fill_parent" 
        android:layout_height="wrap_content" 
        android:lines="5" 
        android:hint="所有聊天信息" 
        android:gravity="center" 
         /> 
    <EditText 
        android:id="@+id/et_input" 
        android:layout_below="@+id/et_show" 
        android:layout_width="fill_parent" 
        android:layout_height="wrap_content" 
        android:hint="輸入聊天信息" 
        android:gravity="center" 
         /> 
    <Button  
        android:id="@+id/bt_send" 
        android:layout_below="@+id/et_input" 
        android:layout_width="fill_parent" 
        android:layout_height="wrap_content" 
        android:text="發送信息" 
        /> 
</RelativeLayout> 

接著是MainAvitvity.java
[java] 
public class MainActivity extends Activity { 
     
    private EditText et_show,et_input; 
    private Button bt_send; 
    private OutputStream os; 
    private Handler handler; 
 
    @Override 
    protected void onCreate(Bundle savedInstanceState) { 
        super.onCreate(savedInstanceState); 
        setContentView(R.layout.activity_main); 
         
        et_input = (EditText) this.findViewById(R.id.et_input); 
        et_show = (EditText) this.findViewById(R.id.et_show); 
        bt_send = (Button) this.findViewById(R.id.bt_send); 
         
         
        try { 
            //定義客戶連接的socket 
            Socket socket = new Socket("本機IP",30000); 
            //啟動客戶端監聽線程 
            new Thread(new ClinetThread(socket,handler)).start(); 
            os = socket.getOutputStream(); 
        } catch (UnknownHostException e) { 
            e.printStackTrace(); 
        } catch (IOException e) { 
            e.printStackTrace(); 
        } 
         
         
        bt_send.setOnClickListener(new OnClickListener() { 
            @Override 
            public void onClick(View v) { 
                try { 
                    //得到輸入框中的內容，寫入到輸入流中 
                    os.write((et_input.getText().toString()+"\r\n").getBytes("utf-8")); 
                    et_input.setText(""); 
                } catch (UnsupportedEncodingException e) { 
                    // TODO Auto-generated catch block 
                    e.printStackTrace(); 
                } catch (IOException e) { 
                    // TODO Auto-generated catch block 
                    e.printStackTrace(); 
                } 
            } 
        }); 
         
         
        handler = new Handler(){ 
            @Override 
            public void handleMessage(Message msg) { 
                super.handleMessage(msg); 
                if(msg.what == 1){ 
                    //得到服務器返回的信息 
                    et_show.append("\n"+msg.obj.toString()); 
                } 
            } 
        }; 
    } 
     
} 

第三是客戶端的線程類
[java] 
public class ClinetThread implements Runnable{ 
 
    Socket socket = null; 
    Handler handler = null; 
     
    BufferedReader br = null; 
     
    public ClinetThread(Socket socket,Handler handler) { 
        this.socket = socket; 
        this.handler = handler; 
        try { 
            br = new BufferedReader(new InputStreamReader(socket.getInputStream())); 
        } catch (IOException e) { 
            e.printStackTrace(); 
        } 
         
    } 
     
    @Override 
    public void run() { 
        String content = null; 
        try { 
            while((content = br.readLine())!=null){ 
                Message msg = new Message(); 
                msg.what = 1; 
                msg.obj = content; 
                handler.sendMessage(msg); 
            } 
        } catch (IOException e) { 
            e.printStackTrace(); 
        } 
    } 
     
} 

接下來是Java工程中的主類
[java] 
/**
 * 創建ServerSocket監聽的主類
 * 該類只負責接收客戶端的socket連接請求，每當客戶端
 * 連接到該serversocket之後，程序將對應socket加入到list
 * 並為該socket開一挑單獨的線程，負責socket的所有通信任務
 * @author Administrator
 *
 */ 
public class SimpleServer { 
     
    //定義保存所有Socket的ArrayList 
    public static ArrayList<Socket> socketList = new ArrayList<Socket>(); 
     
    public static void main(String[] args) { 
        try { 
            ServerSocket ss = new ServerSocket(30000); 
            while (true) { 
                Socket s = ss.accept(); 
                socketList.add(s); 
                new Thread(new ServerThead(s)).start(); 
            } 
        } catch (IOException e) { 
            e.printStackTrace(); 
        } 
         
    } 
} 

其次java工程中的線程類
[java]
/**
 * 負責每個線程通信的類
 * 該類不斷讀取客戶端數據，使用自定義的readFromClient()方法讀取
 * 客戶端數據，如果出現異常表明該socket對應的客戶端socket出現了問題
 * 程序將該socket從list中移除。
 * 當服務器線程讀取到了客戶端數據後，遍歷list集合，並將數據發送到每個
 * socket中
 * @author Administrator
 *
 */ 
public class ServerThead implements Runnable { 
 
    //定義當前線程處理的socket 
    Socket s = null; 
    //該線程所處理的socket對應的輸入流 
    BufferedReader br = null; 
     
    public ServerThead(Socket s) throws IOException { 
        this.s = s; 
        br = new BufferedReader(new InputStreamReader(s.getInputStream())); 
    } 
 
    @Override 
    public void run() { 
        String conntent = null; 
        while((conntent=readFromClient())!=null){ 
            //遍歷socket中的每一個socket 
            for(Socket s:SimpleServer.socketList){ 
                try { 
                    OutputStream os = s.getOutputStream(); 
                    os.write((conntent+"\n").getBytes("utf-8")); 
                } catch (IOException e) { 
                    e.printStackTrace(); 
                } 
                 
            } 
        } 
    } 
 
    private String readFromClient() { 
        try { 
            return br.readLine(); 
        } catch (IOException e) { 
            e.printStackTrace(); 
            SimpleServer.socketList.remove(s); 
        } 
        return null; 
    } 
 
}