JAVA入門到精通-第92講-山寨QQ專案6-多對多的聊天

阿新 • • 發佈：2018-12-01

QQ聊天專案演示-多對多的聊天

流同時併發的異常；
伺服器中轉 2/3號只有一個連線；

接收資訊：while迴圈不停地讀取；

當1號點開兩個視窗時，2/3會共同去爭取這個socket； 會出現流同時併發異常；

Socket處理成static不太合理；
啟動一個視窗就會佔據Socket不放；

------------- -實現真正的多人聊天，互相不出現錯誤

-每一個登入的賬號獨享一份socket -去掉static 當一個連結達成的時候，啟動執行緒，和伺服器保持通訊的狀態；做一個類來管理客戶端這邊的執行緒；

-新的賬號登入，開一個執行緒ClientConServerThread

-管理執行緒的類，放入到一個HashMap裡面：ManageClientConServerThread；

HashMap<k,v> k:使用者賬號，某個賬號獨享的執行緒 v:ClientConServerThread

----------------- -當賬號登入成功，建立執行緒，把執行緒放入HashMap

-------------------- Qq聊天介面沒有必要成為一個執行緒；本身是不合理的；

通過管理執行緒的類，取得了執行緒，通過執行緒取得socket， 通過socket，取得了輸出流：getOutputStream;
---------------------- 給每一個登入賬號分配執行緒；

把通訊的任務交給執行緒類； ---------------------
-多對多聊天

經測試，後臺傳送訊息正常；
--------------- -顯示後臺的訊息到各自的聊天介面

QqChat.java]

/**
 * 這是與好友聊天的介面
 * 因為客戶端，要處於讀取的狀態，因此我們把它做成一個執行緒
 */
package com.qq.client.view;
 
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.Date;
import javax.swing.ImageIcon;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import com.qq.client.model.QqClientConServer;
import com.qq.client.tools.ManageClientConServerThread;
import com.qq.common.Message;
import com.qq.common.MessageType;
 
public class QqChat extends JFrame implements ActionListener {
    JTextArea jta;
    JTextField jtf;
    JButton jb;
    JPanel jp;
    JScrollPane jsp;
    String ownerId;
    String friendId;
 
    // public static void main(String[] args) {
    // new QqChat("小四");
    // }
 
    // 建構函式
    public QqChat(String friendId, String ownerId) {
        this.ownerId = ownerId;
        this.friendId = friendId;
 
        jta = new JTextArea();
        jtf = new JTextField(15);
        jb = new JButton("傳送");
        jb.addActionListener(this);
        jp = new JPanel();
        jp.add(jtf);
        jp.add(jb);
        jsp = new JScrollPane(jta);
 
        this.add(jsp, "Center");
        this.add(jp, "South");
 
        this.setTitle(ownerId + " 正在與 " + friendId + " 聊天");
        this.setSize(350, 300);
        this.setIconImage((new ImageIcon("image/qie.jpg")).getImage());
        this.setLocationRelativeTo(null);
        this.setVisible(true);
    }
 
    // 寫一個方法，讓它顯示訊息
    public void showMessage(Message m){
        String info=m.getSender()+" 對 "+m.getGetder()+" 說:"+m.getCon()+"\r\n";
        jta.append(info);
    }
 
    @Override
    public void actionPerformed(ActionEvent e) {
        if (e.getSource() == jb) {
            // 如果使用者點選了傳送按鈕
            Message m = new Message();
            m.setMesType(MessageType.message_comm_mes);
            m.setSender(this.ownerId);
            m.setGetder(this.friendId);
            m.setCon(this.jtf.getText());
            m.setSendTime(new Date().toString());
            jta.append(ownerId + " 對 " + friendId + " 說:" + jtf.getText()
                    + "\r\n");
            jtf.setText("");
            // 傳送給伺服器
            try {
                ObjectOutputStream oos = new ObjectOutputStream(
                        ManageClientConServerThread
                                .getClientConServerThread(ownerId).getS()
                                .getOutputStream());
                oos.writeObject(m);
            } catch (Exception e1) {
                e1.printStackTrace();
            }
        }
    }
 
