android聊天室的聊天功能吧，先说说服务器端的代码及其功能吧

server.java : 负责服务器的界面，以及更服务器主线程ServerThread的启动，产生了BroadCast广播，产生ClientThread线程

ServerThread.java:服务器监听的端口线程，负责创建ServerSocket及监听是否有新的客户端连接，并记录客户端连接及需要发送的信息，产生了BroadCast广播

BroadCast.java: 服务器向客户端广播线程，负责向客户端发送消息，产生ClientThread线程

ClientThread.java:维持服务器和单个客户端的连接线程，负责接受客户端发来是信息

好了接着就看看他们的代码吧！！

1.server.java-------创建ServerThread对象启动run方法

[java]  view plain copy
  1. package com.wang;  
  2.   
  3. import java.awt.BorderLayout;  
  4. import javax.swing.*;  
  5. import java.awt.event.*;  
  6.   
  7. public class Server extends JFrame implements ActionListener {  
  8.   
  9.     /**** 
  10.      *服务器端主程序负责界面，以及服务段主线程ServerThread的启动 
  11.      * 服务端主线程ServerThread又产生BroadCast及ClientThread线程 建立服务器端主界面中所用到的布局方式 
  12.      ***/  
  13.     // 边框容器  
  14.     BorderLayout borderLayout1 = new BorderLayout();  
  15.     BorderLayout borderLayout2 = new BorderLayout();  
  16.     // 创建面板  
  17.     JPanel jPanel1 = new JPanel();  
  18.     JPanel jPanel2 = new JPanel();  
  19.     // 创建按钮  
  20.     JButton jButton1 = new JButton();  
  21.     JButton jButton2 = new JButton();  
  22.     JScrollPane jScrollPane1 = new JScrollPane();  
  23.   
  24.     // 创建服务器端接收信息文本框  
  25.     static JTextArea jTextArea1 = new JTextArea();  
  26.     boolean bool = false, start = false;  
  27.   
  28.     // 声明ServerThread线程类对象  
  29.     ServerThread serverThread;  
  30.     Thread thread;  
  31.   
  32.     // 构造函数，用于初始化  
  33.     public Server() {  
  34.         super("Server");  
  35.         // 设置内容面板布局方式  
  36.         getContentPane().setLayout(borderLayout1);  
  37.   
  38.         // 初始化按钮组件  
  39.         jButton1.setText("启动服务器");  
  40.         // 按钮的动作设置监听事件  
  41.         jButton1.addActionListener(this);  
  42.         jButton2.setText("关闭服务器");  
  43.         // 按钮的动作设置监听事件  
  44.         jButton2.addActionListener(this);  
  45.   
  46.         // 初始化jPanel1面板对象，并向其中加入组件，上北  
  47.         this.getContentPane().add(jPanel1, java.awt.BorderLayout.NORTH);  
  48.         jPanel1.add(jButton1);  
  49.         jPanel1.add(jButton2);  
  50.   
  51.         // 初始化jPanel2面板对象，并向其中加入组件，  
  52.         jTextArea1.setText("");  
  53.         jPanel2.setLayout(borderLayout2);  
  54.         jPanel2.add(jScrollPane1, java.awt.BorderLayout.CENTER);  
  55.         jScrollPane1.getViewport().add(jTextArea1);  
  56.         this.getContentPane().add(jPanel2, java.awt.BorderLayout.CENTER);  
  57.   
  58.         this.setSize(400, 400);  
  59.         this.setVisible(true);  
  60.     }  
  61.   
  62.     public static void main(String[] args) {  
  63.         Server sever = new Server();  
  64.         sever.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);  
  65.     }  
  66.   
  67.     // 服务器界面中按钮事件处理  
  68.     public void actionPerformed(ActionEvent e) {  
  69.         if (e.getSource() == jButton1) {  
  70.             // 声明一个ServerThread对象  
  71.             serverThread = new ServerThread();  
  72.             serverThread.start();  
  73.         } else if (e.getSource() == jButton2) {  
  74.             bool = false;  
  75.             start = false;  
  76.             serverThread.finalize();  
  77.             this.setVisible(false);  
  78.         }  
  79.     }  
  80. }  

