正文 

当前位置： 首页 > java > java教程

javasocket实现简单在线聊天

     2022-03-23     154

关键词：

出处：http://blog.csdn.net/tuzongxun
最近的项目有一个在线网页交流的需求，由于很久以前做过的demo已经忘记的差不多了，因此便重新学习一下。
 
我计划的大致实现步骤分这样几大步：
1、使用awt组件和socket实现简单的单客户端向服务端持续发送消息；
2、结合线程，实现多客户端连接服务端发送消息；
3、实现服务端转发客户端消息至所有客户端，同时在客户端显示；
4、把awt组件生成的窗口界面改成前端jsp或者html展示的界面，java socket实现的客户端改为前端技术实现。
 
这里首先实现第一步的简单功能，难点在于：
1、没有用过awt组件，没有用过java相关的监听事件；
2、长时间没有使用socket进行客户端和服务端的交互，并且没有真正进行过cs结构的开发。
 
实现功能的代码如下：
客户端：
[java] view plain copy
 
  1. package chat.chat;  
  2.   
  3. import java.awt.BorderLayout;  
  4. import java.awt.Frame;  
  5. import java.awt.TextArea;  
  6. import java.awt.TextField;  
  7. import java.awt.event.ActionEvent;  
  8. import java.awt.event.ActionListener;  
  9. import java.awt.event.WindowAdapter;  
  10. import java.awt.event.WindowEvent;  
  11. import java.io.DataOutputStream;  
  12. import java.io.IOException;  
  13. import java.net.Socket;  
  14. import java.net.UnknownHostException;  
  15.   
  16. /** 
  17.  * 在线聊天客户端 1、生成图形窗口界面轮廓 2、为轮廓添加关闭事件 3、在轮廓中加入输入区域和内容展示区域 4、为输入区域添加回车事件 
  18.  * 5、建立服务端连接并发送数据 
  19.  *  
  20.  * @author tuzongxun123 
  21.  * 
  22.  */  
  23. public class ChatClient extends Frame {  
  24.     // 用户输入区域  
  25.     private TextField tfTxt = new TextField();  
  26.     // 内容展示区域  
  27.     private TextArea tarea = new TextArea();  
  28.     private Socket socket = null;  
  29.     // 数据输出流  
  30.     private DataOutputStream dataOutputStream = null;  
  31.   
  32.     public static void main(String[] args) {  
  33.         new ChatClient().launcFrame();  
  34.     }  
  35.   
  36.     /** 
  37.      * 建立一个简单的图形化窗口 
  38.      *  
  39.      * @author：tuzongxun 
  40.      * @Title: launcFrame 
  41.      * @param 
  42.      * @return void 
  43.      * @date May 18, 2016 9:57:00 AM 
  44.      * @throws 
  45.      */  
  46.     public void launcFrame() {  
  47.         setLocation(300, 200);  
  48.         this.setSize(200, 400);  
  49.         add(tfTxt, BorderLayout.SOUTH);  
  50.         add(tarea, BorderLayout.NORTH);  
  51.         pack();  
  52.         // 监听图形界面窗口的关闭事件  
  53.         this.addWindowListener(new WindowAdapter() {  
  54.   
  55.             @Override  
  56.             public void windowClosing(WindowEvent e) {  
  57.                 System.exit(0);  
  58.                 disConnect();  
  59.             }  
  60.         });  
  61.         tfTxt.addActionListener(new TFLister());  
  62.         setVisible(true);  
  63.         connect();  
  64.     }  
  65.   
  66.     /** 
  67.      * 连接服务器 
  68.      *  
  69.      * @author：tuzongxun 
  70.      * @Title: connect 
  71.      * @param 
  72.      * @return void 
  73.      * @date May 18, 2016 9:56:49 AM 
  74.      * @throws 
  75.      */  
  76.     public void connect() {  
  77.         try {  
  78.             // 新建服务端连接  
  79.             socket = new Socket("127.0.0.1", 8888);  
  80.             // 获取客户端输出流  
  81.             dataOutputStream = new DataOutputStream(socket.getOutputStream());  
  82.             System.out.println("连上服务端");  
  83.         } catch (UnknownHostException e) {  
  84.             e.printStackTrace();  
  85.         } catch (IOException e) {  
  86.             e.printStackTrace();  
  87.         }  
  88.     }  
  89.   
  90.     /** 
  91.      * 关闭客户端资源 
  92.      *  
  93.      * @author：tuzongxun 
  94.      * @Title: disConnect 
  95.      * @param 
  96.      * @return void 
  97.      * @date May 18, 2016 9:57:46 AM 
  98.      * @throws 
  99.      */  
  100.     public void disConnect() {  
  101.         try {  
  102.             dataOutputStream.close();  
  103.             socket.close();  
  104.         } catch (IOException e) {  
  105.             e.printStackTrace();  
  106.         }  
  107.     }  
  108.   
  109.     /** 
  110.      * 向服务端发送消息 
  111.      *  
  112.      * @author：tuzongxun 
  113.      * @Title: sendMessage 
  114.      * @param @param text 
  115.      * @return void 
  116.      * @date May 18, 2016 9:57:56 AM 
  117.      * @throws 
  118.      */  
  119.     private void sendMessage(String text) {  
  120.         try {  
  121.             dataOutputStream.writeUTF(text);  
  122.             dataOutputStream.flush();  
  123.         } catch (IOException e1) {  
  124.             e1.printStackTrace();  
  125.         }  
  126.     }  
  127.   
  128.     /** 
  129.      * 图形窗口输入区域监听回车事件 
  130.      *  
  131.      * @author tuzongxun123 
  132.      * 
  133.      */  
  134.     private class TFLister implements ActionListener {  
  135.   
  136.         @Override  
  137.         public void actionPerformed(ActionEvent e) {  
  138.             String text = tfTxt.getText().trim();  
  139.             tarea.setText(text);  
  140.             tfTxt.setText("");  
  141.             // 回车后发送数据到服务器  
  142.             sendMessage(text);  
  143.         }  
  144.     }  
  145. }  


 