    // @Override
    // public void run() {
    // while(true){
    // //讀取[如果讀不到就等待]
    // try {
    // ObjectInputStream ois=new
    // ObjectInputStream(QqClientConServer.s.getInputStream());
    // Message m=(Message)ois.readObject();
    // //顯示出來
    // String info=m.getSender()+" 對 "+m.getGetder()+" 說:"+m.getCon()+"\r\n";
    // jta.append(info);
    // } catch (Exception e) {
    // e.printStackTrace();
    // }
    // }
    // }
}

110 110 1

/**

 * 這是與好友聊天的介面

 * 因為客戶端，要處於讀取的狀態，因此我們把它做成一個執行緒

*/

package com.qq.client.view;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.io.IOException;

import java.io.ObjectInputStream;

import java.io.ObjectOutputStream;

import java.util.Date;

import javax.swing.ImageIcon;

import javax.swing.JButton;

import javax.swing.JFrame;

import javax.swing.JPanel;

import javax.swing.JScrollPane;

import javax.swing.JTextArea;

import javax.swing.JTextField;

import com.qq.client.model.QqClientConServer;

import com.qq.client.tools.ManageClientConServerThread;

import com.qq.common.Message;

import com.qq.common.MessageType;

public class QqChat extends JFrame implements ActionListener {

    JTextArea jta;

    JTextField jtf;

    JButton jb;

    JPanel jp;

    JScrollPane jsp;

    String ownerId;

    String friendId;

    // public static void main(String[] args) {

    // new QqChat("小四");

    // }

    // 建構函式

