async await 通信用什么

在 JavaScript 中，可以使用 Promise 对象来实现 async/await 通信。当一个函数被标记为 async 时，它会返回一个 Promise 对象。在函数内部使用 await 关键字可以暂停函数的执行，等待 Promise 对象的完成，并返回 Promise 对象的结果。这样，我们就可以在异步操作完成后继续执行函数，并使用 Promise 对象的结果进行下一步操作。

相关问题

用 python 写异步进程间异步通信

在 Python 中，可以使用 asyncio 模块来实现异步进程间异步通信。下面是一个示例代码：

import asyncio

async def producer(queue):
    while True:
        await queue.put('data')  # 生产者不断向队列中放入数据
        await asyncio.sleep(1)   # 每隔1秒放入一次

async def consumer(queue):
    while True:
        data = await queue.get()  # 消费者从队列中获取数据
        print(data)               # 打印获取到的数据

async def main():
    queue = asyncio.Queue()      # 创建一个异步队列
    producer_task = asyncio.create_task(producer(queue))  # 创建生产者任务
    consumer_task = asyncio.create_task(consumer(queue))  # 创建消费者任务
    await asyncio.gather(producer_task, consumer_task)     # 等待两个任务完成

if __name__ == '__main__':
    asyncio.run(main())          # 运行主函数

在这个示例中，我们使用了 asyncio.Queue 来实现异步队列，生产者不断向队列中放入数据，消费者不断从队列中获取数据并打印。使用 asyncio.create_task() 函数创建任务，并使用 asyncio.gather() 函数等待两个任务完成。最后使用 asyncio.run() 函数运行主函数。

注意：在 Python 3.7 之前的版本中，可以使用 asyncio.ensure_future() 函数创建任务。

用非异步的方式实现python的webstocks通信

Websockets协议是一种异步通信协议，因此不能用非异步的方式实现。在Python中，常用的异步框架有asyncio、Tornado、aiohttp等，其中aiohttp内置了对Websockets协议的支持。下面是一个使用aiohttp实现Websockets通信的示例代码：

import asyncio
from aiohttp import web, WSMsgType

async def websocket_handler(request):
    ws = web.WebSocketResponse()
    await ws.prepare(request)

    async for msg in ws:
        if msg.type == WSMsgType.TEXT:
            if msg.data == 'close':
                await ws.close()
            else:
                await ws.send_str('You said: {}'.format(msg.data))
        elif msg.type == WSMsgType.ERROR:
            print('WebSocket connection closed with exception {}'.format(ws.exception()))

    print('WebSocket connection closed')
    return ws

app = web.Application()
app.add_routes([web.get('/ws', websocket_handler)])

if __name__ == '__main__':
    web.run_app(app)

在上述代码中，我们定义了一个`websocket_handler`函数作为Websockets的处理函数，它接收一个`request`对象，返回一个`WebSocketResponse`对象。在函数中，我们使用`await ws.prepare(request)`方法准备WebSocket连接，然后使用`async for msg in ws`循环读取WebSocket消息，根据消息类型进行处理和回复。最后，我们将该处理函数添加到Web应用的路由中，并使用`web.run_app(app)`启动Web应用。