Python Language
WebSockets
खोज…
Aiohttp के साथ सरल इको
aiohttp
एसिंक्रोनस aiohttp
प्रदान करता है।
import asyncio
from aiohttp import ClientSession
with ClientSession() as session:
async def hello_world():
websocket = await session.ws_connect("wss://echo.websocket.org")
websocket.send_str("Hello, world!")
print("Received:", (await websocket.receive()).data)
await websocket.close()
loop = asyncio.get_event_loop()
loop.run_until_complete(hello_world())
Aiohttp के साथ रैपर क्लास
aiohttp.ClientSession
एक कस्टम WebSocket वर्ग के लिए माता-पिता के रूप में उपयोग किया जा सकता है।
import asyncio
from aiohttp import ClientSession
class EchoWebSocket(ClientSession):
URL = "wss://echo.websocket.org"
def __init__(self):
super().__init__()
self.websocket = None
async def connect(self):
"""Connect to the WebSocket."""
self.websocket = await self.ws_connect(self.URL)
async def send(self, message):
"""Send a message to the WebSocket."""
assert self.websocket is not None, "You must connect first!"
self.websocket.send_str(message)
print("Sent:", message)
async def receive(self):
"""Receive one message from the WebSocket."""
assert self.websocket is not None, "You must connect first!"
return (await self.websocket.receive()).data
async def read(self):
"""Read messages from the WebSocket."""
assert self.websocket is not None, "You must connect first!"
while self.websocket.receive():
message = await self.receive()
print("Received:", message)
if message == "Echo 9!":
break
async def send(websocket):
for n in range(10):
await websocket.send("Echo {}!".format(n))
await asyncio.sleep(1)
loop = asyncio.get_event_loop()
with EchoWebSocket() as websocket:
loop.run_until_complete(websocket.connect())
tasks = (
send(websocket),
websocket.read()
)
loop.run_until_complete(asyncio.wait(tasks))
loop.close()
एक वेबसोकेट फैक्टरी के रूप में ऑटोबान का उपयोग करना
ऑटोबान पैकेज का उपयोग पायथन वेब सॉकेट सर्वर कारखानों के लिए किया जा सकता है।
स्थापित करने के लिए, आम तौर पर एक टर्मिनल कमांड का उपयोग करेगा
(लिनक्स के लिए):
sudo pip install autobahn
(विंडोज के लिए):
python -m pip install autobahn
फिर, पायथन स्क्रिप्ट में एक साधारण इको सर्वर बनाया जा सकता है:
from autobahn.asyncio.websocket import WebSocketServerProtocol
class MyServerProtocol(WebSocketServerProtocol):
'''When creating server protocol, the
user defined class inheriting the
WebSocketServerProtocol needs to override
the onMessage, onConnect, et-c events for
user specified functionality, these events
define your server's protocol, in essence'''
def onMessage(self,payload,isBinary):
'''The onMessage routine is called
when the server receives a message.
It has the required arguments payload
and the bool isBinary. The payload is the
actual contents of the "message" and isBinary
is simply a flag to let the user know that
the payload contains binary data. I typically
elsewise assume that the payload is a string.
In this example, the payload is returned to sender verbatim.'''
self.sendMessage(payload,isBinary)
if__name__=='__main__':
try:
importasyncio
except ImportError:
'''Trollius = 0.3 was renamed'''
import trollius as asyncio
from autobahn.asyncio.websocketimportWebSocketServerFactory
factory=WebSocketServerFactory()
'''Initialize the websocket factory, and set the protocol to the
above defined protocol(the class that inherits from
autobahn.asyncio.websocket.WebSocketServerProtocol)'''
factory.protocol=MyServerProtocol
'''This above line can be thought of as "binding" the methods
onConnect, onMessage, et-c that were described in the MyServerProtocol class
to the server, setting the servers functionality, ie, protocol'''
loop=asyncio.get_event_loop()
coro=loop.create_server(factory,'127.0.0.1',9000)
server=loop.run_until_complete(coro)
'''Run the server in an infinite loop'''
try:
loop.run_forever()
except KeyboardInterrupt:
pass
finally:
server.close()
loop.close()
इस उदाहरण में, पोर्ट 9000 पर लोकलहोस्ट (127.0.0.1) पर एक सर्वर बनाया जा रहा है। यह सुनने वाला आईपी और पोर्ट है। यह महत्वपूर्ण जानकारी है, इसका उपयोग करते हुए, आप अपने कंप्यूटर के LAN पते और पोर्ट को अपने मॉडेम से आगे पहचान सकते हैं, हालांकि आपके पास कंप्यूटर के लिए जो भी राउटर हैं। फिर, अपने WAN IP की जांच करने के लिए Google का उपयोग करके, आप पोर्ट 9000 (इस उदाहरण में) पर अपने WAN IP को WebSocket संदेश भेजने के लिए अपनी वेबसाइट डिज़ाइन कर सकते हैं।
यह महत्वपूर्ण है कि आप अपने मॉडेम से आगे पोर्ट करें, जिसका अर्थ है कि अगर आपके पास मॉडेम से चलने वाली डेज़ी जंजीर है, तो मॉडेम की कॉन्फ़िगरेशन सेटिंग्स में प्रवेश करें, मॉडेम से कनेक्टेड राउटर के लिए आगे पोर्ट, और अंतिम राउटर तक आगे कंप्यूटर। जुड़ा हुआ है जो मॉडेम पोर्ट 9000 (इस उदाहरण में) को प्राप्त की जा रही जानकारी को अग्रेषित करता है।