क्लाइंट-सर्वर चैट Qt / C ++ सॉकेट का उपयोग कर

प्रस्तावना

लेख मुख्य रूप से शुरुआती के लिए लक्षित है। इसके लेखन का उद्देश्य नेटवर्क की प्रारंभिक समझ और सॉकेट्स के लिए सॉकेट्स का त्वरित और विस्तृत विवरण है। एक समय मैं एक समान एक की तलाश में था, लेकिन विस्तृत उदाहरणों की आवश्यकता थी। मानक उदाहरण में, क्यूटी के साथ आने वाला भाग्य सर्वर / क्लाइंट बहुत खराब सॉकेट क्षमताओं को दर्शाता है।

तो, सर्वर कर सकते हैं:

• "सुनो" एक मनमाने पते के लिए, बंदरगाह
• नाम से ग्राहक अधिकृत करें
• सामान्य, निजी, सर्वर संदेश भेजें
• उपयोगकर्ता सूची भेजें

क्लाइंट सर्वर के लिए उपयुक्त अनुरोध प्रस्तुत कर सकता है।

समझने के लिए, ये Gooey एप्लिकेशन होंगे:



Qt में, सॉकेट्स के साथ काम करने के लिए qtcpSocket और QTcpServer क्लासेस हैं। संकेतों और स्लॉट का उपयोग करके, आप उनके साथ गैर-अवरोधक (अतुल्यकालिक मोड) में काम कर सकते हैं। इसका मतलब है कि यदि सर्वर से कनेक्शन को ध्यान देने योग्य मात्रा में समय लगता है, तो gui ब्लॉक नहीं होता है, लेकिन घटनाओं को संसाधित करना जारी रखता है, और जब कनेक्शन (या त्रुटि) होती है, तो एक निश्चित स्लॉट को बुलाया जाएगा (वर्तमान मामले में, कनेक्टेड () सिग्नल से जुड़ा)।

ग्राहक

चलो एक सरल के साथ शुरू करते हैं - हम कक्षाएं विरासत में नहीं लेंगे, लेकिन क्यूटीपीसी सॉकेट का उपयोग करें:

//dialog.h class Dialog : public QDialog { private slots: //      void onSokConnected(); void onSokDisconnected(); // readyRead ,     (      )  void onSokReadyRead(); void onSokDisplayError(QAbstractSocket::SocketError socketError); private: QTcpSocket *_sok; // quint16 _blockSize;//    QString _name;//  }; 

सामान्य तौर पर, जब सॉकेट्स के साथ काम करते हैं, तो आपको डेटा को बाइट्स के एक सेट के रूप में देखना होगा, अन्यथा केवल आंशिक रूप से जानकारी प्रदर्शित करने में समस्याएं हो सकती हैं (एक पूर्ण संदेश नहीं आया है, और अगला पिछले एक टुकड़े के साथ प्रदर्शित किया गया है)। इन परेशानियों से बचने के लिए, हम डेटा स्ट्रीम (QDataStream) का उपयोग करेंगे और सॉकेट्स के बीच ब्लॉक ट्रांसफर करेंगे जिसमें पहले 2 बाइट्स वर्तमान ब्लॉक का आकार है, तीसरा बाइट सर्वर (या सर्वर रिस्पांस) के लिए क्लाइंट कमांड है, और बाकी कमांड के आधार पर डेटा है। यह कहने योग्य है कि टीसीपी प्रोटोकॉल सभी पैकेटों के वितरण की गारंटी देता है, इसलिए आप इसे संसाधित करने के लिए ब्लॉक के पूर्ण आकार के लिए सुरक्षित रूप से प्रतीक्षा कर सकते हैं।

 //dialog.cpp Dialog::Dialog(QWidget *parent) :QDialog(parent),ui(new Ui::Dialog) { //  _sok = new QTcpSocket(this); //  connect(_sok, SIGNAL(readyRead()), this, SLOT(onSokReadyRead())); connect(_sok, SIGNAL(connected()), this, SLOT(onSokConnected())); connect(_sok, SIGNAL(disconnected()), this, SLOT(onSokDisconnected())); connect(_sok, SIGNAL(error(QAbstractSocket::SocketError)),this, SLOT(onSokDisplayError(QAbstractSocket::SocketError))); } //     , ,  connectToHost()   void, ,            onSokDisplayError void Dialog::on_pbConnect_clicked() { _sok->connectToHost(ui->leHost->text(), ui->sbPort->value()); } void Dialog::onSokConnected() { //       QByteArray block; QDataStream out(&block, QIODevice::WriteOnly); // 2    .  MyClient    ,        -   //  -  out << (quint16)0 << (quint8)MyClient::comAutchReq << ui->leName->text(); _name = ui->leName->text(); //   out.device()->seek(0); //      out << (quint16)(block.size() - sizeof(quint16)); _sok->write(block); } void Dialog::onSokReadyRead() { //     QDataStream in(_sok); //     2     if (_blockSize == 0) { //   2     2  if (_sok->bytesAvailable() < (int)sizeof(quint16)) return; //  (2 ) in >> _blockSize; } //     if (_sok->bytesAvailable() < _blockSize) return; else //    _blockSize = 0; //3  -   quint8 command; in >> command; switch (command) { //   ,   ,        MyClient::comUsersOnline case MyClient::comUsersOnline: { QString users; in >> users; if (users == "") return; //    ,   (       QStringList) QStringList l = users.split(","); //  ui->lwUsers->addItems(l); } break; //    case MyClient::comPublicServerMessage: { //     QString message; in >> message; AddToLog("[PublicServerMessage]: "+message, Qt::red); } ... } } 

