जब्बार के माध्यम से निगरानी प्रणाली

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

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

एक पूरी तरह से अलग मामला इंस्टेंट मैसेजिंग सिस्टम (ICQ, XMPP) है। XMPP को प्राथमिकता दी जाती है क्योंकि यह खुला होता है। और इस तथ्य के कारण कि यह एक पूर्ण नेटवर्क प्रोटोकॉल है, निम्न विकल्प "बॉक्स से बाहर" उपलब्ध हैं:

• संपर्क सूची एक मेलिंग सूची हो सकती है (यह सूची संपादित करना आसान है)
• डेटा एन्क्रिप्ट किया गया है
• वितरण नियंत्रण
• आप प्राप्तकर्ता (ऑनलाइन) की स्थिति देख सकते हैं यह समझने के लिए कि कौन संदेश प्राप्त कर सकता है
• आप व्यक्तिगत कंप्यूटर और मोबाइल डिवाइस दोनों पर संदेश प्राप्त कर सकते हैं और इसके लिए आपको एक विशेष कार्यक्रम विकसित करने की आवश्यकता नहीं है
• अधिसूचना को अन्तरक्रियाशीलता द्वारा विस्तारित किया जा सकता है: अतिरिक्त अनुरोधों को संसाधित करते हुए, चैट / सम्मेलन जोड़ें

यदि वांछित है, तो सूची जारी रखी जा सकती है।

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

कार्यान्वित कार्यक्षमता: कई तकनीकी स्थापनाओं से त्रुटियों को एकत्रित करना, जैबर के माध्यम से संदेश भेजना, जैबर के माध्यम से सामान्य चैट करना।

वास्तुकला और बातचीत तंत्र

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

ग्राहक

कार्यक्रम के मापदंडों

पैरामीटर ने जोंस में स्टोर करने का फैसला किया। काम के लिए, 4 जी क्यूटी का उपयोग किया जाता है, इसमें अभी तक जोंस के साथ काम नहीं होता है, इसलिए क्यूटी (क्यूटी-जोन) के लिए तीसरे पक्ष के पुस्तकालय का उपयोग करके पार्सिंग किया जाता है।

Database.json क्लाइंट सेटिंग फ़ाइल

{ "LogFileName":"c://manlog.log", "ConnectionString":"Driver={Microsoft Paradox Driver (*.db )};DriverID=282;FIL=Paradox 4.x;DBQ=c:\\;ReadOnly=1", "CNCName":"CNC_01", "RefreshPeriod":"2000" } 

पढ़ना पैरामीटर:

  QFile configFile("./config/database.json"); configFile.open(QIODevice::ReadOnly | QIODevice::Text); QTextStream dbFileIn(&configFile); QString jsonData = dbFileIn.readAll(); configFile.close(); bool ok = false; QVariantMap result = QtJson::parse(jsonData, ok).toMap(); if(ok) { foreach(QVariant key, result.keys()) { if(key.toString().toLower()=="connectionstring") connecionString = result.value(key.toString()).toString(); if(key.toString().toLower()=="logfilename") logFileName = result.value(key.toString()).toString(); if(key.toString().toLower()=="refreshperiod") refreshPeriod = result.value(key.toString()).toString().toInt(); if(key.toString().toLower()=="cncname") cncName = result.value(key.toString()).toString(); } } 

PARADOX डेटाबेस से कनेक्शन

क्यूटी से डेटाबेस का उपयोग करने के लिए QODBC है । PARADOX तक पहुंच के लिए कनेक्शन स्ट्रिंग:

 "Driver={Microsoft Paradox Driver (*.db )};DriverID=282;FIL=Paradox 4.x;DBQ=c:\\;ReadOnly=1" 

जहां DBQ डेटाबेस के लिए रास्ता है।
एक महत्वपूर्ण बिंदु: "* .db" से पहले ") के बाद कनेक्शन लाइन में" "एक स्थान है!

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

रैक पर प्रोग्राम मैनलॉग टेबल के लिए लॉग लिखता है।

क्षेत्र का नाम	टाइप	नियुक्ति
डेटा	तिथि	लॉग में प्रविष्टि की तारीख
समय	दिनांक समय	लॉगिंग टाइम
Mes	varchar	संदेश

