我正在编写一个应用程序,它需要从两个来源接收事件。有些事件来自Websocket客户机连接,有些来自传入的HTTP请求。aiohttp是否可以在同一个应用程序中同时使用这两个侦听器,还是需要两个单独的可执行文件?在

我目前有一个函数,它接受websocket事件,并对每个事件调用回调async def callback(msg):

print(msg)

async def websocket():

session = aiohttp.ClientSession()

async with session.ws_connect('http://example.org/websocket') as ws:

async for msg in ws:

if msg.type == aiohttp.WSMsgType.TEXT:

await callback(msg.data)

elif msg.type == aiohttp.WSMsgType.CLOSED:

break

elif msg.type == aiohttp.WSMsgType.ERROR:

break

问题是它永远阻塞,所以我不知道如何将它与aiohttp服务器集成。如果我这样做:

^{pr2}$

则不会调用web.run_app。有什么方法可以做到这一点吗?这似乎是异步的理想情况,多个事物异步处理多个事件。我该怎么做?在

python websocket 客户端_aiohttp Websocket客户端和HTTP相关推荐

  1. java getbasicremote_Vue+Java 通过websocket实现服务器与客户端双向通信操作

    1. vue代码 methods: { //在方法里调用 this.websocketsend()发送数据给服务器 onConfirm () { //需要传输的数据 let data = { code ...

  2. WebSocket简单使用(二) - 客户端

    WebSocket简单使用(二) - 客户端 原文 http://www.oseye.net/user/kevin/blog/79 关于WebSocket我打算分如下几篇博文来探探路: WebSock ...

  3. java 网页通讯_Vue+Java 通过websocket实现服务器与客户端双向通信操作

    1. vue代码 methods: { //在方法里调用 this.websocketsend()发送数据给服务器 onConfirm () { //需要传输的数据 let data = { code ...

  4. 使用mongoose来创建嵌入式websocket客户端和http客户端

    使用mongoose来创建嵌入式websocket客户端和http客户端 使用mongoose原因 1 嵌入式非常合适 2 在简单需要的场合下,不需要其他文件,只需要两个文件包含 包含mongoose ...

  5. Websocket(二)-客户端与服务器通信

    Websocket(二)-客户端与服务器通信 服务端 客户端测试 const WebSocket = require('ws'); const Server = WebSocket.Server; c ...

  6. Java 编程问题:十三、HTTP 客户端和 WebSocket API

    原文:Java Coding Problems 协议:CC BY-NC-SA 4.0 贡献者:飞龙 本文来自[ApacheCN Java 译文集],自豪地采用谷歌翻译. 本章包括 20 个问题,旨在介 ...

  7. 【RuoYi-Vue-Plus】扩展笔记 02 - 集成 WebSocket 发送消息到客户端(源码)

    文章目录 前言 关于需求实现的对比(轮询与 `WebSocket` ) 关于本篇文章 参考目录 代码实现参考 原理分析参考 集成流程 1.Maven 2.WebSocket 配置类 `WebSocke ...

  8. 基于springboot的websocket服务端和客户端demo(简单易上手)

    jdk 1.8 1.导入maven依赖 <!-- websocket服务端依赖 --> <dependency><groupId>org.springframewo ...

  9. java服务端与Android客户端使用 websocket 通信

    最近因为项目需要所以得使用 websocket 来进行服务器与客户端的通信.使用java 来实现服务端,Android 实现客户端. 刚开始服务端使用 @ServerEndPoint 注解来实现 We ...

最新文章

  1. 梯度爆炸是什么?有什么后果?如何判断梯度爆炸?如何避免梯度爆炸?
  2. 人群分析--ResnetCrowd: A Residual Deep Learning Architecture
  3. 《应用程序性能测试的艺术(第2版)》—第2章 2.4节小结
  4. 多线程环境下,程序真是危机四伏
  5. Last non-zero Digit in N! HDU - 1066
  6. 【Java】时间的新旧比较
  7. 前端—每天5道面试题(1)
  8. 补第一阶段冲刺站立会议5(5月17日)
  9. Python简明教程之后应该学什么?
  10. 01【C3D 行为识别】项目下载 环境配置 数据集转化视频帧 UCF101数据集处理
  11. CleanMyMac X断网激活码免费共享教程免费分享
  12. Python字符串格式化
  13. Qq也进入鸿蒙系统,鸿蒙系统完善进行中,手机QQ接入HMS不需要后台运行秒收信息...
  14. micropython RX8025T 驱动简单演示
  15. Python智能机器人2(电脑应用的使用,聊天等功能)
  16. 鸿蒙系统卸载预装,神器:无需Root卸载预装APP
  17. 淘宝API应用调用官方买家信息数据
  18. 生活随笔:为何遇不到美女坐我旁边?
  19. swapidc不能连接到主机_swapidc 安装教程 安装/启动 插件教程
  20. 74160ENT引脚设计法+同步置数法接成60进制加法计数电路

热门文章

  1. CentOS 6.7快速搭建lamp环境
  2. 8. 进制转化的函数
  3. Android笔记(adb命令--reboot loader)
  4. 创业笔记-Node.js入门之阻塞与非阻塞
  5. Linux 环境变量配置
  6. php empty()和isset()的区别
  7. 【Smart_Point】unique_ptr中独占指针使用MakeFrame
  8. 使用who.is查域名DNS信息以及用sameip.org查其他网站
  9. 千万级并发HAproxy均衡负载系统介绍
  10. Tomcat定时任务