話不多說，先上圖

即時通信系統:可以完成群聊、私人聊天，實時發送和顯示聊天信息，完成好友列表,進一步可以帶表情，附件發送，聊天信息的傳送，等 系統的主要技術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&amp;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和serverPoetString 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());

到此這篇關于java仿QQ微信聊天室的文章就介紹到這了,更多相關java聊天室內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網！