java仿QQ微信聊天室功能的实现
作者:冷血~多好 发布时间:2022-05-14 17:44:28
话不多说,先上图
即时通信系统:可以完成群聊、私人聊天,实时发送和显示聊天信息,完成好友列表,进一步可以带表情,附件发送,聊天信息的传送,等 系统的主要技术socket通信技术,多线程技术,数据库技术。
本系统实现的功能有:1.用户名字登录 2.用户之间的群聊和查看群聊记录3.用户之间的私聊和私聊记录4.动态刷新并显示好友列表5.显示在线人数 6.服务器可以显示用户在线状态 7.能够退出处理。
该程序可以实现局域网的聊天,只要把ip改为局域网ip即可。该系统ui中有许多没实现的功能,比如添加好友(通过验证成为好友),发布说说到空间,然后可以进行点赞和评论等。
有兴趣的可进行拓展。。系统视频效果观看链接http://m.v.qq.com/play.html?cid=&vid=f3241h0cgfo&vuid24=7Dp8aai1Y0YPJR%2FiSwf3dQ%3D%3D&url_from=share&second_share=0&share_from=copy&pgid=page_detail&mod_id=mod_toolbar_new
下载链接https://download.csdn.net/download/qq_44716544/12352588
gitee下载链接https://gitee.com/c-xiaobai-c/java-chat-system.git
注册,下面是数据库的关键代码,主要用于验证账号的唯一性和昵称的唯一性,主要用到了二重判断,先是判断账号的唯一,然后再判断昵称的唯一,当有一条件不足则注册失败,下边代码主要是数据库的查询功能,先是查询数据库中有没有该账号,然后查数据库中有没该昵称,最后把注册信息存储进数据库,不过下面只展示了查询的代码,储存信息代码类似这里不做展示。
Connectionlain c = new Connectionlain();
Connection conn = c.getConnect();
PreparedStatement ps = null;
ResultSet rs = null;
try {
ps = conn.prepareStatement("select *from userlist where name=?");
ps.setString(1, textloginName.getText());
rs = ps.executeQuery();
if (rs.next()) {
JOptionPane.showMessageDialog(this, "该昵称已存在,请重新填写昵称");
} else {
save();
}
} catch (SQLException e1) {
// TODO Auto-generated catch block
//e1.printStackTrace();
}
finally{
try {
rs.close();
ps.close();
// ct.close();
} catch (SQLException e1) {
e1.printStackTrace();
}
}
联系人页面,主要用到了数据库的读取功能,对已登录的用户账号进行读取,还用到了jlist列表,把已登录的用户账号显示在好友列。
下面展示关键代码:
list = new JList(listModel);
list.setSelectionMode(ListSelectionModel.SINGLE_SELECTION);// 设置单 一选择模式(每次只能有一个元素被选中)
list.setCellRenderer(new MyCellRenderer(icons));//使用自己的CellRenderer,使用图片功能
listScroller = new JScrollPane(list);
listScroller.setBounds(20,300,465,350);//添加带滚动条的list
//list.setBounds(20,300,450,350);
listScroller.setBackground(new Color(30, 144, 255));
listScroller.setOpaque(false);
listScroller.setBorder(null);
//this.add(listScroller,BorderLayout.CENTER);//添加带滚动条的list
//this.add(list);
this.add(listScroller);
listModel = new DefaultListModel();
try {
Class.forName("com.mysql.jdbc.Driver");
//(2)获取数据库连接
Connection ct=DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/check?useUn icode=true&characterEncoding=utf_8","root", "123");
//(3)创建SQL语句对象
Statement ps=ct.createStatement();
//(4)执行查询,返回结果集
ResultSet rs=ps.executeQuery("SELECT * FROM userlist2");
String []data1=new String [1];
while(rs.next()){
//if(rs.next()){
//rowData可以存放多行
String st1=rs.getString(1);
data1[0] =rs.getString(1);
for(int i=0;i<data1.length;i++){
listModel.add(i, data1[i]);//添加登录的用户到列表框
}
System.out.println(data1[0]);
}} catch (Exception e1) {
e1.printStackTrace();
} finally{
try {
if(rs!=null){
rs.close();
}
if(ps!=null){
ps.close();
}
if(ct!=null){
ct.close();
}
} catch (SQLException e1) {
e1.printStackTrace();
}
因为群聊和私聊的代码相似,只展示私聊关键代码;下面展示关键代码:
String serverIp="127.0.0.1";
int serverPort=8000;
//连接服务器,获取套接字io流
socket=new Socket(serverIp,serverPort);
dis=new DataInputStream(socket.getInputStream());
dos=new DataOutputStream(socket.getOutputStream());
//获取用户名,构建,发送登陆报文
String id2="好友"+id1;
String msgLogin="LOGIN#"+id2;
dos.writeUTF(msgLogin);
dos.flush();
//读取服务器返回的信息,判断是否登录成功
String response=dis.readUTF();
//登陆失败
if(response.equals("FAIL")){
addMsg("登陆失败");
System.out.println("登陆失败");
socket.close();
return;
}
//登陆成功
if(response.equals("SUCCESS")){
addMsg("登陆成功");
isLogged=true;
btnSend.setEnabled(true);
}
}
public void run(){
//连接服务器并登录
try{
login();
}catch(IOException e){
//addMsg("连接服务器时出现异常");
e.printStackTrace();
System.out.println("连接服务器时出现异常");
return;
}
while(isLogged){
try{
String msg=dis.readUTF();
String[] parts=msg.split("#");
//处理服务器发送过来的报文
if(parts[0].equals("USERLIST")){
for(int i=1;i<parts.length;i++){
}
}
if(parts[0].equals("LOGIN")){
addMsg(parts[1]+"上线了");
}
if(parts[0].equals("LOGOUT")){
}
if(parts[0].equals("TALKTO_ALL")){
addMsg(parts[1]+"跟所有人说:"+parts[2]);
}
if(parts[0].equals("TALKTO")){
addMsg(parts[1]+"跟我说:"+parts[2]);
}
}catch(IOException e){
isLogged=false;
e.printStackTrace();
}
}
}
}
//启动线程
private void start(){
clientThread=new ClientThread();
clientThread.start();
}
private void addMsg(String msg)
textAreaRecord.append(msg+"\n");
//自动滚动到文本区的最后一行
textAreaRecord.setCaretPosition(textAreaRecord.getText().length());
new save();
}
private void addMsg2(String msg){
textAreaRecord.append("\t"+"\t"+"\t"+"\t"+msg+":"+"用户"+id1+"\n");
//自动滚动到文本区的最后一行
textAreaRecord.setCaretPosition(textAreaRecord.getText().length());
new save();
}
class save{
public save(){
try {
// 注册mysql驱动程序
Class.forName("com.mysql.jdbc.Driver");//driver
System.out.println("找到Mysql数据库驱动程序");
} catch (Exception e1) {
System.out.println("在类路径上找不到Mysql驱动程序," + "请检查类路径上是否加载mysql的jar包!");
}
// (3)获取数据库连接
Connection conn = null;// 同时按下CTRL+SHIFT+O
try {
conn = DriverManager.getConnection(
"jdbc:mysql://127.0.0.1:3306/check?charcterEncoding=utf-8", "root", "123");//(url,username,password)
System.out.println("建立数据库连接成功");
} catch (Exception e1) {
e1.printStackTrace();
System.out.println("创建数据库连接失败!");
}
// (4)创建一个SQL语句执行(需要在Java执行SQL语句)
Statement stmt = null;
try {
// 通过conn对象创建SQL语句对象
stmt = conn.createStatement();
} catch (Exception e1) {
e1.printStackTrace();
}
String sql = "INSERT INTO usermessage2 (message2) VALUES('"+textAreaRecord.getText()+"')";
try {
// 执行SQL语句
stmt.executeUpdate(sql);
// JOptionPane op7=new JOptionPane();
// op7.showMessageDialog(null, "注册成功");
System.out.println("数据插入成功");
// JOptionPane.showMessageDialog(this, "注册成功");
} catch (Exception e1) {
e1.printStackTrace();
System.out.println("插入失败");
}
//(6)关闭资源
try {
stmt.close();
conn.close();
} catch (Exception e1) {
e1.printStackTrace();
服务器 主要用到了网络通信和多线程的功能
try{
//获取serverip和serverPoet
String serverIp=textServerIP.getText();
int serverPort=Integer.parseInt(textPort.getText());
//创建套接字地址
SocketAddress socketAddress=new InetSocketAddress(serverIp,serverPort);
//创建ServerSocket,绑定套接字地址
server=new ServerSocket();
server.bind(socketAddress);
//修改判断服务器是否运行的标识变量
isRunning=true;
btnStart.setEnabled(false);
btnStop.setEnabled(true);
addMsg("服务器启动成功");
System.out.println("服务器启动成功");
}catch(IOException e){
System.out.println("服务器启动失败");
e.printStackTrace();
isRunning=false;
}
}
public void run(){
startServer();
//当服务器处于运行状态时,循环监听客户端的连接请求
while(isRunning){
try{
Socket socket=server.accept();
//创建与客户端交互的线程
Thread thread=new Thread(new ClientHandler(socket));
thread.start();
}catch(IOException e){
System.out.println("还没连接");
}
}
}
}
class ClientHandler implements Runnable{
private Socket socket;
private DataInputStream dis;
private DataOutputStream dos;
private boolean isConnected;
private String username;
public ClientHandler(Socket socket){
this.socket=socket;
try{
this.dis=new DataInputStream(socket.getInputStream());
this.dos=new DataOutputStream(socket.getOutputStream());
isConnected=true;
}catch(IOException e){
isConnected=false;
e.printStackTrace();
}
}
public void run(){
while(isRunning&&isConnected){
try{
//读取客户端发送的报文
String msg=dis.readUTF();
String[] parts=msg.split("#");
if(parts[0].equals("LOGIN")){
String loginUsername=parts[1];
Date date3=new Date();
SimpleDateFormat f2=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String d3=f2.format(date3);
String q="用户:"+parts[1]+""+"已登录"+"\t"+d3;
addMsg(q);
//如果该用户已登录,则返回失败报文,否则返回成功报文
if(clientHandlerMap.containsKey(loginUsername)){
dos.writeUTF("FAIL");
}else{
dos.writeUTF("SUCCESS");
//将此客户端处理线程的信息添加到clientHandlerMap中
clientHandlerMap.put(loginUsername, this);
//将现有用户的信息发给新用户
StringBuffer msgUserList=new StringBuffer();
msgUserList.append("USERLIST");
for(String username : clientHandlerMap.keySet()){
msgUserList.append(username +"#");
}
dos.writeUTF(msgUserList.toString());
//将新登录的用户信息发给其他用户
String msgLogin="LOGIN#"+loginUsername;
broadcastMsg(loginUsername,msgLogin);
//存储登录的用户名
this.username=loginUsername;
}
}
if(parts[0].equals("LOGOUT")){
clientHandlerMap.remove(username);
String msgLogout="LOGOUT#"+username;
//broadcastMsg(username,msgLogout);
isConnected=false;
socket.close();
}
if(parts[0].equals("TALKTO_ALL")){
String msgTalkToAll="TALKTO_ALL#"+username+"#"+parts[1]; Date date3=new Date();
SimpleDateFormat f2=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String d3=f2.format(date3);
String p="用户 "+username+"对所有人说"+parts[1]+"\t"+d3;
addMsg2(p);
broadcastMsg(username,msgTalkToAll);}
if(parts[0].equals("TALKTO")){
ClientHandler clientHandler=clientHandlerMap.get(parts[1]);
if(null!=clientHandler){
String msgTalkTo="TALKTO#"+username+"#"+parts[2];
Date date3=new Date();
SimpleDateFormat f2=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String d3=f2.format(date3);
String p2="用户 "+clientHandler+" 对"+username+"说: "+parts[2]+"\t"+d3;
addMsg2(p2);
clientHandler.dos.writeUTF(msgTalkTo);
clientHandler.dos.flush();
}
}
}catch(IOException e){
isConnected=false;
e.printStackTrace();
}
}
}
/**
* 将某个用户发来的信息广播个其他用户
*/
private void broadcastMsg(String fromUsername,String msg) throws IOException{
for(String toUserName : clientHandlerMap.keySet()){
if(fromUsername.equals(toUserName)==false){
DataOutputStream dos=clientHandlerMap.get(toUserName).dos;
dos.writeUTF(msg);
dos.flush();
}
}
}
}
/**
* 添加消息到文本框
*/
private void addMsg(String msg){
//在文本区添加一条消息,并加上换行
textAreaRecord.append(msg+"\n");
textAreaRecord.setCaretPosition(textAreaRecord.getText().length());
来源:https://blog.csdn.net/qq_44716544/article/details/115284633
猜你喜欢
- 在微信公众号里面需要上传头像,时间比较紧,调用学习jssdk并使用 来不及 就用了input1、使用input:file标签, 去调用系统默
- 具体安装步骤,不再赘述,仅附上个人工作、学习中的对 EasyCode 的详细配置。插件链接地址:https://gitee.com/make
- 格式要求:SU MO TU WE TH FR SA &nb
- ES是一个基于Lucene的分布式全文搜索服务器,和SQL Server的全文索引(Fulltext Index)有点类似,都是基于分词和分
- SpringBoot整合第三方技术一、整合Junit新建一个SpringBoot项目使用@SpringBootTest标签在test测试包内
- 什么是队列结构一种线性结构,具有特殊的运算法则【只能在一端(队头)删除,在另一端(队尾)插入】。分类:顺序队列结构链式队列结构基本操作:入队
- 最近重新研究Java基础知识,发现以前太多知识知识略略带过了,比较说Java的线程机制,在Java中有两类线程:User Thread(用户
- package TOOLS;import java.io.BufferedReader;import java.io.File;import
- 利用Javaweb开发的一个校园服务系统,通过发布自己的任务并设置悬赏金额,有些类似于赏金猎人,在这里分享给大家,有需要可以联系我:2186
- 本文实例讲述了Java继承Thread类创建线程类。分享给大家供大家参考,具体如下:一 点睛通过继承Thread类创建线程并启动多线程的步骤
- 阿里终面在线编程题,写出来与大家分享一下 有一个单向链表
- 相信在做B/S模式的项目时,我们请求server端时通常遇到返回数据的处理,对返回数据的格式处理方式多样,随着JSON的流行,现在很多的项目
- 一、题目描述题目:模拟一个简单的银行系统,使用两个不同的线程向同一个账户存钱。实现:使用特殊域变量volatile实现同步。二、解题思路创建
- 引言最近在工作中结合线程池使用 InheritableThreadLocal 出现了获取线程变量“错误&rdqu
- 日常对于金额计算,应该都是用的BigDecimal,可是苦于没有好的工具类方法,现在贡献一个我正在用的对于数字计算的工具类,项目中就是用的这
- 简介本文用示例介绍java的Period的用法。Duration和Period说明Duration类通过秒和纳秒相结合来描述一个时间量,最高
- 一.前言这一篇来看看 SpringIOC 里面的一个细节点 , 来简单看看 BeanDefinition 这个对象 , 以及有没有办法对其进
- //构造文件File类File f=new File(fileName);//判断是否为目录f.isDirectory();//获取目录下的
- 在使用 springboot 或者 springcloud 开发的时候,通常为了保证系统的安全性,配置文件中的密码等铭感信息都会进行加密处理
- sidebarDepth: 3条件构造器说明以下出现的第一个入参boolean condition表示该条件是否加入最后生成的SQL中,例如