基于Java Socket实现一个简易在线聊天功能(一)
作者:Past_Future 发布时间:2023-09-23 17:18:35
标签: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实现一个简易在线聊天功能(一)的相关知识网站的支持!
0
投稿
猜你喜欢
- Device Administration对于这个应用,市场上很多,但是看一下评论就知道效果有多差了,因为99%一键锁屏应用没办法卸载。今天
- 这篇文章主要介绍了Java List分页功能实现代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的
- 最近在做一个项目,遇到了项目打成 war 包的一个问题,项目创建时选择的时 jar 包方式,后因项目部署要求,需要打成 war 包部署,遇到
- 总体实现思路是启动一个生产者项目注册, 将所含服务注册到zookeeper的注册中心, 然后在启动一个消费者项目,将所需服务向zookeep
- 本文实例为大家分享了C#请求http向网页发送数据、网页接收,供大家参考,具体内容如下首先,我们需要的是什么东西?用POST方式请求http
- 布局布局效果如下,下面每个“网格”都是一个按钮,点击按钮,就会有相应的事件发生。由于UniformG
- Threadlocal有什么用:简单的说就是,一个ThreadLocal在一个线程中是共享的,在不同线程之间又是隔离的(每个线程都只能看到自
- 介绍细心的小伙伴可能会发现,抖音新上线了IP属地的功能,小伙伴在发表动态、发表评论以及聊天的时候,都会显示自己的IP属地信息下面,我就来讲讲
- 背景最近遇到一个有意思的事情,java应用运行在阿里云的ack集群中,某一天有个应用启动突然发现阿里云上的agent都没有注册了,于是开始排
- 在这篇文章中,我精选了几个比较适合 Java 编码的 IDEA 主题供小伙伴们选择。另外,我自己用的是 One Dark theme 这款。
- 笔者计划为大家介绍分布式文件系统,用于存储应用的图片、word、excel、pdf等文件。在开始介绍分布式文件系统之前,为大家介绍一下使用本
- 数据适配DataAdapter 对象是DataSet 和数据源之间的桥梁,可以建立并初始化数据表(即DataTable),对数据源执行SQL
- 废话不多说了,直接给大家贴代码,具体代码如下所示://打开Excel文件,转换为DataTable DataTable dtExcel;pr
- 经过上一篇的介绍,相信小伙伴们已经按奈不住内心对springboot的向往,本篇我将继续向小伙伴介绍springboot配置文件的配置,已经
- 四大函数式接口新时代的程序员:lambda 表达式,链式编程,函数式接口,Stream 流式计算函数式接口: 只有一个方法的接口@Funct
- 前言在工作中,比如要实现一个功能,前端传什么参数,后端的controller层中怎么接收参数 ,封装成了什么实体对象,有些参数是在URL上使
- 一、什么是冒泡排序冒泡排序的英文是bubble sort,它是一种基础的交换排序。说到冒泡是不是就想起了快乐肥宅水呢?汽水中有许多小小的水泡
- 1、冒泡排序排序原理:相邻两个元素比较,如果前者比后者大,则交换两个元素。每执行一次,都会确定一个最大值,其位置就固定了,下一次就不需要再参
- Java中,将字节数组转成图片的有很多种方式,今天在这里记录其中一种,方便以后查询,也可以提供给没有接触的童鞋做一个参考。首先是将图片转成字
- 最近IDEA打可执行Jar包搞了三天,一直失败,好好学习一下Maven-assembly,在此记录一下1. 需求项目打包,满足以下要求:1.