2.ServerThread.java -----创建Broadcast对象，启动该线程，实现run方法后，不断的向客户端发送消息，ServerThread开启后，不断的获取新的客户端并监听是否发送消息

[java]  view plain copy
  1. package com.wang;  
  2.   
  3. import java.util.*;  
  4. import java.io.*;  
  5. import java.net.*;  
  6.   
  7. public class ServerThread extends Thread  
  8. // 服务器监听端口线程  
  9. {  
  10.     // 声明ServerSocket类对象  
  11.     ServerSocket serverSocket;  
  12.     // 指定服务器监听端口常量  
  13.     public static final int PORT = 80;  
  14.   
  15.     /** 
  16.      * 创建一个Vector对象，用于存储客户端连接的ClientThread对象 , ClientThread类维持服务器与单个客户端的连接线程 
  17.      * 负责接收客户端发来的信息，clients负责存储所有与服务器建立连接的客户端 
  18.      **/  
  19.   
  20.     Vector clients;  
  21.     // 创建一个Vector对象，用于存储客户端发送过来的信息  
  22.     Vector messages;  
  23.     // BroadCast类负责服务器向客户端广播消息  
  24.     BroadCast broadcast;  
  25.   
  26.     String ip;  
  27.     InetAddress myIPaddress = null;  
  28.   
  29.     public ServerThread() {  
  30.         /*** 
  31.          * 创建两个Vector数组非常重要 ， clients负责存储所有与服务器建立连接的客户端， 
  32.          * messages负责存储服务器接收到的未发送出去的全部客户端的信息 
  33.          *  
  34.          **/  
  35.         clients = new Vector();  
  36.         messages = new Vector();  
  37.   
  38.         try {  
  39.             // 创建ServerSocket类对象  
  40.             serverSocket = new ServerSocket(PORT);  
  41.         } catch (IOException E) {  
  42.         }  
  43.         // 获取本地服务器地址信息  
  44.         try {  
  45.             myIPaddress = InetAddress.getLocalHost();  
  46.         } catch (UnknownHostException e) {  
  47.             System.out.println(e.toString());  
  48.         }  
  49.         ip = myIPaddress.getHostAddress();  
  50.         Server.jTextArea1.append("服务器地址：" + ip + "端口号:"  
  51.                 + String.valueOf(serverSocket.getLocalPort()) + "\n");  
  52.   
  53.         // 创建广播信息线程并启动  
  54.         broadcast = new BroadCast(this);  
  55.         broadcast.start();  
  56.     }  
  57.   
  58.     /** 
  59.      * 注意：一旦监听到有新的客户端创建即new Socket(ip, PORT)被执行, 
  60.      * 就创建一个ClientThread来维持服务器与这个客户端的连接 
  61.      **/  
  62.     public void run() {  
  63.         while (true) {  
  64.             try {  
  65.                 // 获取客户端连接，并返回一个新的Socket对象  
  66.                 Socket socket = serverSocket.accept();  
  67.   
  68.                 System.out.println(socket.getInetAddress().getHostAddress());  
  69.                 // 创建ClientThread线程并启动,可以监听该连接对应的客户端是否发送来消息， 并获取消息  
  70.                 ClientThread clientThread = new ClientThread(socket, this);  
  71.                 clientThread.start();  
  72.                 if (socket != null) {  
  73.                     synchronized (clients) {  
  74.                         // 将客户端连接加入到Vector数组中保存  
  75.                         clients.addElement(clientThread);  
  76.                     }  
  77.                 }  
  78.             } catch (IOException E) {  
  79.                 System.out.println("发生异常：" + E);  
  80.                 System.out.println("建立客户端联机失败！");  
  81.                 System.exit(2);  
  82.             }  
  83.         }  
  84.     }  
  85.   
  86.     public void finalize() {  
  87.         try {  
  88.             // 关闭serverSocket方法  
  89.             serverSocket.close();  
  90.         } catch (IOException E) {  
  91.         }  
  92.         serverSocket = null;  
  93.     }  
  94. }  

    95. 3.BroadCast.java------

    [java]  view plain copy
    1. package com.wang;  
    2.   
    3. import java.io.*;  
    4.   
    5. public class BroadCast extends Thread { // 服务器向客户端广播线程  
    6.     ClientThread clientThread;  
    7.     // 声明ServerThread对象  
    8.     ServerThread serverThread;  
    9.     String str;  
    10.   
    11.     public BroadCast(ServerThread serverThread) {  
    12.         this.serverThread = serverThread;  
    13.     }  
    14.   
    15.     // 该方法的作用是不停地向所有客户端发送新消息  
    16.     public void run() {  
    17.         while (true) {  
    18.             try {  
    19.                 // 线程休眠200 ms  
    20.                 Thread.sleep(200);  
    21.             } catch (InterruptedException E) {  
    22.             }  
    23.   
    24.             // 同步化serverThread.messages  
    25.             synchronized (serverThread.messages) {  
    26.                 // 判断是否有未发的消息  
    27.                 if (serverThread.messages.isEmpty()) {  
    28.                     continue;  
    29.                 }  
    30.                 // 获取服务器端存储的需要发送的第一条数据信息  
    31.                 str = (String) this.serverThread.messages.firstElement();  
    32.             }  
    33.             // 同步化serverThread.clients  
    34.             synchronized (serverThread.clients) {  
    35.                 // 利用循环获取服务器中存储的所有建立的与客户端的连接  
    36.                 for (int i = 0; i < serverThread.clients.size(); i++) {  
    37.                     clientThread = (ClientThread) serverThread.clients  
    38.                             .elementAt(i);  
    39.                     try {  
    40.                         // 向记录的每一个客户端发送数据信息  
    41.                         clientThread.out.writeUTF(str);  
    42.                     } catch (IOException E) {  
    43.                     }  
    44.                 }  
    45.                 // 从Vector数组中删除已经发送过的那条数据信息  
    46.                 this.serverThread.messages.removeElement(str);  
    47.             }  
    48.         }  
    49.     }  
    50. }  

    4.ClientThread.java----获得Socket的输入输出流，向客户端接收或者发送数据

    [java]  view plain copy
    1. package com.wang;  
    2.   
    3. import java.net.*;  
    4. import java.io.*;  
    5. public class ClientThread extends Thread            
    6. {     
    7.     /** 
    8.      * 维持服务器与单个客户端的连接线程，负责接收客户端发来的信息, 
    9.      * 声明一个新的Socket对象， 
    10.      * 用于保存服务器端用accept方法得到的客户端的连接 
    11.     **/  
    12.     Socket clientSocket;  
    13.       
    14.     //声明服务器端中存储的Socket对象的数据输入／输出流  
    15.     DataInputStream in = null;  
    16.     DataOutputStream out = null;  
    17.       
    18.     //声明ServerThread对象  
    19.     ServerThread serverThread;  
    20.   
    21.     public ClientThread(Socket socket,ServerThread serverThread)  
    22.     {  
    23.         clientSocket=socket;     
    24.         this.serverThread=serverThread;  
    25.         try  
    26.         {  
    27.             //创建服务器端数据输入／输出流  
    28.             in = new DataInputStream(clientSocket.getInputStream());  
    29.             out = new DataOutputStream(clientSocket.getOutputStream());  
    30.         }  
    31.         catch (IOException e2)  
    32.         {  
    33.             System.out.println("发生异常"+e2);  
    34.             System.out.println("建立I/O通道失败！");  
    35.             System.exit(3);  
    36.         }  
    37.     }  
    38.     //该方法监听该连接对应得客户端是否有消息发送  
    39.     public void run()  
    40.     {  
    41.         while(true)  
    42.         {   
    43.             try  
    44.             {  
    45.                 //读入客户端发送来的信息  
    46.                 String message=in.readUTF();  
    47.                 synchronized(serverThread.messages)  
    48.                 {  
    49.                     if(message!=null)  
    50.                     {  
    51.                         //将客户端发送来得信息存于serverThread的messages数组中  
    52.                         serverThread.messages.addElement(message);  
    53.                         //在服务器端的文本框中显示新消息  
    54.                         Server.jTextArea1.append(message+'\n');  
    55.                     }  
    56.                 }  
    57.             }  
    58.             catch(IOException E){break;}  
    59.         }  
    60.     }  
    61. }  
    5.接着看看手机客户端的布局main.xml

    [html]  view plain copy
    1. <?xml version="1.0" encoding="utf-8"?>  
    2. <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"  
    3.     android:layout_width="fill_parent"  
    4.     android:layout_height="fill_parent"  
    5.     android:orientation="vertical" >  
    6.   
    7.     <LinearLayout  
    8.         android:layout_width="fill_parent"  
    9.         android:layout_height="wrap_content"  
    10.         android:orientation="horizontal" >  
    11.   
    12.         <EditText  
    13.             android:id="@+id/username"  
    14.             android:layout_width="270dp"  
    15.             android:layout_height="wrap_content"  
    16.             android:hint="请输入用户名："  
    17.             android:maxLength="10" >  
    18.         EditText>  
    19.   
    20.         <Button  
    21.             android:id="@+id/LoginButton"  
    22.             android:layout_width="wrap_content"  
    23.             android:layout_height="wrap_content"  
    24.             android:text="登陆" />  
    25.     LinearLayout>  
    26.   
    27.     <LinearLayout  
    28.         android:layout_width="fill_parent"  
    29.         android:layout_height="wrap_content"  
    30.         android:orientation="horizontal" >  
    31.   
    32.         <EditText  
    33.             android:id="@+id/ip"  
    34.             android:layout_width="270dp"  
    35.             android:layout_height="wrap_content"  
    36.             android:digits=".1234567890"  
    37.             android:hint="10.254.1.62" >  
    38.         EditText>  
    39.   
    40.         <Button  
    41.             android:id="@+id/LeaveButton"  
    42.             android:layout_width="wrap_content"  
    43.             android:layout_height="wrap_content"  
    44.             android:text="退出" />  
    45.     LinearLayout>  
    46.   
    47.     <EditText  
    48.         android:id="@+id/history"  
    49.         android:layout_width="fill_parent"  
    50.         android:layout_height="280dp" >  
    51.     EditText>  
    52.   
    53.     <LinearLayout  
    54.         android:layout_width="fill_parent"  
    55.         android:layout_height="wrap_content"  
    56.         android:orientation="horizontal" >  
    57.   
    58.         <EditText  
    59.             android:id="@+id/message"  
    60.             android:layout_width="270dp"  
    61.             android:layout_height="wrap_content" >  
    62.         EditText>  
    63.   
    64.         <Button  
    65.             android:id="@+id/SendButton"  
    66.             android:layout_width="wrap_content"  
    67.             android:layout_height="wrap_content"  
    68.             android:text="发送" />  
    69.     LinearLayout>  
    70.   
    71. LinearLayout>  
    6.接着看看手机客户端的实现ChatClientActivity.java

    [java]  view plain copy
    1. package com.wang;  
    2.   
    3. import android.app.Activity;  
    4. import android.os.Bundle;  
    5. import java.io.DataInputStream;  
    6. import java.io.DataOutputStream;  
    7. import java.io.IOException;  
    8. import java.net.InetAddress;  
    9. import java.net.Socket;  
    10. import java.sql.Date;  
    11. import java.text.SimpleDateFormat;  
    12.   
    13. import android.app.Activity;  
    14. import android.os.Bundle;  
    15. import android.os.Handler;  
    16. import android.os.Message;  
    17. import android.view.View;  
    18. import android.view.Window;  
    19. import android.view.WindowManager;  
    20. import android.widget.Button;  
    21. import android.widget.EditText;  
    22. import android.widget.Toast;  
    23.   
    24. public class ChatClientActivity extends Activity implements Runnable {  
    25.     private EditText usernameEdit;  
    26.     private EditText ipEdit;  
    27.     private EditText historyEdit;  
    28.     private EditText messageEdit;  
    29.   
    30.     private Button loginButton;  
    31.     private Button sendButton;  
    32.     private Button leaveButton;  
    33.   
    34.     /** 
    35.      * 声明字符串，name存储用户名 chat_txt存储发送信息 chat_in存储从服务器接收到的信息 
    36.      ****/  
    37.   
    38.     private String username, ip, chat_txt, chat_in;  
    39.     // 创建Socket通信端口号常量  
    40.     public static final int PORT = 80;  
    41.   
    42.     // 声明套接字对象  
    43.     Socket socket;  
    44.   
    45.     // 声明线程对象  
    46.     Thread thread;  
    47.   
    48.     // 声明客户器端数据输入输出流  
    49.     DataInputStream dataInputStream;  
    50.     DataOutputStream dataOutputStream;  
    51.     // 是否登录的标记  
    52.     boolean flag = false;  
    53.   
    54.     public void onCreate(Bundle savedInstanceState) {  
    55.         super.onCreate(savedInstanceState);  
    56.         // 取消标题栏  
    57.         this.requestWindowFeature(Window.FEATURE_NO_TITLE);  
    58.         // 设置全屏  
    59.         this.getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN,  
    60.                 WindowManager.LayoutParams.FLAG_FULLSCREEN);  
    61.   
    62.         setContentView(R.layout.main);  
    63.         // 实例化组件  
    64.         usernameEdit = (EditText) findViewById(R.id.username);  
    65.         ipEdit = (EditText) findViewById(R.id.ip);  
    66.         historyEdit = (EditText) findViewById(R.id.history);  
    67.         messageEdit = (EditText) findViewById(R.id.message);  
    68.   
    69.         loginButton = (Button) findViewById(R.id.LoginButton);  
    70.         sendButton = (Button) findViewById(R.id.SendButton);  
    71.         leaveButton = (Button) findViewById(R.id.LeaveButton);  
    72.   
    73.         // 为三个按钮注册监听器  
    74.         loginButton.setOnClickListener(listener);  
    75.         sendButton.setOnClickListener(listener);  
    76.         leaveButton.setOnClickListener(listener);  
    77.     }  
    78.   
    79.     View.OnClickListener listener = new View.OnClickListener() {  
    80.   
    81.         @Override  
    82.         public void onClick(View v) {  
    83.             switch (v.getId()) {  
    84.             // "进入聊天室"按钮的处理  
    85.             case R.id.LoginButton:  
    86.                 if (flag == true) {  
    87.                     Toast.makeText(ChatClientActivity.this, "亲，你已经登陆过啦！！！",  
    88.                             Toast.LENGTH_LONG).show();  
    89.                     return;  
    90.                 }  
    91.                 // 获取用户名  
    92.                 username = usernameEdit.getText().toString();  
    93.                 // 获取服务器ip  
    94.                 ip = ipEdit.getText().toString();  
    95.                 // 判断用户名是否有效及ip是否为空  
    96.                 if (username != "" && username != null && username != "用户名输入"  
    97.                         && ip != null) {  
    98.                     try {  
    99.                         // 创建Socket对象  
    100.                         socket = new Socket(ip, PORT);  
    101.                         // 创建客户端数据输入／输出流，用于对服务器端发送或接收数据  
    102.                         dataInputStream = new DataInputStream(socket  
    103.                                 .getInputStream());  
    104.                         dataOutputStream = new DataOutputStream(socket  
    105.                                 .getOutputStream());  
    106.   
    107.                         // 得到系统的时间  
    108.                         Date now = new Date(System.currentTimeMillis());  
    109.                         SimpleDateFormat format = new SimpleDateFormat(  
    110.                                 "hh:mm:ss");  
    111.                         String nowStr = format.format(now);  
    112.   
    113.                         // 输出某某上线啦  
    114.                         dataOutputStream.writeUTF("└(^o^)┘: " + username  
    115.                                 + " : " + nowStr + " 上线啦！");  
    116.                     } catch (IOException e1) {  
    117.                         System.out.println("抱歉连接不成功！！！");  
    118.                     }  
    119.                     thread = new Thread(ChatClientActivity.this);  
    120.                     // 开启线程，监听服务器段是否有消息  
    121.                     thread.start();  
    122.                     // 说明已经登录成功  
    123.                     flag = true;  
    124.                 }  
    125.                 break;  
    126.             // "发送"按钮的处理  
    127.             case R.id.SendButton:  
    128.                 if (flag == false) {  
    129.                     Toast.makeText(ChatClientActivity.this, "亲，你还没登录，请先登录！",  
    130.                             Toast.LENGTH_LONG).show();  
    131.                     return;  
    132.                 }  
    133.                 // 获取客户端输入的发言内容  
    134.                 chat_txt = messageEdit.getText().toString();  
    135.                 if (chat_txt != null) {  
    136.                     // 得到当前时间  
    137.                     Date now = new Date(System.currentTimeMillis());  
    138.                     SimpleDateFormat format = new SimpleDateFormat("hh:mm:ss");  
    139.                     String nowStr = format.format(now);  
    140.   
    141.                     // 发言，向服务器发送发言的信息  
    142.                     try {  
    143.                         dataOutputStream.writeUTF("(^_^)∠※--->" + username  
    144.                                 + " : " + nowStr + " 说\n" + chat_txt);  
    145.                     } catch (IOException e2) {  
    146.                     }  
    147.                 } else {  
    148.                     try {  
    149.                         dataOutputStream.writeUTF("请发言！！！");  
    150.                     } catch (IOException e3) {  
    151.                     }  
    152.                 }  
    153.                 break;  
    154.             // "退出聊天室"按钮事件的处理  
    155.             case R.id.LeaveButton:  
    156.                 if (flag == true) {  
    157.                     if (flag == false) {  
    158.                         Toast.makeText(ChatClientActivity.this,  
    159.                                 "亲，你还没登录，请先登录！", Toast.LENGTH_LONG).show();  
    160.                         return;  
    161.                     }  
    162.                     try {  
    163.                         dataOutputStream.writeUTF("(^_^)/~~ " + username  
    164.                                 + "下线了！");  
    165.                         // 关闭socket  
    166.                         dataOutputStream.close();  
    167.                         dataInputStream.close();  
    168.                         socket.close();  
    169.                     } catch (IOException e4) {  
    170.                     }  
    171.                 }  
    172.                 flag = false;  
    173.                 Toast.makeText(ChatClientActivity.this, "已退出！",  
    174.                         Toast.LENGTH_LONG).show();  
    175.                 break;  
    176.             }  
    177.         }  
    178.     };  
    179.   
    180.     // 客户端线程启动后的动作  
    181.     @Override  
    182.     public void run() {  
    183.         // 循环执行，作用是一直监听服务器端是否有消息  
    184.         while (true) {  
    185.             try {  
    186.                 // 读取服务器发送来的数据信息  
    187.                 chat_in = dataInputStream.readUTF();  
    188.                 chat_in = chat_in + "\n";  
    189.                 // 发送一个消息，要求刷新界面  
    190.                 mHandler.sendMessage(mHandler.obtainMessage());  
    191.             } catch (IOException e) {  
    192.             }  
    193.         }  
    194.     }  
    195.   
    196.     Handler mHandler = new Handler() {  
    197.         public void handleMessage(Message msg) {  
    198.             // 将消息并显示在客户端的对话窗口中  
    199.             historyEdit.append(chat_in);  
    200.             // 刷新  
    201.             super.handleMessage(msg);  
    202.   
    203.         }  
    204.     };  
    205.   
    206. }  

    7,亲，别忘了由于需要网络，需要添加联网的权限哦！！

    [html]  view plain copy
    1. <uses-permission android:name="android.permission.INTERNET"/>  
    8.如果你完成以上功能，就可以实现android手机客户端上的简单的聊天功能了，运行结果给如下：

    更多相关文章

    1. Android(安卓)简单的Http框架
    2. Android的消息循环机制 Looper Handler类分析
    3. Android(安卓)你对Handler了解多少？（使用详解篇）
    4. android前端和java后端通过RSA加密方式传递数据时出现javax.cryp
    5. Android实时绘制效果（一）
    6. Android(安卓)NDK开发之旅36--FFmpeg音视频同步播放用C实现
    7. Android中为什么主线程不会因为Looper.loop()里的死循环卡死？
    8. android 资料
    9. Android(安卓)4.1 - 如何使用systrace做性能分析

    随机推荐

    1. Android应用程序线程消息循环模型分析
    2. android 模拟器的使用(Android模拟器介绍
    3. Android初学的学习笔记
    4. Android(安卓)tips（八）-->Android(安卓)Stu
    5. 为什么Android没有iOS那么顺滑
    6. Android(安卓)onTouchEvent, onClick及on
    7. 2012年度工作总结
    8. Android(安卓)M 新的运行时权限开发者需
    9. Android在网络中与JavaWeb的项目进行交互
    10. Android最全面试题71道题 详解