🧢 🤳🏾 👦🏽 DBMS Caché में सॉकेट्स के साथ काम करें। WebSocket प्रोटोकॉल के सर्वर साइड का एक उदाहरण कार्यान्वयन 🎌 🍧 🐑

Caché DBMS, सॉकेट्स के माध्यम से दूरस्थ प्रक्रियाओं के साथ TCP / IP पर संचार के लिए निम्न-स्तरीय कमांड प्रदान करता है, जो शुरुआती लोगों के लिए मुश्किल हो सकता है।

क्या लचीलेपन, गति और विकास में आसानी को खोए बिना "अलग तरीके से" सॉकेट का उपयोग करना संभव है?

बेशक वहाँ है: बस मौजूदा खुले , उपयोग , बंद , आदि आज्ञाओं के आसपास एक वस्तु आवरण लिखें। OOP के संदर्भ में, यह इनकैप्सुलेशन है ।

सौभाग्य से, ऐसी कक्षा, यहां तक कि कक्षाएं - एक सर्वर साइड के लिए और एक क्लाइंट के लिए - पहले से ही लिखी गई हैं और कम से कम कैच संस्करण 5.2 के साथ आती हैं, अर्थात्:

% IO.ServerSocket - सर्वर पक्ष पर काम करने के लिए;
% IO.Socket - क्लाइंट पक्ष पर काम के लिए;

उनके उपयोग से दो सरल उदाहरणों पर विचार करें।

उदाहरण संख्या १

सर्वर कोड

#dim sock As %IO.ServerSocket = ##class ( %IO.ServerSocket ). %New ()
set sock. TranslationTable = "UTF8"

write #, " ..." , !

#; : pPort, pTimeout, pSC
do sock. Open (7001, 1, .sc)