यह सब क्लाइंट के साथ है - मुख्य बिंदुओं का वर्णन किया गया है, बाकी बहुत सरल है।

सर्वर

सर्वर में सब कुछ अधिक जटिल होगा - हम गुई (डायलॉग), सर्वर (माईस्वर) और क्लाइंट (मायक्लियर) को अलग कर देंगे। जो सॉकेट्स से अपरिचित है वह यह नहीं समझ सकता है कि क्लाइंट किस सर्वर में हो सकता है? इसलिए, सॉकेट को सर्वर से कनेक्ट करते समय, सर्वर पर, एक नियम के रूप में, एक "क्लाइंट" सॉकेट बनाया जाता है, जिसे सरणी में जोड़ा जाता है (विचार एक साहचर्य सरणी का उपयोग करने का सुझाव देता है, लेकिन सादगी के लिए हम QList ले लेंगे)।

 //dialog.cpp Dialog::Dialog(QWidget *parent) :QDialog(parent), ui(new Ui::Dialog) { // .    - parent,  -     ,     myclient   _serv = new MyServer(this, this); //      connect(this, SIGNAL(messageFromGui(QString,QStringList)), _serv, SLOT(onMessageFromGui(QString,QStringList))); ... //     127.0.0.1:1234 if (_serv->doStartServer(QHostAddress::LocalHost, 1234)) {...} else {...} } 

हम qtcpServer से वर्ग वारिस करते हैं, यह वर्चुअल फ़ंक्शन इनकमिंग कॉनकनेक्शन को ओवरराइड करने के लिए आवश्यक है, जिसमें आने वाले कनेक्शन को इंटरसेप्ट किया गया है (इनपुट पैरामीटर सॉकेट डिस्क्रिप्टर है)

 //myserver.h class MyServer : public QTcpServer { public: bool doStartServer(QHostAddress addr, qint16 port); void doSendToAllUserJoin(QString name); //    void doSendToAllUserLeft(QString name); void doSendToAllMessage(QString message, QString fromUsername); //  void doSendToAllServerMessage(QString message);//  void doSendServerMessageToUsers(QString message, const QStringList &users); //   void doSendMessageToUsers(QString message, const QStringList &users, QString fromUsername); QStringList getUsersOnline() const; //   bool isNameValid(QString name) const; //  bool isNameUsed(QString name) const; //    protected: void incomingConnection(int handle); private: QList<MyClient *> _clients; //  QWidget *_widget; //         myclient }; //myserver.cpp void MyServer::incomingConnection(int handle) { //  ,    (   ),    - parent MyClient *client = new MyClient(handle, this, this); //    ,       if (_widget != 0) { connect(client, SIGNAL(addUserToGui(QString)), _widget, SLOT(onAddUserToGui(QString))); connect(client, SIGNAL(removeUserFromGui(QString)), _widget, SLOT(onRemoveUserFromGui(QString))); ... } _clients.append(client); } /*           ,    _clients, ,    */ void MyServer::doSendServerMessageToUsers(QString message, const QStringList &users) { //    QByteArray block; QDataStream out(&block, QIODevice::WriteOnly); out << (quint16)0 << MyClient::comPrivateServerMessage << message; out.device()->seek(0); out << (quint16)(block.size() - sizeof(quint16)); //   (  ,     users  ) for (int j = 0; j < _clients.length(); ++j) if (users.contains(_clients.at(j)->getName())) _clients.at(j)->_sok->write(block); } 

ग्राहक वर्ग के लिए, शायद यह केवल इंटरफ़ेस का वर्णन करने योग्य है, यहाँ सब कुछ सादृश्य द्वारा स्पष्ट है। MyClient को QTcpSocket से विरासत में प्राप्त करने की आवश्यकता नहीं है, इसे अलग तरीके से किया जा सकता है:

 //myclient.h class MyClient : public QObject { //   MyServer    _sok friend class MyServer; public: static const QString constNameUnknown; static const quint8 comAutchReq = 1; static const quint8 comUsersOnline = 2; ... static const quint8 comErrNameUsed = 202; void setName(QString name) {_name = name;} QString getName() const {return _name;} bool getAutched() const {return _isAutched;} void doSendCommand(quint8 comm) const; void doSendUsersOnline() const; signals: //    void addUserToGui(QString name); void removeUserFromGui(QString name); void messageToGui(QString message, QString from, const QStringList &users); //    QList void removeUser(MyClient *client); //      private slots: void onConnect(); void onDisconnect(); void onReadyRead(); void onError(QAbstractSocket::SocketError socketError) const; private: QTcpSocket *_sok; // MyServer *_serv; //   quint16 _blockSize; //   QString _name; // bool _isAutched; //  }; 

अपडेट 2017 :
काश, स्रोत कोड पहले से ही हमेशा के लिए खो जाता है
अपडेट 2018 :
जैसा कि आप जानते हैं, जो कुछ भी कभी इंटरनेट पर अपलोड किया गया है, वह हमेशा के लिए बना रहता है। Vladpower के लिए धन्यवाद फिर से उपलब्ध हैं