基于Java Socket实现一个简易在线聊天功能（一）

package chat.chat; import java.awt.BorderLayout; import java.awt.Frame; import java.awt.TextArea; import java.awt.TextField; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.WindowAdapter; import java.awt.event.WindowEvent; import java.io.DataOutputStream; import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException; /**  * 在线聊天客户端 1、生成图形窗口界面轮廓 2、为轮廓添加关闭事件 3、在轮廓中加入输入区域和内容展示区域 4、为输入区域添加回车事件  * 5、建立服务端连接并发送数据  *  * @author tuzongxun123  *  */ public class ChatClient extends Frame {   // 用户输入区域   private TextField tfTxt = new TextField();   // 内容展示区域   private TextArea tarea = new TextArea();   private Socket socket = null;   // 数据输出流   private DataOutputStream dataOutputStream = null;   public static void main(String[] args) {     new ChatClient().launcFrame();   }   /**    * 建立一个简单的图形化窗口    *    * @author：tuzongxun    * @Title: launcFrame    * @param    * @return void    * @date May 18, 2016 9:57:00 AM    * @throws    */   public void launcFrame() {     setLocation(300, 200);     this.setSize(200, 400);     add(tfTxt, BorderLayout.SOUTH);     add(tarea, BorderLayout.NORTH);     pack();     // 监听图形界面窗口的关闭事件     this.addWindowListener(new WindowAdapter() {       @Override       public void windowClosing(WindowEvent e) {         System.exit(0);         disConnect();       }     });     tfTxt.addActionListener(new TFLister());     setVisible(true);     connect();   }   /**    * 连接服务器    *    * @author：tuzongxun    * @Title: connect    * @param    * @return void    * @date May 18, 2016 9:56:49 AM    * @throws    */   public void connect() {     try {       // 新建服务端连接       socket = new Socket("127.0.0.1", 8888);       // 获取客户端输出流       dataOutputStream = new DataOutputStream(socket.getOutputStream());       System.out.println("连上服务端");     } catch (UnknownHostException e) {       e.printStackTrace();     } catch (IOException e) {       e.printStackTrace();     }   }   /**    * 关闭客户端资源    *    * @author：tuzongxun    * @Title: disConnect    * @param    * @return void    * @date May 18, 2016 9:57:46 AM    * @throws    */   public void disConnect() {     try {       dataOutputStream.close();       socket.close();     } catch (IOException e) {       e.printStackTrace();     }   }   /**    * 向服务端发送消息    *    * @author：tuzongxun    * @Title: sendMessage    * @param @param text    * @return void    * @date May 18, 2016 9:57:56 AM    * @throws    */   private void sendMessage(String text) {     try {       dataOutputStream.writeUTF(text);       dataOutputStream.flush();     } catch (IOException e1) {       e1.printStackTrace();     }   }   /**    * 图形窗口输入区域监听回车事件    *    * @author tuzongxun123    *    */   private class TFLister implements ActionListener {     @Override     public void actionPerformed(ActionEvent e) {       String text = tfTxt.getText().trim();       tarea.setText(text);       tfTxt.setText("");       // 回车后发送数据到服务器       sendMessage(text);     }   } } 

package chat.chat; import java.io.DataInputStream; import java.io.EOFException; import java.io.IOException; import java.net.BindException; import java.net.ServerSocket; import java.net.Socket; /**  * java使用socket和awt组件简单实现在线聊天功能服务端 可以实现一个客户端连接后不断向服务端发送消息  * 但不支持多个客户端同时连接，原因在于代码中获得客户端连接后会一直循环监听客户端输入，造成阻塞  * 以至于服务端无法二次监听另外的客户端，如要实现，需要使用异步或者多线程  *  * @author tuzongxun123  *  */ public class ChatServer {   public static void main(String[] args) {     // 是否成功启动服务端     boolean isStart = false;     // 服务端socket     ServerSocket ss = null;     // 客户端socket     Socket socket = null;     // 服务端读取客户端数据输入流     DataInputStream dataInputStream = null;     try {       // 启动服务器       ss = new ServerSocket(8888);     } catch (BindException e) {       System.out.println("端口已在使用中");       // 关闭程序       System.exit(0);     } catch (Exception e) {       e.printStackTrace();     }     try {       isStart = true;       while (isStart) {         boolean isConnect = false;         // 启动监听         socket = ss.accept();         System.out.println("one client connect");         isConnect = true;         while (isConnect) {           // 获取客户端输入流           dataInputStream = new DataInputStream(               socket.getInputStream());           // 读取客户端传递的数据           String message = dataInputStream.readUTF();           System.out.println("客户端说：" + message);         }       }     } catch (EOFException e) {       System.out.println("client closed!");     } catch (Exception e) {       e.printStackTrace();     } finally {       // 关闭相关资源       try {         dataInputStream.close();         socket.close();       } catch (IOException e) {         e.printStackTrace();       }     }   } }