每次都是网络插座或龙卷风下降

我是异步编程的新手。我已经使用 python 3.5 asyncio 几天了。我想使服务器能够从websocket机器客户端（GPS）接收数据，并将html页面呈现为websocket服务器的浏览器客户端。我在端口 8765 中使用 websocket 在机器客户端和服务器之间进行连接。为了渲染网页，我在端口 8888 使用了龙卷风（html 文件位于 ./views/index.html ）。该代码仅适用于 websocket 服务器。当我添加龙卷风服务器时，代码表现得很奇怪，我不知道为什么。asyncio 用法一定有问题。如果我放置

app = make_app()
app.listen(8888)
tornado.ioloop.IOLoop.current().start()

就在之前

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

，则 WebSocket 服务器无法连接。如果我反其道而行之，龙卷风服务器就不会运行。

请帮助我，因为我是异步编程的新手。下面给出了 server.py、索引.html和 client.py（机器客户端）。

server.py

#!/usr/bin/env python
import tornado.ioloop 
import tornado.web 
import asyncio
import websockets
class MainHandler(tornado.web.RequestHandler):
    def get(self):
        self.render("./views/index.html", title = "GPS")
def make_app():
    return tornado.web.Application([
        (r"/", MainHandler),
    ])
clients = []
async def hello(websocket, path):
    clients.append(websocket)
    while True:
        name = await websocket.recv()
        print("< {}".format(name))
        print(clients)
        greeting = "Hello {}!".format(name)
        for each in clients:

            await each.send(greeting)
            print("> {}".format(greeting))
start_server = websockets.serve(hello, 'localhost', 8765)
print("Listening on *8765")
app = make_app()
app.listen(8888)
print("APP is listening on *8888")
tornado.ioloop.IOLoop.current().start()
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

client.py

#!/usr/bin/env python

import serial
import time 
import asyncio
import websockets
ser =serial.Serial("/dev/tty.usbmodem1421", 9600, timeout=1)
async def hello():
    async with websockets.connect('ws://localhost:8765') as websocket:
        while True:
            data = await retrieve()
            await websocket.send(data)
            print("> {}".format(data))
            greeting = await websocket.recv()
            print("< {}".format(data))

async def retrieve():
        data = ser.readline()
        return data #return the location from your example
asyncio.get_event_loop().run_until_complete(hello())
asyncio.get_event_loop().run_forever()

./views/index.html

<html>
   <head>
      <title>{{ title }}</title>
   </head>
   <body>
      <script>
            var ws = new WebSocket("ws://localhost:8765/"),
            messages = document.createElement('ul');
            ws.onopen = function(){
              ws.send("Hello From Browser")
            }
            ws.onmessage = function (event) {
            var messages = document.getElementsByTagName('ul')[0],
                message = document.createElement('li'),
                content = document.createTextNode(event.data);
            message.appendChild(content);
            messages.appendChild(message);
        };
        document.body.appendChild(messages);
    </script>

一次只能运行一个事件循环（除非你为每个事件循环提供自己的线程，但这要复杂得多）。幸运的是，Tornado 和 asyncio 之间有一座桥梁，可以让它们共享同一个 IOLoop。

在程序的早期（在任何与龙卷风相关的代码（如 app = make_app() ）之前），执行以下操作：

import tornado.platform.asyncio
tornado.platform.asyncio.AsyncIOMainLoop().install()

并且不要打电话给IOLoop.current().start().这会重定向所有使用 Tornado 的组件以改用 asyncio 事件循环。

相关内容

最新更新

热门标签：