tencent cloud

腾讯云消息队列（Cloud Message Queue，CMQ）是分布式消息队列服务，能够为分布式部署的不同应用之间或者一个应用的不同组件之间，提供基于消息的可靠的异步通信机制，消息被存储在高可靠、高可用的 CMQ 队列中，多进程可以同时读写、互不干扰。
CMQ 提供了四种 SDK，本文以 Python 为例进行说明。

Python SDK 简介

为了方便使用，CMQ 将用户操作、队列操作、主题操作等抽象成了几个类：

• Account：封装账户 SecretId、SecretKey，用户可以创建删除队列、主题及订阅，并查看这些对象。
• queue：收发消息，查看设置队列属性。
• topic：发布消息，查看设置主题属性，查看订阅者。
• cmq_client：可以设置一些客户端的与服务器端连接属性，如设置是否写日志、连接超时时间、是否长连接等。

所有的类均为非线程安全的，如果需要多线程使用，最好每个线程实例化自己的对象。

下载 SDK >>

队列模型

这里的队列与数据结构中定义的 Queue 有一定区别。数据结构中的队列严格按照 FIFO 操作，这里的分布式队列不会有严格的 FIFO（后续会推出专属的 FIFO 产品）。这里的队列相当于一个高性能、高容量、高可靠的容器，可以生产消息投递进去，也可以把消息取出来消费。队列在初始化的时候有自己的属性设置。属性以及含义如下：

查看队列模型快速入门>>

主题模型

主题模型类似设计模式中的发布订阅模式，Topic 相当于发布消息的单位，Topic 下面的订阅者相当于观察者模式。Topic 会把发布的消息主动推送给订阅者：

查看主题模型快速入门 >>