Qt में सॉकेट्स के साथ काम करें

परिचय

कुछ साल पहले, मंचों में से एक में, मुझे ऐसा अद्भुत वाक्यांश मिला - "जीवन में हर स्वाभिमानी प्रोग्रामर को अपना स्वयं का चैट क्लाइंट लिखना होगा।" तब मेरे ज्ञान ने मुझे ऐसा करने की अनुमति नहीं दी। मैं मुस्कुराया और इस वाक्यांश को पारित किया। लेकिन अभी हाल ही में, मुझे इस विशेष समस्या का सामना करना पड़ा - मुझे अपनी चैट लिखनी पड़ी। खैर, चूंकि हाल ही में मेरी रुचि क्यूटी-अनुप्रयोगों के अध्ययन और विकास पर केंद्रित है, जिस पर यह किया जाएगा, यह स्वयं द्वारा तय किया गया था।



Qt में नेटवर्किंग QtNetwork के माध्यम से की जाती है। और परियोजना के लिए इसे समर्थन शुरू करने के लिए, आपको .pro फ़ाइल में qt + = नेटवर्क जोड़ने की आवश्यकता है। Qt सॉकेट कनेक्शन के कई प्रकारों का समर्थन करता है। इनमें से मुख्य हैं: क्वैडपॉकेट और क्यूकस्पॉकेट। डेटा पैकेटों के आदान-प्रदान के लिए क्वैडसकेट एक डेटाग्राम सॉकेट है। इस सॉकेट का उपयोग करके, डेटा को जांचे बिना भेजा जाता है कि डेटा आ गया है या नहीं। दूसरी ओर, qcpSocket एक बिंदु-से-बिंदु कनेक्शन स्थापित करता है और भ्रष्टाचार और डेटा हानि के खिलाफ अतिरिक्त तंत्र प्रदान करता है।



दोनों वर्ग QAbstractSocket वर्ग से विरासत में मिले हैं। QSslSocket क्लास भी है, लेकिन मुझे उस समय इसकी ज़रूरत नहीं थी, इसलिए मैंने इसे नहीं छुआ।

बातचीत

जब मैंने एप्लिकेशन आर्किटेक्चर को डिजाइन करना शुरू किया, तो सवाल यह था: "और उपयोगकर्ता उपयोगकर्ताओं को एक दूसरे के साथ कैसे बातचीत करेंगे?" यह सिर्फ इतना था कि चैट को स्थानांतरित करने की क्षमता के साथ चैट को सामान्य चैट विंडो और निजी संदेशों दोनों का समर्थन करना था। यदि फ़ाइल स्थानांतरण के साथ सबकुछ स्पष्ट था - केवल टीसीपी था, क्योंकि पैकेट आने पर नियंत्रण और जांच होनी चाहिए, तो मुख्य चैट के साथ कठिनाइयां थीं। आखिरकार, चैट में कोई अलग सर्वर नहीं है। हां, और अगर उनकी बातचीत टीसीपी के माध्यम से की जाती है, तो प्रत्येक उपयोगकर्ता के लिए एक बंदरगाह आवंटित करना आवश्यक होगा, जो थोड़ा उपरि है। ठीक है, अगर टीसीपी नहीं, तो यूडीपी! यह इसके लिए पूरी तरह से उपयुक्त है। एक विशिष्ट पोर्ट को सुनकर, हम उपयोगकर्ता से संदेश प्राप्त करते हैं जिन्होंने उन्हें उसी पोर्ट पर सभी को भेजा है। और अगर कुछ चैट मैसेज खो जाता है, तो यह इतना डरावना नहीं होगा।

QUdpSocket

जैसा कि यह निकला, क्वैडपॉकेट श्रेणी के साथ काम करना आसान नहीं है, लेकिन बहुत सरल है। हम एक क्लास ऑब्जेक्ट बनाते हैं, निर्दिष्ट पोर्ट से बांधते हैं, QIODevice क्लास के सिग्नल से जुड़ते हैं और इस पोर्ट पर संदेशों के आने का इंतजार करते हैं।

UdpChat(QString nick, int port) {

nickname = nick;

socket = new QUdpSocket( this );

_port = port;

socket->bind(QHostAddress::Any, port);

// //

connect(socket, SIGNAL(readyRead()), SLOT(read()));

}



* This source code was highlighted with Source Code Highlighter .

मैं कोड के अगले ब्लॉक से पहले यह भी कहना चाहूंगा कि हमारे मामले में चैट नेटवर्क पर लोगों की संख्या नहीं जानता है। हम सिर्फ एक प्रसारण अनुरोध करेंगे। लेकिन लोगों की एक सूची बनाने के लिए, हम "कौन ऑनलाइन है?" जैसी कोई चीज़ भेजेगा, जिससे यह संदेश पाने वाले लोग "I" भेजेंगे। इसलिए हमारे पास 3 प्रकार के संदेश होंगे:

1. उपयोगकर्ता से नियमित संदेश
2. संदेश - उपयोगकर्ता ऑनलाइन
3. संदेश - ऑनलाइन कौन है?

