java仿QQ微信聊天室功能的實(shí)現(xiàn)

更新時(shí)間：2021年04月26日 14:11:31 作者：冷血～多好

這篇文章主要介紹了java仿QQ微信聊天室的實(shí)現(xiàn)代碼，代碼簡(jiǎn)單易懂，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，,需要的朋友可以參考下

話不多說，先上圖

即時(shí)通信系統(tǒng):可以完成群聊、私人聊天，實(shí)時(shí)發(fā)送和顯示聊天信息，完成好友列表,進(jìn)一步可以帶表情，附件發(fā)送，聊天信息的傳送，等系統(tǒng)的主要技術(shù)socket通信技術(shù)，多線程技術(shù)，數(shù)據(jù)庫(kù)技術(shù)。

本系統(tǒng)實(shí)現(xiàn)的功能有:1.用戶名字登錄 2.用戶之間的群聊和查看群聊記錄3.用戶之間的私聊和私聊記錄4.動(dòng)態(tài)刷新并顯示好友列表5.顯示在線人數(shù) 6.服務(wù)器可以顯示用戶在線狀態(tài) 7.能夠退出處理。

該程序可以實(shí)現(xiàn)局域網(wǎng)的聊天，只要把ip改為局域網(wǎng)ip即可。該系統(tǒng)ui中有許多沒實(shí)現(xiàn)的功能，比如添加好友（通過驗(yàn)證成為好友），發(fā)布說說到空間，然后可以進(jìn)行點(diǎn)贊和評(píng)論等。

有興趣的可進(jìn)行拓展。。系統(tǒng)視頻效果觀看鏈接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

注冊(cè)，下面是數(shù)據(jù)庫(kù)的關(guān)鍵代碼，主要用于驗(yàn)證賬號(hào)的唯一性和昵稱的唯一性，主要用到了二重判斷，先是判斷賬號(hào)的唯一，然后再判斷昵稱的唯一，當(dāng)有一條件不足則注冊(cè)失敗，下邊代碼主要是數(shù)據(jù)庫(kù)的查詢功能，先是查詢數(shù)據(jù)庫(kù)中有沒有該賬號(hào)，然后查數(shù)據(jù)庫(kù)中有沒該昵稱，最后把注冊(cè)信息存儲(chǔ)進(jìn)數(shù)據(jù)庫(kù)，不過下面只展示了查詢的代碼，儲(chǔ)存信息代碼類似這里不做展示。

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, "該昵稱已存在,請(qǐng)重新填寫昵稱");
		             } 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();  
                       }  
       }

聯(lián)系人頁(yè)面，主要用到了數(shù)據(jù)庫(kù)的讀取功能，對(duì)已登錄的用戶賬號(hào)進(jìn)行讀取，還用到了jlist列表，把已登錄的用戶賬號(hào)顯示在好友列。

下面展示關(guān)鍵代碼：
        list = new JList(listModel);
	   	list.setSelectionMode(ListSelectionModel.SINGLE_SELECTION);// 設(shè)置單 一選擇模式（每次只能有一個(gè)元素被選中）
		list.setCellRenderer(new MyCellRenderer(icons));//使用自己的CellRenderer，使用圖片功能
		listScroller = new JScrollPane(list);
		listScroller.setBounds(20,300,465,350);//添加帶滾動(dòng)條的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);//添加帶滾動(dòng)條的list
		//this.add(list);
		this.add(listScroller);
		
  listModel = new DefaultListModel();  
	    try {  
           Class.forName("com.mysql.jdbc.Driver");
   		//(2)獲取數(shù)據(jù)庫(kù)連接
   		Connection ct=DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/check?useUn   icode=true&amp;characterEncoding=utf_8","root", "123");
   		//（3）創(chuàng)建SQL語句對(duì)象
   		Statement ps=ct.createStatement();
   		//(4)執(zhí)行查詢，返回結(jié)果集
   		 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();  
                }

因?yàn)槿毫暮退搅牡拇a相似，只展示私聊關(guān)鍵代碼；下面展示關(guān)鍵代碼：

String serverIp="127.0.0.1";
			int serverPort=8000;
			//連接服務(wù)器，獲取套接字io流
			socket=new Socket(serverIp,serverPort);
			dis=new DataInputStream(socket.getInputStream());
			dos=new DataOutputStream(socket.getOutputStream());
			//獲取用戶名，構(gòu)建，發(fā)送登陸報(bào)文
			String   id2="好友"+id1;
			String msgLogin="LOGIN#"+id2;
			dos.writeUTF(msgLogin);
			dos.flush();
			//讀取服務(wù)器返回的信息，判斷是否登錄成功
		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(){
			//連接服務(wù)器并登錄
			try{
				login();
			}catch(IOException e){
				//addMsg("連接服務(wù)器時(shí)出現(xiàn)異常");
				e.printStackTrace();
				System.out.println("連接服務(wù)器時(shí)出現(xiàn)異常");
				return;
			}
			while(isLogged){
				try{
					String msg=dis.readUTF();
					String[] parts=msg.split("#");
					//處理服務(wù)器發(fā)送過來的報(bào)文
					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();
				}
			}
		}	
	}
	//啟動(dòng)線程
