話不多說，先上圖

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

本系統(tǒng)實(shí)現(xiàn)的功能有:1.用戶名字登錄 2.用戶之間的群聊和查看群聊記錄3.用戶之間的私聊和私聊記錄4.動態(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)贊和評論等。

有興趣的可進(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

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

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(); } }

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

下面展示關(guān)鍵代碼：list = new JList(listModel); list.setSelectionMode(ListSelectionModel.SINGLE_SELECTION);// 設(shè)置單 一選擇模式（每次只能有一個元素被選中）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)獲取數(shù)據(jù)庫連接 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語句對象 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ā)送登陸報文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ù)器時出現(xiàn)異常');e.printStackTrace();System.out.println('連接服務(wù)器時出現(xiàn)異常');return;}while(isLogged){try{String msg=dis.readUTF();String[] parts=msg.split('#');//處理服務(wù)器發(fā)送過來的報文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');//自動滾動到文本區(qū)的最后一行textAreaRecord.setCaretPosition(textAreaRecord.getText().length());new save();}private void addMsg2(String msg){textAreaRecord.append('t'+'t'+'t'+'t'+msg+':'+'用戶'+id1+'n');//自動滾動到文本區(qū)的最后一行textAreaRecord.setCaretPosition(textAreaRecord.getText().length());new save()；}class save{public save(){ try { // 注冊mysql驅(qū)動程序 Class.forName('com.mysql.jdbc.Driver');//driver System.out.println('找到Mysql數(shù)據(jù)庫驅(qū)動程序'); } catch (Exception e1) { System.out.println('在類路徑上找不到Mysql驅(qū)動程序，' + '請檢查類路徑上是否加載mysql的jar包!'); } // (3)獲取數(shù)據(jù)庫連接 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('建立數(shù)據(jù)庫連接成功'); } catch (Exception e1) { e1.printStackTrace(); System.out.println('創(chuàng)建數(shù)據(jù)庫連接失敗！'); } // （4）創(chuàng)建一個SQL語句執(zhí)行（需要在Java執(zhí)行SQL語句） Statement stmt = null; try { // 通過conn對象創(chuàng)建SQL語句對象 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, '注冊成功'); System.out.println('數(shù)據(jù)插入成功');// JOptionPane.showMessageDialog(this, '注冊成功'); } 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和serverPoetString 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)識變量isRunning=true;btnStart.setEnabled(false);btnStop.setEnabled(true);addMsg('服務(wù)器啟動成功');System.out.println('服務(wù)器啟動成功');}catch(IOException e){System.out.println('服務(wù)器啟動失敗');e.printStackTrace();isRunning=false;}}public void run(){startServer();//當(dāng)服務(wù)器處于運(yùn)行狀態(tài)時，循環(huán)監(jiān)聽客戶端的連接請求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ā)送的報文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);//將現(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);//存儲登錄的用戶名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();}}} /** * 將某個用戶發(fā)來的信息廣播個其他用戶 */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)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！