डेटा प्रकार के स्तंभों में मुझसे गलती की जा सकती है। और उनमें क्यूटी भी गलत है, इसलिए एसक्यूएल क्वेरी को संकलित करते समय, मुझे ट्रिक करनी थी: समय को एक स्ट्रिंग में बदलना, क्योंकि टेटटाइम () की तरह एक फ़ील्ड लेना संभव नहीं था।

 SELECT data, format(ManLog.Time,'hh:mm:ss'), mes from ManLog 

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

  QSqlQuery query; query.exec("SELECT data, format(ManLog.Time,'hh:mm:ss'), mes from ManLog"); ... QByteArray msg = query.value(2).toByteArray(); // ! 

डेटा डेटाबेस से पढ़ा गया है, और अब इसे त्रुटि कोड के साथ सत्यापित किया जाना चाहिए। लेकिन हमें एन्कोडिंग में बाइनरी फॉर्म में त्रुटि कोड भी चाहिए, जिसमें वे डेटाबेस में हैं। आप त्रुटि कोड को json में पंजीकृत कर सकते हैं, लेकिन जब json फाइल पढ़ते हैं, तो हम फिर से एन्कोडिंग समस्या का सामना करते हैं। इसलिए, समझाने का समय नहीं है , एक आईएनआई फ़ाइल बनाएं और एक नोटपैड के साथ विंडोज त्रुटियों को ड्राइव करें:

त्रुटि सूची फ़ाइल

errorlist.ini - त्रुटियों की सूची के साथ फाइल करें

     -  .. 

मैं बाइनरी सरणियों की सूची में डेटा पढ़ता हूं:

  QFile fileIni("./config/errorlist.ini"); fileIni.open(QFile::ReadOnly); QByteArray errorRaw = fileIni.readAll(); fileIni.close(); errorRaw = errorRaw.replace('\n', ""); QList<QByteArray> errorAllList = errorRaw.split('\r'); for(int i=0;i<errorAllList.count();i++) { if(errorAllList.at(i).count()>0) { errorList << errorAllList.at(i); } } 

फिर हम पहले से पढ़ी गई पंक्तियों की एक सूची शुरू करते हैं ताकि उन्हें फिर से नेटवर्क पर न भेजा जाए। हम रिफ्रेशपिरियोड अवधि के साथ टाइमर शुरू करते हैं और एक डेटा पुनः अनुरोध करते हैं । यदि कोई नया डेटा है - इसे UDP के माध्यम से नेटवर्क पर भेजें।

किसी नेटवर्क पर डेटा भेजना

QDataStream का उपयोग करके डेटा को क्रमबद्ध करने का निर्णय लिया गया था। मशीन का नाम, दिनांक, समय, संकेत भेजा जाता है - चाहे रेखा एक त्रुटि हो, और संदेश द्विआधारी रूप में ही।

निर्धारित करें कि क्या लाइन में कोई त्रुटि है

  QString errText="ok"; foreach(QByteArray err, errorList) { if(msg.contains(err)) { errText = "ERROR"; } } 

हम क्रमबद्ध करें, भेजें:

  QByteArray datagram; QDataStream out( &datagram, QIODevice::ReadWrite ); out.setVersion(QDataStream::Qt_4_0); out << cncName; out << query->value(0).toDate(); //date out << logTime;//time out << errText; out << msg;//bytearray udpSocket->writeDatagram(datagram, QHostAddress::Broadcast, 45000); 

सर्वर साइड

इसमें दो भाग होते हैं: UDP संदेश प्राप्त करना और उन्हें xmpp के माध्यम से भेजना।

UDP पैकेट प्राप्त करें

बंदरगाह के बारे में सुनकर:

  udpSocket = new QUdpSocket(this); connect(udpSocket, SIGNAL(readyRead()), this, SLOT(onReadyRead())); udpSocket->bind(45000); 

यदि प्राप्त रिकॉर्ड में "त्रुटि" का संकेत है, तो हम प्राप्त संदेश को पार्स करते हैं और एक संकेत का उत्सर्जन करते हैं।

 void CncReceiver::onReadyRead() { QByteArray buffer; ... buffer.resize(udpSocket->pendingDatagramSize()); udpSocket->readDatagram(buffer.data(), buffer.size()); QDataStream in( &buffer, QIODevice::ReadWrite ); in.setVersion(QDataStream::Qt_4_0); in >> cncName; in >> date; in >> time; in >> errText; in >> msg; ... if(errText!="ok") emit needSendToAll(msg, cncName, date, time); } 