private void start(){
	clientThread=new ClientThread();
	clientThread.start();
}
private void addMsg(String msg)
	textAreaRecord.append(msg+"\n");
	//自動(dòng)滾動(dòng)到文本區(qū)的最后一行
	textAreaRecord.setCaretPosition(textAreaRecord.getText().length());
	new save();	
}
private void addMsg2(String msg){
	textAreaRecord.append("\t"+"\t"+"\t"+"\t"+msg+":"+"用戶"+id1+"\n");
	//自動(dòng)滾動(dòng)到文本區(qū)的最后一行
	textAreaRecord.setCaretPosition(textAreaRecord.getText().length());
	new save()；	
}
	class save{	
		public save(){
			  try {
				   // 注冊(cè)mysql驅(qū)動(dòng)程序
				   Class.forName("com.mysql.jdbc.Driver");//driver
				   System.out.println("找到Mysql數(shù)據(jù)庫(kù)驅(qū)動(dòng)程序");
 
			    } catch (Exception e1) {
				   System.out.println("在類路徑上找不到Mysql驅(qū)動(dòng)程序，" + "請(qǐng)檢查類路徑上是否加載mysql的jar包!");
			   }
			   // (3)獲取數(shù)據(jù)庫(kù)連接
			    Connection conn = null;// 同時(shí)按下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("建立數(shù)據(jù)庫(kù)連接成功");
				
 
			     } catch (Exception e1) {
			      	e1.printStackTrace();
			      	System.out.println("創(chuàng)建數(shù)據(jù)庫(kù)連接失??！");
			      }
 
			//     （4）創(chuàng)建一個(gè)SQL語句執(zhí)行（需要在Java執(zhí)行SQL語句）
			      Statement stmt = null;
			       try {
			     	// 通過conn對(duì)象創(chuàng)建SQL語句對(duì)象
			     	stmt = conn.createStatement();
			     } catch (Exception e1) {
			     	e1.printStackTrace();
			   }
 
 
			    String sql = "INSERT INTO usermessage2 (message2) VALUES('"+textAreaRecord.getText()+"')";
			
			
			    try {
			  	// 執(zhí)行SQL語句
			    	stmt.executeUpdate(sql);
			  	//  JOptionPane op7=new JOptionPane();
			   //  op7.showMessageDialog(null, "注冊(cè)成功");
			   	System.out.println("數(shù)據(jù)插入成功");
		//	   	JOptionPane.showMessageDialog(this, "注冊(cè)成功");
				
			    } catch (Exception e1) {
			    	e1.printStackTrace();
			  	System.out.println("插入失敗");
			   }
			
		  	//(6)關(guān)閉資源
			   try {
				  stmt.close();
				  conn.close();
			      } catch (Exception e1) {
				    e1.printStackTrace();

服務(wù)器主要用到了網(wǎng)絡(luò)通信和多線程的功能

try{
			//獲取serverip和serverPoet
			String serverIp=textServerIP.getText();
			int serverPort=Integer.parseInt(textPort.getText());
			//創(chuàng)建套接字地址
			SocketAddress socketAddress=new InetSocketAddress(serverIp,serverPort);
			//創(chuàng)建ServerSocket，綁定套接字地址
			server=new ServerSocket();
			server.bind(socketAddress);
			//修改判斷服務(wù)器是否運(yùn)行的標(biāo)識(shí)變量
			isRunning=true;
			
			btnStart.setEnabled(false);
			btnStop.setEnabled(true);
			addMsg("服務(wù)器啟動(dòng)成功");
			System.out.println("服務(wù)器啟動(dòng)成功");				
		}catch(IOException e){
			System.out.println("服務(wù)器啟動(dòng)失敗");
			e.printStackTrace();
			isRunning=false;
		}
	}
	public void run(){
		startServer();
		//當(dāng)服務(wù)器處于運(yùn)行狀態(tài)時(shí)，循環(huán)監(jiān)聽客戶端的連接請(qǐng)求
		while(isRunning){
			try{
				Socket socket=server.accept();
				//創(chuàng)建與客戶端交互的線程
				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{
				//讀取客戶端發(fā)送的報(bào)文
				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);	
					//如果該用戶已登錄，則返回失敗報(bào)文，否則返回成功報(bào)文
					if(clientHandlerMap.containsKey(loginUsername)){
						dos.writeUTF("FAIL");
					}else{
						dos.writeUTF("SUCCESS");
						//將此客戶端處理線程的信息添加到clientHandlerMap中
						clientHandlerMap.put(loginUsername, this);
						//將現(xiàn)有用戶的信息發(fā)給新用戶
						StringBuffer msgUserList=new StringBuffer();
						msgUserList.append("USERLIST");
					
						for(String username : clientHandlerMap.keySet()){
							msgUserList.append(username +"#");
						}
						dos.writeUTF(msgUserList.toString());
						//將新登錄的用戶信息發(fā)給其他用戶
						String msgLogin="LOGIN#"+loginUsername;
						broadcastMsg(loginUsername,msgLogin);
						//存儲(chǔ)登錄的用戶名
						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+"對(duì)所有人說"+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+" 對(duì)"+username+"說: "+parts[2]+"\t"+d3;
							addMsg2(p2);
							
							clientHandler.dos.writeUTF(msgTalkTo);
							clientHandler.dos.flush();
						}		
				}			
			}catch(IOException e){
				isConnected=false;
				e.printStackTrace();
			}
	}	
}
 
/**
 * 將某個(gè)用戶發(fā)來的信息廣播個(gè)其他用戶
 */
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){
	//在文本區(qū)添加一條消息，并加上換行
	textAreaRecord.append(msg+"\n");
	textAreaRecord.setCaretPosition(textAreaRecord.getText().length());

到此這篇關(guān)于java仿QQ微信聊天室的文章就介紹到這了,更多相關(guān)java聊天室內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: