启动服务后,如何同时持续监听消息队列(mns)的消息(工单解决全过程)?

简介:

我: 如何监听消息队列的消息?我使用django开发,在启动服务的的时候就开启监听,但是这样由于使用while True,导致服务启动阻塞.请问应该如何解决?

工程师: 多线程并发消费消息,可以参考: https://help.aliyun.com/document_detail/32451.html 虽然是java demo, 原理类似,可以拿来参考。


我: 看起来有点吃力,逻辑是当启动web服务的时候同时启动一个线程,这个线程执行receive_message

工程师: 这个线程执行receive_message 具体遇到什么问题? 具体堵塞在什么地方?


我: 之前的写法是这样,执行到message.receive_message()这里就停在这里了

message = Message(topic='user', queue='register') 
message.receive_message()

现在我改成了这样:

message = Message(topic='user', queue='register') 
threading.Thread(target=message.receive_message).start()

这样写好像就解决了我的问题

工程师: 抱歉,我们对django开发所知甚少。 相关开发问题,还需要您到相关开发社区去咨询一下。


我: 这跟django没有关系吧

工程师: 如果配置了长轮询https://help.aliyun.com/document_detail/34478.html 那么当队列没有消息时,receive_message会挂住,如果WaitSecond内有消息,立即返回;否则,会等到WaitSecond后才返回。
“执行到message.receive_message()这里就停在这里了” 停止了多长时间?


我: 长时间,一直没有执行下面的代码;还有一个问题,我使用的python的sdk,消息写入队列成功,但是取的时候出现错误,在你们的控制台也是base64出现乱码;我写入的消息内容只有Message内容, 消息取出的是如上图的结构吗?

工程师: 您好,消息的结构是这样的。请问您乱码问题在本地读取也是,还是只是控制台测试是这样?


我: 使用sdk的receive_message(wait_seconds)方法,会报Incorrect padding错误

工程师: 长轮询最长是30秒,如果超过30秒receive_message都没有返回,可以怀疑是代码的问题,建议使用单线程写个最简单的程序(官网python demo),先将receive_message调试成功。
关于乱码: queue提供的sdk,会默认对发送的消息做Base64 Encode,对接收到的消息做Base64 Decode。
所以如果使用queue sdk来发送,sdk接收是没有问题的。 在队列控制台点击“接收消息”时,您需要指定使用base64解码.


我: 问题好像已经解决了 1.开启进程可以解决持续监听队列消息的问题 2.关于编码问题,python sdk中, Queue和Topic都有发送消息的方法,Queue.send_message()默认经过base64编码,使用Queue.receive_message时默认解码所以可以正常执行(你们官方示例就是这样),但是Topic.publish_message()默认写入队列时未经过base64编码,但是官方未给出主题队列获取消息的示例,则同样使用Queue.receive_message获取消息,则会报错,只要在获取Queue示例queue后,再执行queue.set_encoding(False),然后在获取消息就不会报错了

工程师: topic提供的sdk, 默认是不做任何编解码的。
所以如果用sdk发送消息到topic, 配置推送消息到队列,用python sdk拉取队列消息,是会产生乱码的,需要自行做base64解码。
php: 从1.2.1版本开始,Queue提供了禁用Base64的选项,需要在getQueueRef的时候传入参数$base64 = FALSE;
java: 从1.1.0版本开始,消息Base64编码支持可选。 其他语言的queue sdk目前还不提供base64编解码可选。

相关文章
|
4月前
|
消息中间件 数据管理 Serverless
阿里云消息队列 Apache RocketMQ 创新论文入选顶会 ACM FSE 2025
阿里云消息团队基于 Apache RocketMQ 构建 Serverless 消息系统,适配多种主流消息协议(如 RabbitMQ、MQTT 和 Kafka),成功解决了传统中间件在可伸缩性、成本及元数据管理等方面的难题,并据此实现 ApsaraMQ 全系列产品 Serverless 化,助力企业提效降本。
|
2月前
|
消息中间件 Java Kafka
消息队列比较:Spring 微服务中的 Kafka 与 RabbitMQ
本文深入解析了 Kafka 和 RabbitMQ 两大主流消息队列在 Spring 微服务中的应用与对比。内容涵盖消息队列的基本原理、Kafka 与 RabbitMQ 的核心概念、各自优势及典型用例,并结合 Spring 生态的集成方式,帮助开发者根据实际需求选择合适的消息中间件,提升系统解耦、可扩展性与可靠性。
220 1
消息队列比较:Spring 微服务中的 Kafka 与 RabbitMQ
|
2月前
|
安全 数据管理 关系型数据库
Dify on DMS,快速构建开箱即用的客服对话数据质检服务
本文介绍基于 Dify 与阿里云数据管理服务 DMS 的智能客服对话质检解决方案。该方案通过集成 Dify 的 AI 能力与 DMS 的数据管理能力,实现从数据获取到质检分析的全链路闭环,提升客服质检效率与准确性,助力企业数字化转型。
309 20
|
4月前
|
人工智能 自然语言处理 语音技术
深度解析:AI语音客服系统如何重塑客户服务体验与主流解决方案探析
在数字化浪潮下,AI语音客服凭借高效、便捷、24小时在线的优势,成为企业提升服务效率、优化体验的重要工具。本文详解其核心技术、应用价值、选型要点及市场主流方案,如阿里云通义晓蜜、合力亿捷等,助力企业智能化升级。
420 1
|
6月前
|
人工智能 自然语言处理 语音技术
|
10月前
|
机器学习/深度学习 人工智能 自然语言处理
人工智能在虚拟客服中的关键作用:提升交互体验与服务效率
人工智能在虚拟客服中的关键作用:提升交互体验与服务效率
641 90
|
消息中间件 JSON Java
开发者如何使用轻量消息队列MNS
【10月更文挑战第19天】开发者如何使用轻量消息队列MNS
840 97
|
消息中间件 安全 Java
云消息队列RabbitMQ实践解决方案评测
一文带你详细了解云消息队列RabbitMQ实践的解决方案优与劣
358 106

相关产品

  • 云消息队列 MQ