नतीजतन, हम प्राप्त करते हैं:

void send(QString str, qint8 type) {

QByteArray data;

QDataStream out (&data, QIODevice::WriteOnly);

out << qint64(0);

out << qint8(type);

out << str;

out .device()->seek(qint64(0));

out << qint64(data.size() - sizeof (qint64));

socket->writeDatagram(data, QHostAddress::Broadcast, _port);

}



void read() {

QByteArray datagram;

datagram.resize(socket->pendingDatagramSize());

QHostAddress *address = new QHostAddress();

socket->readDatagram(datagram.data(), datagram.size(), address);



QDataStream in (&datagram, QIODevice::ReadOnly);



qint64 size = -1;

if ( in .device()->size() > sizeof (qint64)) {

in >> size;

} else return ;

if ( in .device()->size() - sizeof (qint64) < size) return ;



qint8 type = 0;

in >> type;



if (type == USUAL_MESSAGE) {

QString str;

in >> str;

// //

} else if (type == PERSON_ONLINE) {

// QHostAddress //

} else if (type == WHO_IS_ONLINE) {

sending(nickname, qint8(PERSON_ONLINE));

}

}



* This source code was highlighted with Source Code Highlighter .

सब कुछ पारदर्शी और स्पष्ट है। यह इंटरफ़ेस को बन्धन करने के लिए बनी हुई है, सभी संकेतों को कनेक्ट करें और मुख्य चैट विंडो तैयार है।

QTcpSocket

इस सॉकेट के लिए, यह क्लाइंट-सर्वर मॉडल को लागू करता है। अर्थात्, हमारे मामले में, प्रत्येक उपयोगकर्ता एक सर्वर की तरह बन सकता है यदि वह किसी को निजी संदेश लिखने या फ़ाइल भेजने के लिए पहले शुरू करता है। या मुवक्किल द्वारा, यदि वे उसे पहले निजी तौर पर लिखते थे।



संदेश भेजने में कोई कठिनाई नहीं है। लेकिन फाइल भेजने के लिए हम एक क्लासिक ट्रिक करेंगे। चूँकि पूरी फाइल को स्ट्रीम में धकेला नहीं जा सकता है, यह फाइल से डेटा को पढ़ेगा और स्ट्रीम में पार्टवाइज़ लिखेगा, और फिर उन्हें भेजेगा।

void sendFile(QString fileName) {

if (sendFile != NULL){

return ;

}

sendFile = new QFile(fileName);

if (sendFile->open(QFile::ReadOnly)){

QByteArray data;

QDataStream out (&data, QIODevice::WriteOnly);

// //

clientSocket->write(data);

clientSocket->waitForBytesWritten();

connect(clientSocket, SIGNAL(bytesWritten(qint64)), this , SLOT(sendPartOfFile()));

sendPartOfFile();

} else {

emit this ->errorSendFile(QString( "File not can open for read" ));

return ;

}

}



void sendPartOfFile() {

char block[SIZE_BLOCK_FOR_SEND_FILE];

if (!sendFile->atEnd()){

qint64 in = sendFile->read(block, sizeof (block));

qint64 send = clientSocket->write(block, in );

} else {

sendFile->close();

sendFile = NULL;

disconnect(clientSocket, SIGNAL(bytesWritten(qint64)), this , SLOT(sendPartOfFile()));

emit endSendFile();

}

}



* This source code was highlighted with Source Code Highlighter .

यह धारा को पढ़ने पर विचार करने के लिए बनी हुई है। चूंकि केवल 2 डेटा प्रकार आते हैं - मेसेज और सेंडर, एक नियमित इनपुट पार्सर लिखना मुश्किल नहीं होगा। यह वर्ग विधि के समान है जो यूडीपी सॉकेट को लागू करता है। ब्याज की हस्तांतरित फ़ाइल की धारा से पढ़ रहा है।

void receiveFile(QString fileName) {

QString savePath = "Downloads/" ;

QDir dir;

dir.mkpath(savePath);

receiveFile = new QFile(savePath + fileName);

sizeReceivedData = 0;

receiveFile();

}



void receiveFile() {

QDataStream in (clientSocket);

if (!bufferForUnreadData.isEmpty()){

receiveFile->write(bufferForUnreadData);

sizeReceivedData += bufferForUnreadData.size();

bufferForUnreadData.clear();

}

char block[SIZE_BLOCK_FOR_SEND_FILE];

while (! in .atEnd()){

qint64 toFile = in .readRawData(block, sizeof (block));

sizeReceivedData += toFile;

receiveFile->write(block, toFile);

}

if (sizeReceivedData == sizeReceiveFile){

receiveFile->close();

receiveFile = NULL;

sizeReceiveFile = 0;

sizeReceivedData = 0;

}

}



* This source code was highlighted with Source Code Highlighter .

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



लेख का उद्देश्य उदाहरण द्वारा दिखाना था कि सॉकेट्स के साथ काम करना सरल और आसान है। मुझे उम्मीद है कि यह लेख भविष्य में किसी की मदद करेगा। सौभाग्य है।