基于python的MQTT和环信即时通信的MQTT通信
代码如下:
# -*- coding: utf-8 -*-
# 以下代码在2021年10月21日 python3.10环境下运行通过
import paho.mqtt.client as mqtt
import time
HOST = "xxxxx.xxx.mqtt.chat"
PORT = 1883
client_id = "xxxxxxxx@xxxx"
#连接并订阅回调函数,在连接时会调用
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
client.subscribe("Myled") # 订阅消息
#消息接收回调函数,在其他MQTT客户端和本客户端发起订阅消息后会触发
def on_message(client, userdata, msg):
print("主题:"+msg.topic+" 消息:"+str(msg.payload.decode('utf-8')))
#订阅成功回调函数,在发起订阅后会触发
def on_subscribe(client, userdata, mid, granted_qos):
print("On Subscribed: qos = %d" % granted_qos)
# 失去连接回调函数,断开连接时会触发
def on_disconnect(client, userdata, rc):
if rc != 0:
print("Unexpected disconnection %s" % rc)
client = mqtt.Client(client_id)
client.username_pw_set("hxm", "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxhIEhgpnAR7JMp_cVgpy5yAwMAAAF_m9h2BDeeSAABkc6dqIpUjy3N6jOixZTcXRaw6GxjU678xFwcKpEwrQ")
client.on_connect = on_connect
client.on_message = on_message
client.on_subscribe = on_subscribe
client.on_disconnect = on_disconnect
client.connect(HOST, PORT, 60)
#client.loop_forever()
run = True
client.loop_start()
while run:
time.sleep(2)
client.subscribe("Myled0")#订阅,会在回调函数里接收的
#client.publish("Myled0",100)#发布
说明:1、xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxhIEhgpnAR7JMp_cVgpy5yAwMAAAF_m9h2BDeeSAABkc6dqIpUjy3N6jOixZTcXRaw6GxjU678xFwcKpEwrQ是环信的
查看token获取的,相当于密码
2、查询信息用订阅,然后其回调函数来接收;上传信息用发布
3、client_id = "xxxxxxxx@xxxx"z中前面是自己取的值,@后面的是环信的AppID的值
基于python的MQTT和环信即时通信的MQTT通信相关推荐
- 环信即时通讯IM重大更新助力企业数字化转型
即时通讯IM是人与人沟通的基础服务,随着线上场景的进一步丰富,用户对于IM的能力要求日益提升.IM本质是一项服务,用户对于体验质量的要求异常严苛,掌握终端用户质量体验的变化和趋势,能够快速发现问题及根 ...
- 聊天服务器 单机性能,环信即时聊天服务器
环信即时聊天服务器 内容精选 换一换 本章节通过示例项目"小蝌蚪即时交互游戏"介绍如何使用DevCloud开发基于PHP语言的H5应用.项目名称:小蝌蚪即时交互游戏.项目简介:小蝌 ...
- android 环信集成,Android Studio下的环信即时通讯简单集成
环信即时通讯云是全球最大的即时通讯云 PaaS 平台,可以快速实现APP的即时通讯的功能,官方的DEMO是基于Eclipse开发的,对于新版本的Android Studio支持不太好,下面就简单说一下 ...
- 环信即时通讯单聊集成,添加好友,实现单聊
前段时间由于项目需要,了解一下环信即时通讯,然后自己通过查资料写了一个基于环信的单聊demo,一下是源码,希望可以帮助到需要的小伙伴. 首先,我们要去环信官网注册账号,这个我就不多说了,注册完登录,创 ...
- 【APICloud系列|25】 easeChat模块(环信-即时通讯)的实现
导读:easeChat 模块封装了环信即时通讯云的开放SDK,封装的接口都是纯功能类接口, 主要分三大类: 1,注册.登录.退出.监听 2,创建群组.添加/删除好友.获取好友列表 3,消息.会话.聊天 ...
- 环信 即时通讯sdk实现客服功能
仅适用于已经集成环信 即时通讯sdk,又需求实现客服功能,而不更换sdk. 下面的api环信 即时通讯并没有在文档中暴露,是我咨询了环信客服后知道的 核心就是 给 Message对象 setAttr ...
- 环信即时通讯云获得A轮融资 开启 “高品质更好用”IM时代
国内首家专注即时通讯云服务的公司--环信即时通讯云今日在发布会上正式宣布完成来自SIG海纳亚洲的500万美元A轮融资. 在此轮融资成功后,环信会在应开发者要求开发更多新功能的同时,着重于保持稳定的系统 ...
- 环信即时通讯云iOS版V2.0.9.1服务评测
集成测试 评测环境 2G/3G/WiFi网络下: 测评环境 MAC OS(10.9.2)+ XCode(5.1) + iPhone 测试对象 环信即时通讯云 IOS SDK Version 2.0.9 ...
- 安卓开发环信即时通信,聊天软件-可实现单聊群聊
最近花了一个星期的时间在B站跟着老师学了环信即时聊天工具的使用 附上学习网站:https://www.bilibili.com/video/BV1cW411V7yd?p=1 附上自己的代码 https ...
最新文章
- 数据库事务的隔离级别 (转)
- iOS:极光推送控制器跳转
- dubbo配置(一)
- 递归算法——汉诺塔问题
- go/git设置及取消代理方法
- shrio的rememberMe不起作用
- mysql libs 5.1.71_用python创建数据库监控平台(1)安装MySQL5.7
- Java大新闻不断涌现:Java SE 6和OpenJDK
- restTemplate使用和踩坑总结
- 8086汇编求一组正整数{0x1223,0x1234,0x1434,0x2345,0x3412,0x1712}中的最大数并存在变量MAX中
- 更新 PORTS-Tree 且升级已安装的软件[zt]
- java 内存文件_Java内存映射文件(Memory Mapped Files)
- 企业综合安防管理平台
- 《世界咖啡》一书小结
- 小甲鱼python入门_python基础笔记(非系统/自用/参考小甲鱼的零基础入门学习python)上...
- 4、网络层:三层物理设备:集线器、交换机、路由器【IP、ICMP、BGP、OSPF
- hibernate5.4+mysql8+java8实例
- 深度玄学-实战开发步骤
- 兰大计算机网络复试答案
- 开源全渠道业务中台OMS订单管理系统