if $$$ISOK (sc) {

do sock. Listen ()

do {
#; : pMaxReadLen, pTimeout
set s=sock. ReadAny (250, 5)
write s,!

#; : pData, pFlush
do sock. Write ( $$$FormatText ( " %1" , $$$quote (s)), $$$YES )
} while (s'= "bye!" )

do sock. Close ()

write " ..." , !
}

ग्राहक कोड

#dim sock As %IO.ServerSocket = ##class ( %IO.Socket ). %New ()
set sock. TranslationTable = "UTF8"

write #, " ..." , !

#; : pHost, pPort, pTimeout, pSC
do sock. Open ( "127.0.0.1" , "7001" ,1,.sc)

if $$$ISOK (sc) {

#; : pData, pFlush
do sock. Write ( " " , $$$YES )

#; : pMaxReadLen, pTimeout
write sock. ReadAny (250, 5),!

hang 2

do sock. Write ( "bye!" , $$$YES )
write sock. ReadAny (250, 5),!

do sock. Close ()

write " ..." , !
}

सर्वर पर परिणाम:
```
  ...    bye!  ... 
```
ग्राहक पर परिणाम:
```
  ...    "  "    "bye!"  ... 
```

एक उदाहरण पर विस्तार से रहने का कोई मतलब नहीं है, क्योंकि सब कुछ काफी पारदर्शी है।
मैं केवल यह नोट करता हूं कि जब " बाय! " स्टॉप लाइन क्लाइंट भाग से प्राप्त होती है, तो सर्वर भाग अपना काम समाप्त कर देता है।

उदाहरण संख्या 2

कोड:

Class demo.socket Extends %RegisteredObject
{

ClassMethod Server2()
{
#; do ##class(demo.socket).Server2()

#dim sock As %IO.ServerSocket = ##class ( %IO.ServerSocket ). %New ()

write #, " ..." , !

do sock. Open (10081, 1, .sc)

if $$$ISOK (sc) {

do sock. Listen (-1, .sc)

do {
set s=sock. ReadAny ( $$$MaxLocalLength ,, .sc)
write s,!
do sock. Write (s, $$$YES , .sc)
} while (s'= "bye!" )

do sock. Close ()

write " ..." , !
}
}

ClassMethod Client2( end As %Boolean = { $$$NO })
{
#; do ##class(demo.socket).Client2(1)

#dim sock As %IO.ServerSocket = ##class ( %IO.Socket ). %New ()

write #, " ..." , !

do sock. Open ( "127.0.0.1" , "10081" ,1,.sc)

if $$$ISOK (sc) {

set time= $zhorolog

for i=1:1:10 {
do sock. Write ( "1234567890" , $$$YES , .sc)
set s=sock. ReadAny ( $$$MaxLocalLength ,, .sc)
write s,!
}

write "= " , $zhorolog -time, " ." ,!

do :end sock. Write ( "bye!" , $$$YES , .sc)

do sock. Close ()

write " ..." , !
} else {
write $system .Status . GetErrorText (sc, "ru" ),!
}
}

}

WebSocket प्रोटोकॉल का समर्थन करने के लिए सर्वर भाग का एक उदाहरण कार्यान्वयन

ऊपर दिए गए दो उदाहरण काफी सरल हैं, क्योंकि सर्वर के हिस्से को एक समय में केवल एक क्लाइंट कनेक्शन को संसाधित करने की अनुमति है।

क्या होगा अगर हमें एक ही समय में दसियों / सैकड़ों क्लाइंट कनेक्शन संभालने की आवश्यकता है?
ऐसा करने के लिए, IO.ServerSocket: ListenJob () पद्धति का उपयोग करें

आइए एक अधिक जटिल उदाहरण लिखें, उदाहरण के लिए, Caché DBMS में WebSocket प्रोटोकॉल समर्थन जोड़ें।

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

और याद रहे कि Caché DBMS, OOP और SQL को सपोर्ट करने के अलावा, NoSQL रिपॉजिटरी के रूप में भी कार्य कर सकता है ...

इंटरनेट पर खुद ही WebSocket प्रोटोकॉल के बारे में बहुत कुछ लिखा जा चुका है। इसके आधार पर, चैट रूम, ऑनलाइन गेम और सब कुछ जहां सर्वर (डेटाबेस) के साथ फास्ट डेटा एक्सचेंज की आवश्यकता होती है।
मैं ध्यान देता हूं कि हमारा डेमो प्रोटोकॉल के केवल दो संस्करणों का समर्थन करेगा: 76 और 7।

परीक्षणों के लिए, हमें उन आधुनिक ब्राउज़रों में से एक की आवश्यकता है जिनके पास WebSocket समर्थन है।
पुराने ब्राउज़रों के लिए, जैसे IE 8, आप एक विशेष प्लगइन का उपयोग कर सकते हैं जो फ्लैश के शीर्ष पर चलता है।

जो इच्छुक हैं वे लेख के अंत में स्रोतों में प्रोटोकॉल कार्यान्वयन के तकनीकी विवरण पा सकते हैं।

यहां हम केवल एक छोटे से उदाहरण पर विचार करेंगे जो सरलतम वेब चैट को लागू करता है।

नोट: Caché ObjectScript में WebSocket प्रोटोकॉल को लागू करने का स्रोत कोड केवल सूचना के उद्देश्यों के लिए है।

तो:

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

उदाहरण के लिए:

/// . Class demo.Server Extends net.WebSocketEvents { /// onbeforeconnect. /// <br> . Method onbeforeconnect() As %Boolean { set ^tmp( $i (^tmp), "onbeforeconnect" )= $lb (.. WebSocketGET ,.. WebSocketHost ,.. WebSocketOrigin ,.. WebSocketVer ) q $$$YES } /// onconnect. Method onconnect() { set ^tmp( $i (^tmp), "onconnect" )= "" } /// onmessage. /// <br> : /// <br><var>msg</var> - , . Method onmessage( msg As %String ) { set ^tmp( $i (^tmp), "onmessage" )=msg #; . /* do ..send("Cachéasd"_$random(1000)):msg="get", ..send($replace($j("",32000)," ","é")):msg="getBig", ..sendBroadcast("from Caché to All"):msg="toAll", ..sendBroadcast($$$FormatText(" : %1",$$$quote($p(msg,"^",2)))):$e(msg)="^" */ if msg= "get" { do .. send ( "Cachéasd" _ $random (1000)) } elseif msg= "getBig" { do .. send ( $replace ( $j ( "" ,32000), " " , "é" )) } elseif msg= "toAll" { do .. sendBroadcast ( "from Caché to All" ) } elseif $e (msg)= "^" { do .. sendBroadcast ( $$$FormatText ( " : %1" , $$$quote ( $p (msg, "^" ,2)))) } } /// onclose. Method onclose() { set ^tmp( $i (^tmp), "onclose" )= "" } }
यदि आप एक प्लगइन का उपयोग करते हैं जो फ्लैश का उपयोग करता है (ऊपर देखें), तो फ्लैश प्लेयर के नवीनतम संस्करण को पूर्व-इंस्टॉल करें, जिसे यहां से डाउनलोड किया जा सकता है ।
नोट: उन ब्राउज़र में WebSocket को सक्षम करने के लिए मत भूलना जिसमें वे डिफ़ॉल्ट रूप से अक्षम हैं, उदाहरण के लिए ओपेरा में।
सर्वर पर WebSocket कनेक्शन के प्रसंस्करण के लिए सर्वर शुरू करें:
```
 SAMPLES>do ##class(net.WebSocketServer).Start("demo.Server") 
```
ब्राउज़र में शुरू करें, उदाहरण के लिए फ़ायरफ़ॉक्स, पृष्ठ (वर्ग) डेमो.वेबक्लीअंट , जिसका स्रोत कोड इस प्रकार है:

Class demo.webclient Extends %ZEN.Component.page { /// If true, then attempt to refresh this page when its session timeout period has expired. /// This will cause a login page to display if the current session has ended /// and security is set to require login. Parameter AUTOLOGOUT As BOOLEAN = 0 ; /// Comma-separated list of additional JS include files for the page. Parameter JSINCLUDES As STRING = "websocket/swfobject.js,websocket/web_socket.js" ; XData Contents [ XMLNamespace = "www.intersystems.com/zen" ] { < page xmlns = "www.intersystems.com/zen" title = "" > < vgroup labelPosition = "left" > < label id = "lb" label = " :" /> < text id = "usr" label = ":" /> < button caption = "" onclick = "zenPage.start();" /> < button caption = " 1" label = "Hello123xcf789" onclick = "ws.send('Hello123xcf789');" /> < button caption = " 2" label = "toAll" onclick = "ws.send('toAll');" /> < button caption = " 3" label = "get" onclick = "ws.send('get');" /> < button caption = " 4" label = "getBig" onclick = "ws.send('getBig');" /> < button caption = "" onclick = "ws.close();" /> </ vgroup > </ page > } ClientMethod start() [ Language = javascript ] { ws = new WebSocket( "ws://127.0.0.1:10081/asd s HTTP/1.1///" ); ws.onopen = function () { zenSetProp( 'lb' , 'value' , 'open' ); ws.send( '^' + zenGetProp( 'usr' , 'value' )); }; ws.onmessage = function (e) { zenAlert( 'onmessage' , ' length=' ,e.data.length, ' data=' ,e.data); }; ws.onclose = function () { zenSetProp( 'lb' , 'value' , 'close' ); }; ws.onerror = function () { zenAlert( 'onerror' ); }; } /// This client event, if present, is fired when the page is loaded. ClientMethod onloadHandler() [ Language = javascript ] { // Let the library know where WebSocketMain.swf is: WEB_SOCKET_SWF_LOCATION = "websocket/WebSocketMain.swf" ; WEB_SOCKET_DEBUG = false; } }
सबसे पहले "प्रारंभ" बटन दबाएं। यदि Caché DBMS का ब्राउज़र कनेक्शन सफल होता है, तो आप स्टेटस "ओपन" देखेंगे।
यदि कोई कनेक्शन नहीं है, तो समस्या निवारण अनुभाग देखें। स्थानीय मशीन पर, सब कुछ समस्याओं के बिना काम करना चाहिए।
जब कनेक्शन सफलतापूर्वक स्थापित हो जाता है, तो आप विभिन्न परीक्षणों की कोशिश कर सकते हैं - उदाहरण में उनमें से चार हैं - किसी भी क्रम में।
परीक्षण के अंत में "स्टॉप" बटन पर क्लिक करना न भूलें।
कई ब्राउज़रों को चलाने का प्रयास करें और 6-8 चरणों को दोहराएं।

आइए सर्वर पर लॉग की सामग्री देखें:

फ़ायरफ़ॉक्स 12

 USER>zw ^tmp ^tmp=8 ^tmp(1,"onbeforeconnect")=$lb("/asd%20s%20HTTP/1.1///","127.0.0.1:10081","","hybi-10") ^tmp(2,"onconnect")="" ^tmp(3,"onmessage")="^sdsdf" ^tmp(4,"onmessage")="Hello123xcf789" ^tmp(5,"onmessage")="toAll" ^tmp(6,"onmessage")="get" ^tmp(7,"onmessage")="getBig" ^tmp(8,"onclose")=""

IE 9

 USER>zw ^tmp ^tmp=8 ^tmp(1,"onbeforeconnect")=$lb("/asd s HTTP/1.1///","127.0.0.1:10081","","hybi-10") ^tmp(2,"onconnect")="" ^tmp(3,"onmessage")="^dfg" ^tmp(4,"onmessage")="Hello123xcf789" ^tmp(5,"onmessage")="toAll" ^tmp(6,"onmessage")="get" ^tmp(7,"onmessage")="getBig" ^tmp(8,"onclose")=""

Ws के बजाय सुरक्षित wss प्रोटोकॉल का उपयोग करना

इसके लिए आपको आवश्यकता होगी:

एक नाम के साथ पोर्टल में SSL सर्वर कॉन्फ़िगरेशन को कॉन्फ़िगर करें, उदाहरण के लिए, WebSocketSSL और " Peer प्रमाणपत्र सत्यापन स्तर " को " कोई नहीं " सेट करें।
नोट: Caché DBMS में SSL कॉन्फ़िगर करने का विवरण इस ब्लॉग के पिछले लेखों में से एक में पाया जा सकता है।
WebSocket डेमॉन को शुरू करते समय, हमें अपने SSL कॉन्फ़िगरेशन को निर्दिष्ट करने की आवश्यकता है:
```
 SAMPLES>do ##class(net.WebSocketServer).Start("demo.Server",,"WebSocketSSL") 
```
यदि आप एक प्लगइन का उपयोग कर रहे हैं जो फ्लैश का उपयोग करता है (ऊपर देखें), तो पहले पोर्ट 843 पर पॉलिसी फ़ाइल डेमन चलाएं:
```
 SAMPLES>do ##class(net.WebSocketServer).StartPolicy() 
```
पहले लाइन को बदलकर Demo.webclient क्लास को फिर से खोलें
```
  "ws: //127.0.0.1: 10081 ..." 
```
पर
```
  "wss: //127.0.0.1: 10081 ..." 
```
आगे देखें

नतीजतन, हमारे पास एक वेब एप्लिकेशन, एक सर्वर भाग और एक डेटाबेस है जो विशेष रूप से कैच डीबीएमएस के भीतर लागू किया गया है।

स्रोत परियोजना