服务端：
[java] view plain copy
 
  1. package chat.chat;  
  2.   
  3. import java.io.DataInputStream;  
  4. import java.io.EOFException;  
  5. import java.io.IOException;  
  6. import java.net.BindException;  
  7. import java.net.ServerSocket;  
  8. import java.net.Socket;  
  9.   
  10. /** 
  11.  * java使用socket和awt组件简单实现在线聊天功能服务端 可以实现一个客户端连接后不断向服务端发送消息 
  12.  * 但不支持多个客户端同时连接，原因在于代码中获得客户端连接后会一直循环监听客户端输入，造成阻塞 
  13.  * 以至于服务端无法二次监听另外的客户端，如要实现，需要使用异步或者多线程 
  14.  *  
  15.  * @author tuzongxun123 
  16.  * 
  17.  */  
  18. public class ChatServer {  
  19.   
  20.     public static void main(String[] args) {  
  21.         // 是否成功启动服务端  
  22.         boolean isStart = false;  
  23.         // 服务端socket  
  24.         ServerSocket ss = null;  
  25.         // 客户端socket  
  26.         Socket socket = null;  
  27.         // 服务端读取客户端数据输入流  
  28.         DataInputStream dataInputStream = null;  
  29.         try {  
  30.             // 启动服务器  
  31.             ss = new ServerSocket(8888);  
  32.         } catch (BindException e) {  
  33.             System.out.println("端口已在使用中");  
  34.             // 关闭程序  
  35.             System.exit(0);  
  36.         } catch (Exception e) {  
  37.             e.printStackTrace();  
  38.         }  
  39.   
  40.         try {  
  41.             isStart = true;  
  42.             while (isStart) {  
  43.                 boolean isConnect = false;  
  44.                 // 启动监听  
  45.                 socket = ss.accept();  
  46.                 System.out.println("one client connect");  
  47.                 isConnect = true;  
  48.                 while (isConnect) {  
  49.                     // 获取客户端输入流  
  50.                     dataInputStream = new DataInputStream(  
  51.                             socket.getInputStream());  
  52.                     // 读取客户端传递的数据  
  53.                     String message = dataInputStream.readUTF();  
  54.                     System.out.println("客户端说：" + message);  
  55.                 }  
  56.   
  57.             }  
  58.         } catch (EOFException e) {  
  59.             System.out.println("client closed!");  
  60.         } catch (Exception e) {  
  61.             e.printStackTrace();  
  62.         } finally {  
  63.             // 关闭相关资源  
  64.             try {  
  65.                 dataInputStream.close();  
  66.                 socket.close();  
  67.             } catch (IOException e) {  
  68.                 e.printStackTrace();  
  69.             }  
  70.         }  
  71.     }  
  72. }  


javasocket编程实现群聊（超详细）(代码片段)

Javasocket编程实现群聊最终效果文末有完整代码，创作不易，点个赞再走吧~客户端之间的交流有人退出群聊时，减少在线人数实现流程1、项目结构即原理分析功能实现多客户之间聊天实时统计在线人数图形化界面创建... 查看详情

javasocket实现服务端，客户端简单网络通信。chat

