代码如下:

# -*- 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通信相关推荐

  1. 环信即时通讯IM重大更新助力企业数字化转型

    即时通讯IM是人与人沟通的基础服务,随着线上场景的进一步丰富,用户对于IM的能力要求日益提升.IM本质是一项服务,用户对于体验质量的要求异常严苛,掌握终端用户质量体验的变化和趋势,能够快速发现问题及根 ...

  2. 聊天服务器 单机性能,环信即时聊天服务器

    环信即时聊天服务器 内容精选 换一换 本章节通过示例项目"小蝌蚪即时交互游戏"介绍如何使用DevCloud开发基于PHP语言的H5应用.项目名称:小蝌蚪即时交互游戏.项目简介:小蝌 ...

  3. android 环信集成,Android Studio下的环信即时通讯简单集成

    环信即时通讯云是全球最大的即时通讯云 PaaS 平台,可以快速实现APP的即时通讯的功能,官方的DEMO是基于Eclipse开发的,对于新版本的Android Studio支持不太好,下面就简单说一下 ...

  4. 环信即时通讯单聊集成,添加好友,实现单聊

    前段时间由于项目需要,了解一下环信即时通讯,然后自己通过查资料写了一个基于环信的单聊demo,一下是源码,希望可以帮助到需要的小伙伴. 首先,我们要去环信官网注册账号,这个我就不多说了,注册完登录,创 ...

  5. 【APICloud系列|25】 easeChat模块(环信-即时通讯)的实现

    导读:easeChat 模块封装了环信即时通讯云的开放SDK,封装的接口都是纯功能类接口, 主要分三大类: 1,注册.登录.退出.监听 2,创建群组.添加/删除好友.获取好友列表 3,消息.会话.聊天 ...

  6. 环信 即时通讯sdk实现客服功能

    仅适用于已经集成环信 即时通讯sdk,又需求实现客服功能,而不更换sdk. 下面的api环信 即时通讯并没有在文档中暴露,是我咨询了环信客服后知道的 核心就是 给 Message对象  setAttr ...

  7. 环信即时通讯云获得A轮融资 开启 “高品质更好用”IM时代

    国内首家专注即时通讯云服务的公司--环信即时通讯云今日在发布会上正式宣布完成来自SIG海纳亚洲的500万美元A轮融资. 在此轮融资成功后,环信会在应开发者要求开发更多新功能的同时,着重于保持稳定的系统 ...

  8. 环信即时通讯云iOS版V2.0.9.1服务评测

    集成测试 评测环境 2G/3G/WiFi网络下: 测评环境 MAC OS(10.9.2)+ XCode(5.1) + iPhone 测试对象 环信即时通讯云 IOS SDK Version 2.0.9 ...

  9. 安卓开发环信即时通信,聊天软件-可实现单聊群聊

    最近花了一个星期的时间在B站跟着老师学了环信即时聊天工具的使用 附上学习网站:https://www.bilibili.com/video/BV1cW411V7yd?p=1 附上自己的代码 https ...

最新文章

  1. 数据库事务的隔离级别 (转)
  2. iOS:极光推送控制器跳转
  3. dubbo配置(一)
  4. 递归算法——汉诺塔问题
  5. go/git设置及取消代理方法
  6. shrio的rememberMe不起作用
  7. mysql libs 5.1.71_用python创建数据库监控平台(1)安装MySQL5.7
  8. Java大新闻不断涌现:Java SE 6和OpenJDK
  9. restTemplate使用和踩坑总结
  10. 8086汇编求一组正整数{0x1223,0x1234,0x1434,0x2345,0x3412,0x1712}中的最大数并存在变量MAX中
  11. 更新 PORTS-Tree 且升级已安装的软件[zt]
  12. java 内存文件_Java内存映射文件(Memory Mapped Files)
  13. 企业综合安防管理平台
  14. 《世界咖啡》一书小结
  15. 小甲鱼python入门_python基础笔记(非系统/自用/参考小甲鱼的零基础入门学习python)上...
  16. 4、网络层:三层物理设备:集线器、交换机、路由器【IP、ICMP、BGP、OSPF
  17. hibernate5.4+mysql8+java8实例
  18. 深度玄学-实战开发步骤
  19. 兰大计算机网络复试答案
  20. 开源全渠道业务中台OMS订单管理系统

热门文章

  1. java 金额转换 元转分 分转元
  2. 传奇服务器 m2自动开启网关,GOM的M2里提示:非法网关连接 添加网关所在机器IP怎么回事?...
  3. iStat Menus 无法正常读取传感器温度的解决办法
  4. 数字货币一元夺宝系统:赋予平台代币新价值
  5. 关于在软件开发过程中建立三道风险防线的想法
  6. C#编程简单模拟与下位机的串口通信
  7. linux内核hz,linux内核中的HZ介绍
  8. java - 解决idea导入项目,中文出现乱码的问题
  9. 蓝屏0x0000007B
  10. 漏洞复现之ms10_018