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

最近做了一个项目，其中有一个在线网页交流的需求，好久没写代码了，手都生疏了，于是先写demo练练手，分享到脚本之家平台，以此做个记录，方便自己和大家使用。

先给大家说下实现步骤分这样几大步：

1、使用awt组件和socket实现简单的单客户端向服务端持续发送消息；

2、结合线程，实现多客户端连接服务端发送消息；

3、实现服务端转发客户端消息至所有客户端，同时在客户端显示；

4、把awt组件生成的窗口界面改成前端jsp或者html展示的界面，java socket实现的客户端改为前端技术实现。

这里首先实现第一步的简单功能，难点在于：

1、没有用过awt组件，没有用过java相关的监听事件；

2、长时间没有使用socket进行客户端和服务端的交互，并且没有真正进行过cs结构的开发。

实现功能的代码如下：

客户端：

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

以上所述是小编给大家介绍的Java Socket实现一个简易在线聊天功能（一）的相关知识网站的支持！