之前写的实现简单网络通信的代码，有一些严重bug。后面详细写。根据上次的代码，主要增加了用户注册，登录页面，以及实现了实时显示当前在登录状态的人数。并解决一些上次未发现的bug。(主要功能代码参见之前随笔https://... 查看详情

javasocket实现udp编程

UDP简介UDP是UserDatagramProtocol的简称，中文名是用户数据报协议，是OSI（OpenSystemInterconnection，开放式系统互联）参考模型中一种无连接的传输层协议，提供面向事务的简单不可靠信息传送服务，IETFRFC768是... 查看详情

javasocket编程--聊天小案例

　　很久以前写过socket聊天室，都快忘完了，心血来潮又重新写一遍。服务器端：packagecom.fancy;importjava.io.BufferedReader;importjava.io.IOException;importjava.io.InputStream;importjava.io.InputStreamReader;importjava.io.OutputStream;imp 查看详情

javasocket聊天系统错误,求解啊，谢谢各位啦！！！！！

java.net.SocketException:selectfailed atjava.net.PlainSocketImpl.socketAccept(NativeMethod) atjava.net.PlainSocketImpl.accept(UnknownSource) atjava.net.ServerSocket.implAccept(UnknownSource) atjava.net.ServerSocket.accept(UnknownSource) atTankServer.start(TankServer.java:18) atTankServer.main(TankSe... 查看详情

项目日志之基于javasocket的网络通讯

   JavaAPI网络类包中的Socket类是网络上运行的两个程序间双向通信的一端，它既可以接受请求，也可以发送请求，利用它可以较为方便的编写网络上数据的传递。我们打算通过Java中基于Socket的网络编程实现一个简单的... 查看详情

字节码学院之javasocket控制台聊天室(代码片段)

学了个把月基础，终于写出了一个双工通信的控制台版本的聊天室了，废话不说啦，直接上代码：服务端代码packagecom.zijiemaedu.socketdemo;importjava.io.*;importjava.net.ServerSocket;importjava.net.Socket;importjava.util.Scanner;/***@author:Mr-zhang*@create: 查看详情

javasocket通信实现私聊群聊

 　　前言　　闲言少叙，上代码！ 　　代码编写 　　server服务端/***服务端*/publicclassServer{privatestaticServerSocketserver=null;privatestaticSocketss=null;/***客户端集合*/privatestaticMap<String,ServerThread>serve 查看详情

javasocket编程简单的web服务器

简单的WEB服务器一个简单的WEB服务器将由列表9.2这样构建.当然,还必须要对方法和回应事件进行改进.简单的服务器不会分析和存储请求头.新的WEB服务器将分析和存储请求,为以后的处理作准备.为了达到这个目的,你必须有一个包... 查看详情

javasocket编程学习笔记

　1.Socket通信简介及模型　　JavaSocket可实现客户端--服务器间的双向实时通信。java.net包中定义的两个类socket和ServerSocket，分别用来实现双向连接的client和server端。2.Socket通信实现方法 2.1 服务器端（非多线程） 　　用... 查看详情

javasocket可配置简易通讯器

写了个简单的小玩意可以进行简单的配置，C/S模式分别都有配置文件https://github.com/lisztomania-Zero/Config_Socket 查看详情

javasocket可配置简易通讯器

写了个简单的小玩意可以进行简单的配置，C/S模式分别都有配置文件https://github.com/lisztomania-Zero/Config_Socket 查看详情

小白看完都会了！javasocket编程聊天室(代码片段)

二、Spring生命周期的大胆猜测这里分享一个阅读源码的小技巧：捉大放小，连蒙带猜！8字真言，我们在阅读源码过程中，因为你要知道，每一个被开源出来的优秀框架，其源码的体系都是极其庞大复杂... 查看详情

javasocket如何实现文件的断点续传，有代码更好

参考技术A上传:上传时附带一个描述数据起始位置的参数。接受的一端接收到数据后，按照起始位置续写文件。下载:按照本地已保存的大小，提交下载请求。服务器按照请求的位置，传数据。大概就是这么个意思。还要处理很多... 查看详情

javasocket实现两个客户段或多个客户端之间通信，该怎么解决

参考技术Ajavasocket有两种方式。一种是UDP这个可以直连，不需要服务器。一种是TCP这个是肯定要能过服务器来通信的。所以你说的。链接建立完毕后不再通过服务器！这个可以实现，但会麻烦一些。1.先说一下简单的点的吧。用TC... 查看详情

javasocket底层是怎样基于tcp/ip实现的？？？

首先必须明确：TCP/IP模型中有四层结构：     应用层（ApplicationLayer）、传输层（Transport Layer）、网络层（InternetLayer ）、链路层（LinkLayer） 其中Ip协议（InternetProtocol）是位于网络层的，TCP协议时位... 查看详情

javasocket编程学习笔记

在上一篇中，使用了javaSocket+Tcp/IP 协议来实现应用程序或客户端--服务器间的实时双向通信，本篇中，将使用UDP协议来实现Socket的通信。1.关于UDP　　UDP协议（用户数据报协议）是无连接的、不可靠的、无序的,速度快，进行... 查看详情

使用javasocket手撸一个http服务器

作为一个Java后端，提供HTTP服务可以说是基本技能之一，但是你真的理解HTTP协议吗？你知道如何使用HTTP服务器吗？Tomcat的底层如何支持HTTP服务？什么是著名的servlet以及如何使用它？套接字编程是您第一次学习Java时不可回避的... 查看详情