PHP + ActiveMQ में ICQ बग-मुखबिर

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

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


इस प्रणाली की योजना इस प्रकार है: एप्लिकेशन (वेब ​​या डेस्कटॉप), जब कोई त्रुटि होती है, तो एक निश्चित XML संदेश उत्पन्न होता है, जिसमें त्रुटि का संक्षिप्त विवरण और प्राप्तकर्ता का ICQ नंबर होता है। यह संदेश STOMP प्रोटोकॉल के माध्यम से ActiveMQ ब्रोकर को भेजा जाता है और कतार में प्रवेश करता है। दुनिया के दूसरे छोर पर या उसी मशीन पर, एक ICQ बॉट है जो इस कतार को सुनता है और, जब कोई संदेश इसमें आता है, तो तुरंत इसे निर्दिष्ट पते पर भेज देता है। और अब विवरण में।

ActiveMQ स्थापित और कॉन्फ़िगर करें

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

आरंभ करने के लिए, वितरण डाउनलोड करें। कुछ दूर फ़ोल्डर में संग्रह को अनपैक करने के लिए इंस्टॉलेशन कम हो गया है। सुविधा के लिए, हम इसे Windows सेवा के रूप में स्थापित करेंगे, इसके लिए आपको ActiveMQ स्क्रिप्ट \ bin \ win32 \ InstallService.bat को चलाने की आवश्यकता है, स्थापित JAVA मशीन की उपस्थिति स्वयं द्वारा मान ली गई है।
आप "प्रशासन" -> "सेवाओं" के माध्यम से प्रदर्शन की जांच कर सकते हैं, लेकिन सूची को शुरू करने के 10 सेकंड बाद प्रतीक्षा करें और सूची 2003 को अपडेट करें, Win 2003 सर्वर पर मुझे एक समस्या थी: सेवा शुरू करने के लिए लग रहा था, लेकिन तुरंत दुर्घटनाग्रस्त हो गया, लॉग और Google में एक लंबी खुदाई का नेतृत्व किया ActiveMQ \ bin \ win32 निर्देशिका में एक कार्य फ़ोल्डर बनाने के लिए एक सरल समाधान है।

ActiveMQ को कॉन्फ़िगर करने के लिए, आपको फ़ाइल \ conf \ activemq.xml खोलनी होगी
हम अपने ब्रोकर का वर्णन करते हैं:
<broker xmlns = "activemq.apache.org/schema/core" brokerName = "localhost" dataDirectory = "${activemq.base}/data" destroyApplicationContextOnStop = "true" persistent = "true" useShutdownHook = "false" >

<broker xmlns = "activemq.apache.org/schema/core" brokerName = "localhost" dataDirectory = "${activemq.base}/data" destroyApplicationContextOnStop = "true" persistent = "true" useShutdownHook = "false" >

लगातार पैरामीटर पर ध्यान दें, यह इस तथ्य के लिए जिम्मेदार है कि आपके सभी संदेश डेटाबेस में संग्रहीत किए जाएंगे और सेवा पुनरारंभ होने के बाद खो नहीं जाएंगे। आपको इसकी आवश्यकता है या नहीं, अपने लिए तय करें, मैंने इस फ़ंक्शन को कनेक्ट किया, और इसे अंतर्निहित kahaDB से अधिक समझने योग्य और पारदर्शी MySQL में पुन: कॉन्फ़िगर किया। यह निम्नानुसार किया जाता है:
जावा के लिए कनेक्टर डाउनलोड करें, इसमें से mysql-कनेक्टर-जावा-5.1.14-bin.jar लें और इसे \ lib फ़ोल्डर में छोड़ दें। MySQL में ही, हम activemq नामक एक डेटाबेस बनाते हैं, इसके लिए हम एक ही पासवर्ड के साथ एक activemq उपयोगकर्ता बनाएंगे। हम इस सब का वर्णन विन्यास में करेंगे:

<persistenceAdapter > <br/>
<jdbcPersistenceAdapter dataSource = "#mysql-ds" /> <br/>
</persistenceAdapter > <br/>
<br/>
<bean id = "mysql-ds" class = "org.apache.commons.dbcp.BasicDataSource" destroy-method = "close" > <br/>
<property name = "driverClassName" value = "com.mysql.jdbc.Driver" /> <br/>
<property name = "url" value = "jdbc:mysql://localhost/activemq?relaxAutoCommit=true" /> <br/>
<property name = "username" value = "activemq" /> <br/>
<property name = "password" value = "activemq" /> <br/>
<property name = "poolPreparedStatements" value = "true" /> <br/>
</bean >

ब्लॉक को टैग के बाहर स्थित होना चाहिए। सेवा को पुनरारंभ करने के बाद, डेटाबेस में 3 तालिकाओं का निर्माण किया जाना चाहिए, अगर ऐसा हुआ, तो सब कुछ सही ढंग से किया गया था।

हम कॉन्फ़िगरेशन के माध्यम से आगे बढ़ते हैं, संभव कनेक्शन कॉन्फ़िगर करते हैं:

<transportConnectors > <br/>
<transportConnector name = "openwire" uri = "tcp://0.0.0.0:61616" /> <br/>
<transportConnector name = "openwire2" uri = "stomp://0.0.0.0:61613" /> <br/>
</transportConnectors >

यहां मैंने अलग-अलग प्रोटोकॉल का उपयोग करके 2 अलग-अलग कनेक्शन सेट किए हैं, यह इस तथ्य के कारण है कि PHP में मैं कनेक्ट करने के लिए STOMP लाइब्रेरी का उपयोग करता हूं, और डेल्फी के तहत मैं एक घटक खोजने में कामयाब रहा जो टीसीपी पर काफी काम करता है।

अगला, हम प्राधिकरण करेंगे, निम्नलिखित टुकड़े को ब्लॉक में जोड़ें:

<plugins > <br/>
<jaasAuthenticationPlugin configuration = "activemq-domain" /> <br/>
<authorizationPlugin > <br/>
<map > <br/>
<authorizationMap > <br/>
<authorizationEntries > <br/>
<authorizationEntry queue = ">" read = "admins" write = "admins" admin = "admins" /> <br/>
<authorizationEntry queue = "icq.>" read = "users" write = "users" admin = "admins" /> <br/>
<authorizationEntry topic = "ActiveMQ.Advisory.>" read = "guests,users" write = "guests,users" admin = "guests,users" /> <br/>
</authorizationEntries > <br/>
</authorizationMap > <br/>
</map > <br/>
</authorizationPlugin > <br/>
</plugins >

अब निम्नलिखित सामग्री के साथ / conf फ़ोल्डर में group.properties फ़ाइल बनाएँ:

admins=system,sslclient,client,broker1,broker2
users=icq
guests=guest


उसी स्थान पर, users.properties फ़ाइल बनाएँ और उसमें लिखें:

system=password
icq=secret

आपको login.config फ़ाइल की भी आवश्यकता है, पूरी फ़ाइल को डाउनलोड करना और उसे / conf फ़ोल्डर में ड्रॉप करना आसान है। सभी सेटिंग्स के बाद, हम सेवा को फिर से शुरू करते हैं और पते पर जाते हैं http: // localhost: 8161 / admin / , अगर सब कुछ सही ढंग से किया गया था, तो आपको नियंत्रण कक्ष द्वारा बधाई दी जाएगी, यदि ऐसा है, तो क्युस पर जाएं और नाम इक्क के साथ एक कतार बनाएं।

ICQ बॉट लिपि

मैंने WebIcqPro लाइब्रेरी को बॉट के आधार के रूप में लिया, यह बहुत सरल और स्थिर है। आपको ब्रोकर को संदेश भेजने के लिए एक पुस्तकालय की भी आवश्यकता होगी, मैंने STOMP प्रोटोकॉल पर एक बहुत ही स्थिर समाधान पाया, लेकिन जब कनेक्शन टूट गया था तो इसे खटखटाया गया था, इसलिए इसे फिर से जोड़ना संभव बनाने के लिए मुझे इसे थोड़ा संशोधित करना पड़ा। मैं यहां सभी बॉट कोड नहीं लाऊंगा; जो कोई भी वास्तव में इच्छुक है वह संग्रह डाउनलोड कर सकता है ।

स्वास्थ्य का परीक्षण करने के लिए, कमांड लाइन के माध्यम से बॉट चलाएं:
"C: \ Program Files \ PHP \ php" C: \ icqbot \ icq.php
यदि सेटिंग्स के साथ सब कुछ ठीक है, तो उसे ActiveMQ और ICQ सर्वर के साथ एक कनेक्शन स्थापित करना चाहिए, और फिर "संदेशों की प्रतीक्षा कर रहा है ..." चैनल सुनना शुरू करना चाहिए। परीक्षण संदेश भेजने के लिए, आप संग्रह से send.php स्क्रिप्ट का उपयोग कर सकते हैं:

<?php <br/>
require_once 'Stomp.php' ; <br/>
$c = new StompConnection ( "localhost" ) ; <br/>
$result = $c -> connect ( "icq" , "bot" ) ; <br/>
<br/>
$mess = '<?xml version="1.0" encoding="windows-1251"?><br/>
<reference><br/>
<type>send</type><br/>
<to>111111111</to><br/>
<from>Test send:</from><br/>
<mes> message</mes><br/>
</reference>' ; <br/>
<br/>
$mess = iconv ( 'cp1251' , 'UTF-8' , $mess ) ; <br/>
$c -> send ( "/queue/icq" , $mess , array ( 'persistent' => 'true' ) ) ; <br/>
$c -> disconnect ( ) ; <br/>
?>

लंबे समय तक मुझे एनकोडिंग के साथ छेड़छाड़ करनी पड़ी ताकि मैं रूसी पाठ के साथ संदेश भेज सकूं, इसलिए जब आप स्क्रिप्ट में विभिन्न एन्कोडिंग के लिए कैस्केडिंग रूपांतरण देखते हैं तो आश्चर्यचकित न हों, अन्यथा यह काम नहीं करना चाहता था। Send.php पर कॉल करने के बाद, एक संदेश निर्दिष्ट UIN को भेजा जाएगा और यह तथ्य लॉग में भी दिखाई देगा।

