Wesocket example with aiohttp22.05.17

server:

!/usr/bin/env python
# -*- coding: utf-8 -*-

from aiohttp import web

async def handle(request):
    name = request.match_info.get('name', "Anonymous")
    text = "Hello, " + name
    return web.Response(text=text)

async def wshandler(request):
    ws = web.WebSocketResponse()
    await ws.prepare(request)
    async for msg in ws:
        if msg.type == web.MsgType.text:
            await ws.send_str("Hello, {}".format(msg.data))
        elif msg.type == web.MsgType.binary:
            await ws.send_bytes(msg.data)
        elif msg.type == web.MsgType.close:
            break
    return ws

app = web.Application()
app.router.add_get('/echo', wshandler)
app.router.add_get('/', handle)
app.router.add_get('/{name}', handle)

web.run_app(app)

client:
<!DOCTYPE HTML>
<html>
  <head>
    <script type="text/javascript">
    function WebSocketTest()
    {
      if ("WebSocket" in window)
      {
        alert("WebSocket is supported by your Browser!");
        var ws = new WebSocket("ws://localhost:8080/echo");
        ws.onopen = function()
        {
          ws.send("hello from foo");
          alert("Message is sent...");
        };
        ws.onmessage = function (evt)
        {
          var msg = evt.data;
          alert("msg received:" + msg);
        };
        ws.onclose = function()
        {
          alert("Connection is closed...");
        };
      }
      else
      {
        alert("WebSocket NOT supported by your Browser!");
      }
    }
    </script>
  </head>
 <body>
   <div id="sse">
     <a href="javascript:WebSocketTest()">Run WebSocket</a>
   </div>
   </body>
</html>

https://github.com/aio-libs/aiohttp

Anonymous

Wesocket example with aiohttp22.05.17

Information Epoch 1767355543