    public QqChat(String friendId, String ownerId) {

        this.ownerId = ownerId;

        this.friendId = friendId;

        jta = new JTextArea();

        jtf = new JTextField(15);

        jb = new JButton("傳送");

        jb.addActionListener(this);

        jp = new JPanel();

        jp.add(jtf);

        jp.add(jb);

        jsp = new JScrollPane(jta);

        this.add(jsp, "Center");

        this.add(jp, "South");

        this.setTitle(ownerId + " 正在與 " + friendId + " 聊天");

        this.setSize(350, 300);

        this.setIconImage((new ImageIcon("image/qie.jpg")).getImage());

        this.setLocationRelativeTo(null);

        this.setVisible(true);

    // 寫一個方法，讓它顯示訊息

    public void showMessage(Message m){

        String info=m.getSender()+" 對 "+m.getGetder()+" 說:"+m.getCon()+"\r\n";

        jta.append(info);

    @Override

    public void actionPerformed(ActionEvent e) {

        if (e.getSource() == jb) {

            // 如果使用者點選了傳送按鈕

            Message m = new Message();

            m.setMesType(MessageType.message_comm_mes);

            m.setSender(this.ownerId);

            m.setGetder(this.friendId);

            m.setCon(this.jtf.getText());

            m.setSendTime(new Date().toString());

            jta.append(ownerId + " 對 " + friendId + " 說:" + jtf.getText()

                    + "\r\n");

            jtf.setText("");

            // 傳送給伺服器

            try {

                ObjectOutputStream oos = new ObjectOutputStream(

                        ManageClientConServerThread

                                .getClientConServerThread(ownerId).getS()

                                .getOutputStream());

                oos.writeObject(m);

            } catch (Exception e1) {

                e1.printStackTrace();

    // @Override

    // public void run() {

    // while(true){

    // //讀取[如果讀不到就等待]

    // try {

    // ObjectInputStream ois=new

100

    // ObjectInputStream(QqClientConServer.s.getInputStream());

101

    // Message m=(Message)ois.readObject();

102

    // //顯示出來

103

    // String info=m.getSender()+" 對 "+m.getGetder()+" 說:"+m.getCon()+"\r\n";

104

    // jta.append(info);

105

    // } catch (Exception e) {

106

    // e.printStackTrace();

107

    // }

108

    // }

109

    // }

110

*******************************************************************************

com.qq.client.model

[QqClienConServer.java]

/**
 * 這是客戶端連線伺服器的後臺
 * 功能：客戶端與伺服器進行資料互動
 */
package com.qq.client.model;
 
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import com.qq.client.tools.ClientConServerThread;
import com.qq.client.tools.ManageClientConServerThread;
import com.qq.common.Message;
import com.qq.common.User;
 
public class QqClientConServer {
    public Socket s;
   
    //傳送第一次請求
    public boolean sendLoginInfoToServer(Object o){
        boolean b=false;
       
        try {
            s=new Socket("127.0.0.1",9999);
            ObjectOutputStream oos=new ObjectOutputStream(s.getOutputStream());
            oos.writeObject(o);
           
            ObjectInputStream ois=new ObjectInputStream(s.getInputStream());
            Message ms=(Message)ois.readObject();
            //這裡就是驗證使用者登入的地方
            if(ms.getMesType().equals("1")){
                b=true;
                //就建立一個該qq號和伺服器端保持通訊連線的執行緒
                ClientConServerThread ccst=new ClientConServerThread(s);
                //啟動該通訊執行緒
                ccst.start();
               
                ManageClientConServerThread.addClientConServerThread(((User)o).getUserId(), ccst);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally{
        }
        return b;
    }
   
    //向伺服器傳送一個物件
    public void SendInfoToServer(Object o){
        try {
            Socket s=new Socket("127.0.0.1",9999);
        } catch (Exception e) {
            e.printStackTrace();
        } finally{
        }
    }

54 54 1

/**

 * 這是客戶端連線伺服器的後臺

 * 功能：客戶端與伺服器進行資料互動

*/

package com.qq.client.model;

import java.io.ObjectInputStream;

import java.io.ObjectOutputStream;

import java.net.Socket;

import com.qq.client.tools.ClientConServerThread;

import com.qq.client.tools.ManageClientConServerThread;

import com.qq.common.Message;

import com.qq.common.User;

public class QqClientConServer {

    public Socket s;

    //傳送第一次請求

    public boolean sendLoginInfoToServer(Object o){

        boolean b=false;

        try {

            s=new Socket("127.0.0.1",9999);

            ObjectOutputStream oos=new ObjectOutputStream(s.getOutputStream());

            oos.writeObject(o);

            ObjectInputStream ois=new ObjectInputStream(s.getInputStream());

            Message ms=(Message)ois.readObject();

            //這裡就是驗證使用者登入的地方

            if(ms.getMesType().equals("1")){

                b=true;

                //就建立一個該qq號和伺服器端保持通訊連線的執行緒

                ClientConServerThread ccst=new ClientConServerThread(s);

                //啟動該通訊執行緒

                ccst.start();

                ManageClientConServerThread.addClientConServerThread(((User)o).getUserId(), ccst);

        } catch (Exception e) {

            e.printStackTrace();

        } finally{

        return b;

    //向伺服器傳送一個物件

    public void SendInfoToServer(Object o){

        try {

            Socket s=new Socket("127.0.0.1",9999);

        } catch (Exception e) {

            e.printStackTrace();

        } finally{

}

*******************************************************************************

[QqClientUser.java]

/**
 * 使用者操作邏輯類
 * QqClientUser會呼叫QqClientConServer的
 * 方法sendLoginInfoToServer向伺服器傳送
 */
package com.qq.client.model;
 
import com.qq.common.User;
 
public class QqClientUser {
    //驗證使用者是否合法
    public boolean checkUser(User u){
        return new QqClientConServer().sendLoginInfoToServer(u);
    }
}

15 15 1

/**

 * 使用者操作邏輯類

 * QqClientUser會呼叫QqClientConServer的

 * 方法sendLoginInfoToServer向伺服器傳送

*/

package com.qq.client.model;

import com.qq.common.User;

public class QqClientUser {

    //驗證使用者是否合法

    public boolean checkUser(User u){

        return new QqClientConServer().sendLoginInfoToServer(u);

*******************************************************************************

com.qq.client.tools

[ClientConServerThread.java]

/**
 * 這是客戶端和伺服器端保持通訊的執行緒
 */
package com.qq.client.tools;
 
import java.io.ObjectInputStream;
import java.net.Socket;
import com.qq.client.view.QqChat;
import com.qq.client.view.QqFriendList;
import com.qq.common.Message;
import com.qq.common.MessageType;
 
public class ClientConServerThread extends Thread{
    private Socket s;
   
    public Socket getS() {
        return s;
    }
 
    public void setS(Socket s) {
        this.s = s;
    }
 
    //建構函式
    public ClientConServerThread(Socket s){
        this.s=s;
    }
   
    public void run(){
        while(true){
            //不停的讀取從伺服器端發來的訊息
            try {
                ObjectInputStream ois=new ObjectInputStream(s.getInputStream());
                Message m=(Message)ois.readObject();
               
                //按訊息包的型別來處理不同的包
                if(m.getMesType().equals(MessageType.message_comm_mes)){
                    //把從伺服器獲得的訊息，顯示到該顯示的聊天介面上
                    QqChat qqChat=ManageQqChat.getQqChat(m.getGetder()+" "+m.getSender());
                    //顯示
                    qqChat.showMessage(m);
                }else if(m.getMesType().equals(MessageType.message_ret_onLineFriend)){
                    String con=m.getCon();
                    String []friends=con.split(" ");
                    String getter=m.getGetder();
                    //修改相應的好友列表
                    QqFriendList qqFrindList=ManageQqFriendList.getQqFriendList(getter);
                    //更新線上好友
                    if(qqFrindList!=null){
                        qqFrindList.updateFriend(m);
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

58 58 1

/**

 * 這是客戶端和伺服器端保持通訊的執行緒

*/

package com.qq.client.tools;

import java.io.ObjectInputStream;

import java.net.Socket;

import com.qq.client.view.QqChat;

import com.qq.client.view.QqFriendList;

import com.qq.common.Message;

import com.qq.common.MessageType;

public class ClientConServerThread extends Thread{

    private Socket s;

    public Socket getS() {

        return s;

    public void setS(Socket s) {

        this.s = s;

    //建構函式

    public ClientConServerThread(Socket s){

        this.s=s;

    public void run(){

        while(true){

            //不停的讀取從伺服器端發來的訊息

            try {

                ObjectInputStream ois=new ObjectInputS

JAVA入門到精通-第92講-山寨QQ專案6-多對多的聊天

QQ聊天專案演示-多對多的聊天流同時併發的異常；伺服器中轉 2/3號只有一個連線；接收資訊：while迴圈不停地讀取；當1號點開兩個視窗時，2/3會共同去

JAVA入門到精通-第92講-山寨QQ項目6-多對多的聊天

不同的 llc data- cli 界面 shm tool 出現 per QQ聊天項目演示-多對多的聊天流同時並發的異常；服務器中轉2/3號只有一個連接；接收信息：while循環不停地讀取；當1號點開兩個窗口時，2/3會共同去爭取這個socket；會出現流同時並發異常；So

JAVA入門到精通-第90講-山寨QQ專案4-登入驗證(1)

common中的User類：序列化就是可以讓一個物件在網路或者檔案中傳輸；例如：使用者資訊； ------------- -客戶端連線伺服器 //把使用者名稱和密碼傳遞給伺服器使用者點選登入：連線QQ，啟動QQ

JAVA入門到精通-第89講-山寨QQ專案3-聊天介面.物件流

當點選某一個好友出現聊天的介面：文字域：JTextArea ------------------------------------------- 更改視窗小圖示： this.setIconImage ((ne

JAVA入門到精通-第88講-山寨QQ專案2-好友列表介面

好友列表介面：卡片整個是一個JPanel，Border佈局的Panel JButton，我的好友；中間也是一個JPanel JScrollPane該控制元件放了一個JPanel（GridLayout(10,1)）好友列表；網格佈局，10-10個好友；

JAVA入門到精通-第87講-山寨QQ專案1-登入介面

不考慮使用者是否離線的問題；寫專案之前單開一個工作區： File-switch workspace v

JAVA入門到精通-第94講-山寨QQ專案8-好友線上提示

遇到的問題：現在每登入一個人，後面的人是能看到前面的登入的人的；但是，前面的人看不到後面的人登入； //後面每登入一個人，有責任去通知前面登入的人他已經上線了；通知了完以後，需要更改好友線上的情況；

JAVA入門到精通-第93講-山寨QQ專案7-好友線上提示

-顯示聊天資訊 -用一個類來管理聊天介面，放到 HashMap裡面； QqChat放到一個類裡面進行管理； HashMap管理就是引用了一下； ManageQqChat類對顯示來說非常重要了；

JAVA入門到精通-第91講-山寨QQ專案5-一對一的聊天

聊天：希望在介面最上面顯示我的QQ號碼：顯示自己的編號；在視窗欄顯示自己的編號： --------------------

JAVA入門到精通-第94講-山寨QQ項目8-好友在線提示

遇到的問題印象聊天界面 hat www user tco man lis 遇到的問題：現在每登錄一個人，後面的人是能看到前面的登錄的人的；但是，前面的人看不到後面的人登錄；//後面每登錄一個人，有責任去通知前面登錄的人他已經上線了；通知了完以後，需要更改好友在線的情況；

JAVA入門到精通-第93講-山寨QQ項目7-好友在線提示

nag neu data- 山寨 blank stat idt getter client -顯示聊天信息-用一個類來管理聊天界面，放到HashMap裏面；QqChat放到一個類裏面進行管理；HashMap管理就是引用了一下；ManageQqChat類對顯示來說非常重要了；

JAVA從入門到精通-第2講-變數-資料型別

不同資料型別資料大小範圍的計算位元組x8-1 至位元組x8-1 資料可以自動從低精度向高精度轉

JAVA入門到精通-第1講

變量環境 col font 開發工具 -h indent -i 簡單的 p.MsoNormal,li.MsoNormal,div.MsoNormal { margin: 0cm; margin-bottom: .0001pt; text-align: justify; f

JAVA入門到精通-第55講-sql server基本使用

服務管理器：自動：跟系統一起啟動；手動避免吃記憶體；企業管理器：（偏向於圖形使用者介面的） SQL Server組來管理的；表只是資料物件的一種；資料庫

JAVA入門到精通-第54講-sql server安裝配置和解除安裝

Sybase在UNIX作業系統上用的更好； Windows身份認證：只要能登陸到windows就認為是合法使用者；混合模式：不但能進windows，還需要使用者名稱和密碼；

JAVA入門到精通-第53講-資料庫概念

資料庫程式設計衡量一個程式設計師技術水平的高低：資料庫、面向物件、網路、介面資料庫：檔案儲存資料的缺點：檔案不利於查詢排名檔案超過10M或

JAVA入門到精通-第62講-複雜查詢

每個部門的平均工資是不一樣的； --from子句中使用查詢分析： 1.首先要知道各個部門的平均工資 select avg(sal), deptno from emp group by deptno

JAVA入門到精通-第67講-sqlserver作業講評

sql server作業點評：使用scott/tiger使用者下的emp表完成下列練習，表的結構說明如下 emp員工表(empno員工號/ename員工姓名/job工作/mgr上級編號/hiredate受僱日期/sal薪金/comm佣金/deptno部門編號) //把課堂上建立的emp,d

JAVA入門到精通-第65講-sql server JDBC

int i=sm.executeUpdate() --ResultSet結果集 rs表示結果集的遊標；指向第一行記錄的最上面；指向頭； rs.next ( ) 取出第一條； rs.getIn

JAVA入門到精通-第66講-sql server-JDBC

sql server JDBC-ODBC sql server面對各種語言的使用； odbc相當於一個開關介面；驅動就是一堆函式、方法或者包； JDBC驅動：資料庫直接支援JAVA程式的呼叫； Hibernate:orm技術，物件關係對映；

JAVA入門到精通-第92講-山寨QQ專案6-多對多的聊天

相關推薦