यह संकेत एक वर्ग द्वारा प्राप्त किया जाएगा जो संदेश भेज सकता है। हमारे मामले में, जेबर में। सादृश्य से, आप मेल या एसएमएस द्वारा भेज सकते हैं।

जैबर को संदेश भेजें

संदेश भेजने के लिए, हम इस अद्भुत पुस्तकालय (qxmpp) से QXmppClient से प्राप्त एक वर्ग बनाते हैं।

हमारे द्वारा उपयोग की जाने वाली मेलिंग सूची को संग्रहीत करने के लिए

 QList<QString> sendList; 

इसे रोस्टर जैबर खाते के डेटा के साथ भरें (खाते के नाम हैं)।

और स्लॉट जो जरूरत को पकड़ता है SendToAll सिग्नल, SendList से सभी को एक संदेश भेजता है।

 void JabberClient::sendToAll(QByteArray msg, QString cncName, QDate errDate, QString errTime) { QString messageToUser; QTextCodec *codec = QTextCodec::codecForName("Windows-1251"); messageToUser = codec->toUnicode(msg); foreach(QString userName, sendList) { this->sendMessage(userName, "CNC_NAME: "+ cncName + "\n" + errDate.toString("yyyy-MM-dd ")+ errTime + "\nMesage:\n" + messageToUser); } } 

जब्बार चैट कार्यान्वयन

खाते द्वारा प्राप्त सभी संदेश प्रेषक के नाम के साथ पूरी संपर्क सूची में भेजे जाते हैं। इस प्रकार, एक सामान्य चैट प्राप्त की जाती है। यह चर्चाओं के लिए सुविधाजनक हो सकता है।

इसे बहुत सरलता से जोड़ा जाता है। ऐसा करने के लिए, JabberClient कंस्ट्रक्टर में हम एक और सिग्नल की प्रोसेसिंग जोड़ते हैं - एक संदेश जो सिग्नल प्राप्त करता है:

  connect(this, SIGNAL(messageReceived(QXmppMessage)), SLOT(onMessageReceived(QXmppMessage))); 

और हम इसे संदेश प्राप्त करने वाले स्लॉट में संसाधित करते हैं:

 void JabberClient::onMessageReceived(QXmppMessage msg) { if(msg.body().length()>0) { qDebug() << nowStr() << "onMessageReceived" << msg.from() << msg.body(); foreach(QString userName, sendList) { this->sendMessage(userName, msg.from() + ">\n" + msg.body()); } } } 

इस तथ्य के कारण संदेश की लंबाई की जाँच करना कि टाइपिंग प्रक्रिया के दौरान कॉल किया जा रहा है, लेकिन संदेश की लंबाई 0 है।

परिणाम

यह परियोजना एक उदाहरण है कि आप क्यूटी से डेटाबेस में दिए गए संदेश एन्कोडिंग के साथ कैसे जुड़ सकते हैं और सिस्टम लोकेल को स्थापित किए बिना जुड़ सकते हैं। यह यह भी दर्शाता है कि संदेश भेजने के लिए qxmpp लाइब्रेरी का उपयोग क्यूटी में कैसे करें।

उदाहरण के लिए स्रोत कोड:
code.google.com/p/cnc-error-monitor

पुनश्च। लेख को पूरक और अद्यतन किया जाएगा।
UPD: json से पैरामीटर्स की निश्चित पार्सिंग, जैबर के माध्यम से चैट कार्यान्वित
UPD2: एक अजीब टिप्पणी: यदि आप क्यूटी 4 वें संस्करण पर ग्राहक के हिस्से को इकट्ठा करते हैं, तो डेटाबेस से बाइटएयरे से डेटा को पढ़ा जाता है जैसा कि आधार एन्कोडिंग में होना चाहिए। और यदि आप क्यूटी 5 पर इकट्ठा करते हैं, तो वहां डेटा दूषित हो जाता है (और कोई पैरामीटर मदद नहीं करता है)।