首页 > 电脑常识 > 云计算

java仿QQ微信聊天室

admin 云计算 2021-04-26 15:55:55 java  
后台-系统设置-扩展变量-手机广告位-内容正文底部

话不多说,先上图

             

 

 

         

 

         

即时通信系统:可以完成群聊、私人聊天,实时发送和显示聊天信息,完成好友列表,进一步可以带表情,附件发送,聊天信息的传送,等 系统的主要技术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

后台-系统设置-扩展变量-手机广告位-内容正文底部
版权声明

本文仅代表作者观点,不代表本站立场。
本文系作者授权发表,未经许可,不得转载。
本文地址:https://jcdi.cn/diannaochangshi/yunjisuan/651.html

留言与评论(共有 0 条评论)
   
验证码:
后台-系统设置-扩展变量-手机广告位-评论底部广告位

教程弟

https://www.jcdi.cn/

统计代码 | 京ICP1234567-2号

Powered By 教程弟 教程弟

使用手机软件扫描微信二维码