android實現簡單的聊天室

     先說一下流程。首先是創建一個java工程，並建立兩個java類，一個用於接收到客戶端的鏈接，並把鏈接添加list中，第二類實現線程runnable接口，專門用來接收發送客戶發送的信息。其次，創建android工程，並建立兩個類，一個用於顯示聊天界面，另外一個負責接收服務器端返回的信息。這個例子確定會有考慮不周的地方可是隻是爲了學習android中網絡相關api的使用，因此請你們謹慎拍磚。

首先仍是android的內容

 <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

 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());
                 }
             }
         };
     }

 }

第三是客戶端的線程類

 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工程中的主類

 /**
  * 建立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]  view plain copy print ?

1. /** 
2.  * 負責每一個線程通訊的類 
3.  * 該類不斷讀取客戶端數據，使用自定義的readFromClient()方法讀取 
4.  * 客戶端數據，若是出現異常代表該socket對應的客戶端socket出現了問題 
5.  * 程序將該socket從list中移除。 
6.  * 當服務器線程讀取到了客戶端數據後，遍歷list集合，並將數據發送到每一個 
7.  * socket中 
8.  * @author Administrator 
9.  * 
10.  */  
11. public class ServerThead implements Runnable {  
12.   
13.     //定義當前線程處理的socket  
14.     Socket s = null;  
15.     //該線程所處理的socket對應的輸入流  
16.     BufferedReader br = null;  
17.       
18.     public ServerThead(Socket s) throws IOException {  
19.         this.s = s;  
20.         br = new BufferedReader(new InputStreamReader(s.getInputStream()));  
21.     }  
22.   
23.     @Override  
24.     public void run() {  
25.         String conntent = null;  
26.         while((conntent=readFromClient())!=null){  
27.             //遍歷socket中的每個socket  
28.             for(Socket s:SimpleServer.socketList){  
29.                 try {  
30.                     OutputStream os = s.getOutputStream();  
31.                     os.write((conntent+"\n").getBytes("utf-8"));  
32.                 } catch (IOException e) {  
33.                     e.printStackTrace();  
34.                 }  
35.                   
36.             }  
37.         }  
38.     }  
39.   
40.     private String readFromClient() {  
41.         try {  
42.             return br.readLine();  
43.         } catch (IOException e) {  
44.             e.printStackTrace();  
45.             SimpleServer.socketList.remove(s);  
46.         }  
47.         return null;  
48.     }  
49.   
50. }  
51. 轉載請標明出處：雅荷灣