- 資訊首頁(yè) > 開(kāi)發(fā)技術(shù) >
- java仿QQ微信聊天室功能的實(shí)現
話(huà)不多說(shuō)，先上圖
即時(shí)通信系統:可以完成群聊、私人聊天，實(shí)時(shí)發(fā)送和顯示聊天信息，完成好友列表,進(jìn)一步可以帶表情，附件發(fā)送，聊天信息的傳送，等 系統的主要技術(shù)socket通信技術(shù)，多線(xiàn)程技術(shù)，數據庫技術(shù)。
本系統實(shí)現的功能有:1.用戶(hù)名字登錄 2.用戶(hù)之間的群聊和查看群聊記錄3.用戶(hù)之間的私聊和私聊記錄4.動(dòng)態(tài)刷新并顯示好友列表5.顯示在線(xiàn)人數 6.服務(wù)器可以顯示用戶(hù)在線(xiàn)狀態(tài) 7.能夠退出處理。
該程序可以實(shí)現局域網(wǎng)的聊天，只要把ip改為局域網(wǎng)ip即可。該系統ui中有許多沒(méi)實(shí)現的功能，比如添加好友（通過(guò)驗證成為好友），發(fā)布說(shuō)說(shuō)到空間，然后可以進(jìn)行點(diǎn)贊和評論等。
有興趣的可進(jìn)行拓展。。系統視頻效果觀(guān)看鏈接
下載鏈接
gitee下載鏈接
注冊，下面是數據庫的關(guān)鍵代碼，主要用于驗證賬號的唯一性和昵稱(chēng)的唯一性，主要用到了二重判斷，先是判斷賬號的唯一，然后再判斷昵稱(chēng)的唯一，當有一條件不足則注冊失敗，下邊代碼主要是數據庫的查詢(xún)功能，先是查詢(xún)數據庫中有沒(méi)有該賬號，然后查數據庫中有沒(méi)該昵稱(chēng)，最后把注冊信息存儲進(jìn)數據庫，不過(guò)下面只展示了查詢(xún)的代碼，儲存信息代碼類(lèi)似這里不做展示。
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, "該昵稱(chēng)已存在,請重新填寫(xiě)昵稱(chē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è)面，主要用到了數據庫的讀取功能，對已登錄的用戶(hù)賬號進(jìn)行讀取，還用到了jlist列表，把已登錄的用戶(hù)賬號顯示在好友列。
下面展示關(guān)鍵代碼：
list = new JList(listModel);
list.setSelectionMode(ListSelectionModel.SINGLE_SELECTION);// 設置單 一選擇模式（每次只能有一個(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)獲取數據庫連接
Connection ct=DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/check?useUn icode=true&characterEncoding=utf_8","root", "123");
//（3）創(chuàng )建SQL語(yǔ)句對象
Statement ps=ct.createStatement();
//(4)執行查詢(xún)，返回結果集
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]);//添加登錄的用戶(hù)到列表框
}
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();
}
因為群聊和私聊的代碼相似，只展示私聊關(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());
//獲取用戶(hù)名，構建，發(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ù)器時(shí)出現異常");
e.printStackTrace();
System.out.println("連接服務(wù)器時(shí)出現異常");
return;
}
while(isLogged){
try{
String msg=dis.readUTF();
String[] parts=msg.split("#");
//處理服務(wù)器發(fā)送過(guò)來(lái)的報文
if(parts[0].equals("USERLIST")){
for(int i=1;i<parts.length;i++){
}
}
if(parts[0].equals("LOGIN")){
addMsg(parts[1]+"上線(xiàn)了");
}
if(parts[0].equals("LOGOUT")){
}
if(parts[0].equals("TALKTO_ALL")){
addMsg(parts[1]+"跟所有人說(shuō):"+parts[2]);
}
if(parts[0].equals("TALKTO")){
addMsg(parts[1]+"跟我說(shuō):"+parts[2]);
}
}catch(IOException e){
isLogged=false;
e.printStackTrace();
}
}
}
}
//啟動(dòng)線(xiàn)程
private void start(){
clientThread=new ClientThread();
clientThread.start();
}
private void addMsg(String msg)
textAreaRecord.append(msg+"\n");
//自動(dòng)滾動(dòng)到文本區的最后一行
textAreaRecord.setCaretPosition(textAreaRecord.getText().length());
new save();
}
private void addMsg2(String msg){
textAreaRecord.append("\t"+"\t"+"\t"+"\t"+msg+":"+"用戶(hù)"+id1+"\n");
//自動(dòng)滾動(dòng)到文本區的最后一行
textAreaRecord.setCaretPosition(textAreaRecord.getText().length());
new save()；
}
class save{
public save(){
try {
// 注冊mysql驅動(dòng)程序
Class.forName("com.mysql.jdbc.Driver");//driver
System.out.println("找到Mysql數據庫驅動(dòng)程序");
} catch (Exception e1) {
System.out.println("在類(lèi)路徑上找不到Mysql驅動(dòng)程序，" + "請檢查類(lèi)路徑上是否加載mysql的jar包!");
}
// (3)獲取數據庫連接
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("建立數據庫連接成功");
} catch (Exception e1) {
e1.printStackTrace();
System.out.println("創(chuàng )建數據庫連接失??！");
}
// （4）創(chuàng )建一個(gè)SQL語(yǔ)句執行（需要在Java執行SQL語(yǔ)句）
Statement stmt = null;
try {
// 通過(guò)conn對象創(chuàng )建SQL語(yǔ)句對象
stmt = conn.createStatement();
} catch (Exception e1) {
e1.printStackTrace();
}
String sql = "INSERT INTO usermessage2 (message2) VALUES('"+textAreaRecord.getText()+"')";
try {
// 執行SQL語(yǔ)句
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)關(guān)閉資源
try {
stmt.close();
conn.close();
} catch (Exception e1) {
e1.printStackTrace();
服務(wù)器 主要用到了網(wǎng)絡(luò )通信和多線(xiàn)程的功能
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ù)器是否運行的標識變量
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();
//當服務(wù)器處于運行狀態(tài)時(shí)，循環(huán)監聽(tīng)客戶(hù)端的連接請求
while(isRunning){
try{
Socket socket=server.accept();
//創(chuàng )建與客戶(hù)端交互的線(xiàn)程
Thread thread=new Thread(new ClientHandler(socket));
thread.start();
}catch(IOException e){
System.out.println("還沒(méi)連接");
}
}
}
}
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{
//讀取客戶(hù)端發(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="用戶(hù):"+parts[1]+""+"已登錄"+"\t"+d3;
addMsg(q);
//如果該用戶(hù)已登錄，則返回失敗報文，否則返回成功報文
if(clientHandlerMap.containsKey(loginUsername)){
dos.writeUTF("FAIL");
}else{
dos.writeUTF("SUCCESS");
//將此客戶(hù)端處理線(xiàn)程的信息添加到clientHandlerMap中
clientHandlerMap.put(loginUsername, this);
//將現有用戶(hù)的信息發(fā)給新用戶(hù)
StringBuffer msgUserList=new StringBuffer();
msgUserList.append("USERLIST");
for(String username : clientHandlerMap.keySet()){
msgUserList.append(username +"#");
}
dos.writeUTF(msgUserList.toString());
//將新登錄的用戶(hù)信息發(fā)給其他用戶(hù)
String msgLogin="LOGIN#"+loginUsername;
broadcastMsg(loginUsername,msgLogin);
//存儲登錄的用戶(hù)名
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="用戶(hù) "+username+"對所有人說(shuō)"+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="用戶(hù) "+clientHandler+" 對"+username+"說(shuō): "+parts[2]+"\t"+d3;
addMsg2(p2);
clientHandler.dos.writeUTF(msgTalkTo);
clientHandler.dos.flush();
}
}
}catch(IOException e){
isConnected=false;
e.printStackTrace();
}
}
}
/**
* 將某個(gè)用戶(hù)發(fā)來(lái)的信息廣播個(gè)其他用戶(hù)
*/
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());
到此這篇關(guān)于java仿QQ微信聊天室的文章就介紹到這了,更多相關(guān)java聊天室內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
免責聲明：本站發(fā)布的內容（圖片、視頻和文字）以原創(chuàng )、來(lái)自互聯(lián)網(wǎng)轉載和分享為主，文章觀(guān)點(diǎn)不代表本網(wǎng)站立場(chǎng)，如果涉及侵權請聯(lián)系QQ:712375056 進(jìn)行舉報，并提供相關(guān)證據，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權內容。
Copyright ? 2009-2021 56dr.com. All Rights Reserved. 特網(wǎng)科技 特網(wǎng)云 版權所有 珠海市特網(wǎng)科技有限公司 粵ICP備16109289號
域名注冊服務(wù)機構:阿里云計算有限公司（萬(wàn)網(wǎng)） 域名服務(wù)機構：煙臺帝思普網(wǎng)絡(luò )科技有限公司（DNSPod） CDN服務(wù)：阿里云計算有限公司 中國互聯(lián)網(wǎng)舉報中心 增值電信業(yè)務(wù)經(jīng)營(yíng)許可證B2
建議您使用Chrome、Firefox、Edge、IE10及以上版本和360等主流瀏覽器瀏覽本網(wǎng)站