बॉट को विंडोज सेवा के रूप में चलाएं

इसके लिए हमें विंडोज एनटी रिसोर्स किट के एक सेट की जरूरत है, जो डाउनलोड न हो। मान लें कि हमारे पास मौजूद सभी बॉट फाइलें C: \ icqbot फ़ोल्डर में हैं । कंसोल खोलें और लिखें
"C: \ Program Files \ Windows संसाधन किट \ Instsrv.exe" ICQBot "C: \ Program Files \ Windows संसाधन किट \ Srvany.exe"
अगला, regedit चलाएं और उसके अंदर HKEY_LOCAL_MACHINE \ SYSTEM \ CurrentControlSet \ Services \ ICQBot सेक्शन पर जाएं , पैरामीटर सेक्शन बनाएं और इसमें एप्लिकेशन मान "C: \ Program Files \ php.exe" C: \ icqbot \ icq के साथ REG_SST कोड टाइप करें। php
अगला, सेवाओं पर जाएं और वहां से हमारे बॉट को लॉन्च करें, अब यह पूरी तरह से स्वायत्त है।

साइट के लिए त्रुटि पकड़ने वाला

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

<?php <br/>
ini_set ( 'display_errors' , 0 ) ; <br/>
error_reporting ( 2 ) ; <br/>
<br/>
if ( $send_report ) { <br/>
include_once ( "Stomp.php" ) ; <br/>
<br/>
function send_report ( $message , $to = '1212312' , $from = 'SENDER' ) { <br/>
global $send_report , $stomp_server , $stomp_url , $stomp_user , $stomp_psw ; <br/>
if ( ! $send_report ) return false ; <br/>
$c = new StompConnection ( $stomp_server ) ; <br/>
$result = $c -> connect ( $stomp_user , $stomp_psw ) ; <br/>
if ( ! is_array ( $to ) ) $to = array ( $to ) ; <br/>
foreach ( $to as $i ) { <br/>
$mess = '<?xml version="1.0" encoding="windows-1251"?><br/>
<reference><br/>
<type>send</type><br/>
<to>' . $i . '</to><br/>
<from>' . $from . '</from><br/>
<mes>' . $message . '</mes><br/>
</reference>' ; <br/>
$c -> send ( $stomp_url , iconv ( 'cp1251' , 'UTF-8' , $mess ) , array ( 'persistent' => 'true' ) ) ; <br/>
} <br/>
$c -> disconnect ( ) ; <br/>
} <br/>
} <br/>
<br/>
function user_log ( $errno , $errmsg , $file , $line ) { <br/>
global $send_report ; <br/>
if ( $errno == 2 ) { <br/>
$filename = strftime ( '%d.%m.%Y %H-%M-%S_' ) . $_REQUEST [ 'PHPSESSID' ] . '.err' ; <br/>
$fl = fopen ( 'errors/' . $filename , 'w' ) ; <br/>
$_SESSION [ 'ERROR_TEXT' ] = 'WARNING: ' . $errmsg . ' in ' . $file . ' on line ' . $line ; <br/>
$_SESSION [ 'ERROR_TIME' ] = strftime ( '%d.%m.%Y %H-%M-%S' ) ; <br/>
$_SESSION [ 'ERROR_PHPSESSID' ] = $_REQUEST [ 'PHPSESSID' ] ; <br/>
$_SESSION [ 'ERROR_TYPE' ] = 'PHP SCRIPT ERROR' ; <br/>
fwrite ( $fl , serialize ( $_SESSION ) ) ; <br/>
fclose ( $fl ) ; <br/>
if ( $send_report ) send_report ( $_SESSION [ 'ERROR_TEXT' ] ) ; <br/>
} <br/>
} <br/>
<br/>
set_error_handler ( 'user_log' ) ; <br/>
?>

स्पष्ट कारणों के लिए, मैं इन रिपोर्टों की संपूर्ण सामग्री को क्रिप्ट कर देता हूं, जो मैं सभी को करने की सलाह देता हूं।

इस प्रकार, एक स्थिर, सरल और सार्वभौमिक अधिसूचना योजना प्राप्त की गई थी, जो किसी भी भाषा में किसी भी आवेदन से आईसीक्यू को संदेश भेजने की अनुमति देता है, अगर ActiveMQ के साथ बातचीत करने के लिए प्रोटोकॉल में से एक इसके लिए वर्णित है।

प्रयुक्त फ़ाइलों की सूची

1. ActiveMQ 5.4.2
2. ActiveMQ के लिए पुष्टि करता है
3. MySQL कनेक्टर
4. PHP के लिए WebICQPro लाइब्रेरी
5. PHP के लिए STOMP लाइब्रेरी
6. बॉट स्क्रिप्ट और एरर इंटरसेप्टर का तैयार-तैयार सेट
7. Windows NT संसाधन किट