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. 转载请标明出处：雅荷湾