展开

关键词

首页关键词.net core 消息队列

.net core 消息队列

相关内容

消息队列 CMQ

消息队列 CMQ

腾讯云消息队列(CMQ)是一种分布式消息队列服务,它能够提供可靠的基于消息的异步通信机制,能够将分布式部署的不同应用(或同一应用的不同组件)之间的收发消息,存储在可靠有效的 CMQ 队列中,防止消息丢失。CMQ 支持多进程同时读写,收发互不干扰,无需各应用或组件始终处于运行状态。
  • 消息队列 CMQ

    ,查询订阅详情,删除订阅,创建订阅接口,清空订阅者消息标签,修改主题属性,查询主题详情,删除主题,创建主题,数据结构,错误码,API 概览,更新历史,产品动态,功能和概念,案例和实践,联系我们,CMQ队列迁移至 TDMQ CMQ 版,产品简介,产品概述,产品功能,词汇表,产品优势,服务等级协议(SLA),案例分享,在线图片处理案例,海量数据处理案例,春晚微信红包案例,Push 和 Pull 的区别,腾讯云 CMQ 与 RabbitMQ 的对比分析,应用场景,应用场景概述,系统解耦,削峰填谷,可靠传递,多次复用,屏蔽平台差异,跨用户数据交换,队列模型,队列相关接口,消息相关接口,创建队列,获取队列列表,订阅相关接口,修改订阅属性,查询订阅详情,删除订阅,创建订阅接口,清空订阅者消息标签,主题相关接口,修改主题属性,查询主题详情,删除主题,创建主题,数据结构,错误码,API 概览,更新历史,消息队列CMQAPI 2017,产品动态,视频专区,功能和概念,案例和实践,联系我们,CMQ 队列迁移至 TDMQ CMQ 版,迁移说明
    来自:
  • 消息队列 CMQ 版

    消息队列 CMQ 版(TDMQ CMQ 版)是一种分布式消息队列服务,它能够提供可靠的,基于消息的异步通信机制,能够将分布式部署的不同应用(或同一应用的不同组件)中的信息传递,存储在可靠有效的 CMQ队列中,防止消息丢失。TDMQ CMQ 版支持多进程同时读写,收发互不干扰,无需各应用或组件始终处于运行状态。
    来自:
  • 广告
    关闭

    11.11智惠云集

    2核4G云服务器首年70元,还有多款热门云产品满足您的上云需求

  • 您找到你想要的搜索结果了吗?
    是的
    没有找到
  • 产品动态

    2019-06-27事务消息 2019年05月动态名称动态描述发布时间相关文档 CMQ 支持死信队列死信队列用于处理无法被正常消费的消息。当一条消息达到最大重试次数后依然消费失败时,CMQ 不会立刻将消息丢弃,而是将其发送到该消费者对应的特殊队列中,即死信队列。对新建的队列,或存量的队列,您都可以启用死信队列。2019-05-20死信队列 2018年12月动态名称动态描述发布时间相关文档 CMQ 支持延迟消息CMQ 消息定时器允许您为要添加到队列的消息指定初始的不可见时段,不可见时间段内使用者将看不到该消息。2018-10-30消息回溯功能 2016年07月动态名称动态描述发布时间相关文档 消息队列 CMQ 产品上线 CMQ 提供可靠的基于消息的异步通信机制,能够将分布式部署的不同应用(或同一应用的不同组件)之间的收发消息,存储在可靠有效的 CMQ 队列中,防止消息丢失。
    来自:
  • 产品概述

    CMQ 消息队列介绍消息队列 CMQ(Cloud Message Queue,以下简称 CMQ)是基于腾讯自研消息引擎的分布式消息队列系统,CMQ 通过腾讯自研分布式 Raft 算法保证消息强一致,消息同步同时在深圳金融专区、上海金融专区均有部署,提供金融级数据高可靠消息队列服务。CMQ 目前提供 HTTP(S)、TCP 协议的接入。提供 PHP、Java、Python 等丰富语言的 SDK 接入。腾讯云 CMQ 分布式消息队列中的消息会被持久化保存,直到接收者成功获取它。 需要在访问量与日俱增、囤积在队列中的消息数日益增长的情况下也能正常运转。传统的消息队列把消息存在本地内存中,单机的处理能力和内存容量都是有限的,不具备可扩展性。腾讯云 CMQ 的分布式架构保证了其扩容的简易性,更重要的是扩容对 CMQ 的使用者是完全透明的。例如,两个腾讯云上的服务在不知道对方地址的情况下需要进行通信,则可以通过约定队列名,一个向队列发送消息,一个从队列中收取消息而实现。
    来自:
  • CMQ 队列迁移至 TDMQ CMQ 版

    迁移原理方案总览整体流程 1在控制台上将 CMQ 的队列和主题元数据迁移至 TDMQ CMQ 版中。 2旧的消费者保持不动,消费端新建消费者,接入到 TDMQ CMQ 版的队列中。3生产者停止向原 CMQ 队列生产消息,并切换生产流接入到 TDMQ CMQ 版队列中。 4旧的消费者继续消费原 CMQ 队列中的存量消息,消费完成后下线 CMQ 业务消费者。queue:填写队列名称。 运行代码,查看消费端服务是否能正常运行无报错。 通过 TDMQ CMQ 版控制台 的队列服务 > 发送消息向消息接收侧发送测试消息,验证消费者服务是否可以正常消费。运行生产消息程序,验证生产者服务是否可以正常发送消息。 步骤4:下线旧消费者等待旧的消费者继续消费完原 CMQ 队列中的存量消息后,下线 CMQ 业务消费者。在 CMQ 控制台 的队列服务 > 队列 > 监控页面可查看 CMQ 队列中堆积的消息数量,当堆积消息数量为0时,代表原 CMQ 队列中的存量消息已被消费完成。
    来自:
  • 简介

    欢迎使用腾讯云消息队列 CMQ(Cloud Message Queue)。腾讯云消息队列(Cloud Message Queue,以下简称 CMQ)是分布式的消息队列服务,用于存储进程间传输的消息,为分布式部署的不同应用之间或者一个应用的不同组件之间提供基于消息的可靠的异步通信服务消息被存储在高可靠、高可用的消息队列中,多进程可以同时读写,互不干扰。使用腾讯云 CMQ,用户可以在执行不同任务的应用程序的分布式组件之间传递信息,既不会丢失消息,也不要求各个组件始终处于可用状态。为此,腾讯云引入了消息队列服务进行消息分发和管理。使用腾讯云 CMQ,您可以分离应用程序的组件以便其独立运行,同时还可以简化组件间的消息管理。分布式应用程序的任何组件均可将消息存储在队列中,腾讯云 CMQ 确保每条消息至少传送一次,并且支持多次读取和写入。单个队列可由多个分布式应用程序组件同时使用而无需这些组件之间的互相协作。
    来自:
  • 死信队列

    达到最大重试次数后,若消费依然失败,则表明消费者在正常情况下无法正确地消费该消息,此时 CMQ 不会立刻将消息丢弃,而是将其发送到该消费者对应的特殊队列中,这个特殊队列就是 DLQ。对新建的队列,或存量的队列,您都可以启用死信队列。应用场景定位问题:例如,某条消息被多次消费后却未被删除,一般是由于该消息未被正确消费,可能存在问题需要回溯定位。单车开锁逻辑中,当 CMQ 堆积了1亿条消息时,会优先处理最新生产的部分消息,老的消息淘汰到死信队列,在消费者有能力时再处理。最大接收次数:将消息发送到死信队列前允许接收该消息的最大次数,支持设定值为1 - 1000次。最大未消费时间:将消息发送到死信队列前达到了最大未消费时间,允许设置5分钟 - 12小时。注意: 当 CMQ 触发高可用性时,CMQ 服务器 leader 切换有可能会导致计算消费次数不准确。 使用规则一个队列只能绑定一个死信队列。绑定的死信队列必须是同地域、同帐号下的队列。
    来自:
  • TCP SDK

    CMQ 目前已开放基于 TCP 协议的 SDK 调用,支持普通消息、事务消息、延迟消息、异步消息的收发功能。其中,事务消息特性仅通过 TCP 方式实现。更多样的特性支持TCP 支持 CMQ 最新的分布式消息事务。配置 Demo 工程创建资源您需要在控制台创建所需消息队列资源,包括 CMQ 队列名、SecretID、SecretKey。具体创建过程请参考 队列模型快速入门 和 主题模型快速入门。配置 Demo 参数修改文件 NameServer 地址、密钥对及消息队列名,NameServer 地址请参考 NameServer 对照表。”具体图示如下: 运行 Demo使用队列模型收发消息配置 Demo 参数。
    来自:
  • 使用示例

    为了帮助用户快速使用云消息服务(CMQ)API,这里给出一个使用示例,能够引导用户使用 API 完整地创建队列、发送消息、消费消息、删除消息并删除队列。请参照下面说明将域名中的 {$region} 替换成相应地域: 外网接口请求域名:https:cmq-queue-{$region}.api.qcloud.com内网接口请求域名:http:cmq-queue队列模型以内网为例(外网操作时,需将域名中的 tencentyun 替换成 qcloud),请求域名的构成规则形如 cmq-queue-{$region}.api.tencentyun.comv2index.php,可以进行管理队列和发送消费消息等操作。大小至少1Byte,最大长度受限于设置的队列消息最大长度属性。
    来自:
  • 队列和消息标识符

    使用腾讯云 CMQ 时,用户首先需要熟悉以下三个标识符:队列名称、消息 ID 和接收句柄。1. 队列名称创建新队列时,用户必须提供在此地域范围内唯一的队列名称,不同地域间队列名称可以重复。腾讯云 CMQ 使用地域和队列名称唯一标识一个队列,每当用户要对队列执行操作时,都需要提供这两个参数。2.消息 ID每条消息都会收到一个由腾讯云系统分配的消息 ID,该 ID 可由 SendMessage 接口请求中返回给用户。此标识符用于识别消息。需要注意的是,删除消息时用户需要消息的接收句柄,而不是消息 ID。消息 ID 有形如“Msg-XXXXXXXX”的样式。3. 接收句柄每当收到来自队列的消息时,用户都会收到该消息的接收句柄。消息句柄始终与接收消息的操作相关联,与消息本身无关。要删除消息或更改消息属性,用户则必须提供接收句柄,而不是消息 ID。这意味着,必须始终先接收消息,然后才能删除更改它。
    来自:
  • 词汇表

    本部分介绍了腾讯云 CMQ 队列的基本属性、队列和消息的标识符等内容。1.腾讯云 CMQ 消息服务提供的有时效的消息句柄可以有效避免 数据误操作,也极大降低了句柄泄露可能给用户带来的风险 生产者Producer向 CMQ 的消息服务发送消息的角色 消费者Consumer从 CMQ队列(Queue)相关名词 专有名词对应英文解释 队列Queue消息存储的目的地,消费者主动从这里获取消息。后续将支持 CMQ 主动推送的 PUSH 模式 可见消息Activemessages队列中处于 Active 状态的消息总数(近似值) 不可见消息InactiveMessages队列中处于 InactiveCMQ 的 Topic 下的消息分类。
    来自:
  • 简介

    更多腾讯云 API 3.0 使用介绍请查看:快速入门欢迎使用腾讯云消息队列 CMQ(Cloud Message Queue)。腾讯云消息队列(Cloud Message Queue,以下简称 CMQ)是分布式的消息队列服务,用于存储进程间传输的消息,为分布式部署的不同应用之间或者一个应用的不同组件之间提供基于消息的可靠的异步通信服务消息被存储在高可靠、高可用的消息队列中,多进程可以同时读写,互不干扰。使用腾讯云 CMQ,用户可以在执行不同任务的应用程序的分布式组件之间传递信息,既不会丢失消息,也不要求各个组件始终处于可用状态。为此,腾讯云引入了消息队列服务进行消息分发和管理。使用腾讯云 CMQ,您可以分离应用程序的组件以便其独立运行,同时还可以简化组件间的消息管理。分布式应用程序的任何组件均可将消息存储在队列中,腾讯云 CMQ 确保每条消息至少传送一次,并且支持多次读取和写入。单个队列可由多个分布式应用程序组件同时使用而无需这些组件之间的互相协作。
    来自:
  • HTTP SDK

    概述腾讯云消息队列 CMQ 目前支持 Java、Python、PHP 及 C++ SDK ,后续会支持更多语言。欢迎广大开发者根据 API 说明开发更多语言版本的 SDK。目前消息队列对于公网下行流量是要收取流量费用的,用内网可以节省这部分的费用。配置 Demo 工程创建资源您需要在控制台创建所需消息队列资源,包括 CMQ 队列名、SecretID、SecretKey。具体创建过程请参考 队列模型快速入门 和 主题模型快速入门。运行 Demo使用队列模型收发消息先运行 Producer 类发送消息,再运行 Consumer 类接受消息。发送消息代码示例:String msg = hello!,用队列处理消息。
    来自:
  • 功能类

    可以在图形管理界面中查看队列的情况吗?CMQ 提供可视化控制台,您可以很方便地查看当前队列情况。进入控制台 >>CMQ 目前支持 MQTT 协议吗?CMQ 目前不支持 MQTT 协议。CMQ 使用哪种协议访问?CMQ 使用 HTTP、TCP 协议,CMQ SDK 会维护 TCP 长连接。CMQ 会进行消息去重吗?目前 CMQ 不会对消息进行去重。重复消息出现的原因以及去重方案,您可以参考 消息去重。CMQ 消费消息时,pull 的长轮询是如何实现的?队列有 pollingWaitSeconds 属性,表示默认的队列长轮询时间。消费消息时如果有消息,则直接返回消息;如果当前队列没有消息,则会等待 pollingWaitSeconds 时间,如果在该时间内有消息则返回消息;如果超过了该时间仍然没有消息,则会报没有消息的异常。CMQ 队列和主题模式 QPS 有限制吗?CMQ 对单队列和单主题 QPS 有限制,默认限制为 5000QPS。CMQ 队列模式有流量限制吗?CMQ 对单队列有流量限制,默认限制为 50MBs。
    来自:
  • 事务消息

    用户实现类似 XOpen XA 的分布事务功能,通过 CMQ 事务消息能达到分布式事务的最终一致。发送事务消息示例package demo; import com.qcloud.cmq.client.common.ClientConfig;import com.qcloud.cmq.client.common.LogHelper3000ms producer.setRequestTimeoutMS(5000); 设置首次回查的时间间隔,默认5000ms producer.setFirstCheckInterval(5); 消息发往的队列TransactionStatus checkStatus(Message msg) { 用户实现,检查本地事务的执行状态 ... ... return TransactionStatus.COMMIT; }}消费事务消息消费事务消息与从普通队列或者订阅中消费一致,详情请参考 队列模型消费消息。
    来自:
  • 在线图片处理案例

    使用腾讯云 CMQ 实现了上述需求,用户的图片存储在腾讯云存储中(CBSCOS等),用户的每一个操作请求都会作为一个消息存入请求队列(Request Queue)中,消息内容为:图片索引,由图片名称+用户请求的操作类型运行在 CVM 的图片处理服务从 Request Queue 中获取消息(图片索引),图片处理服务器从云端下载数据,并进行图片编辑,完毕后把处理结果发送到结果队列(Response Queue)中,结果图片存储到云存储中但是系统利用 CMQ 使得错误对用户透明,一方面用户可以继续上传照片,web server 可以继续发消息到 Request Queue,消息会被保存在队列中直到图片处理服务可用后取走;另一方面。因为 CMQ 提供的接收消息(包括接收顺序队列消息和接收并发队列消息)特性保证消息在接收后仍然在队列中,直到消息的接收者显式来删除它。本特性保证了图片处理服务与图片上传服务的解耦。CMQ 的两个特性让这个需求成为可能: 单个 CMQ 队列是可以让多个 server 同时共享访问的(即发送消息、接收并发队列消息、删除并发队列消息功能)。
    来自:
  • 入门指南

    腾讯云消息队列(Cloud Message Queue,CMQ)是分布式消息队列服务,能够为分布式部署的不同应用之间或者一个应用的不同组件之间,提供基于消息的可靠的异步通信机制,消息被存储在高可靠、高可用的CMQ 队列中,多进程可以同时读写、互不干扰。CMQ 提供了四种 SDK,本文以 Python 为例进行说明。Python SDK 简介为了方便使用,CMQ 将用户操作、队列操作、主题操作等抽象成了几个类: Account:封装账户 SecretId、SecretKey,用户可以创建删除队列、主题及订阅,并查看这些对象这里的队列相当于一个高性能、高容量、高可靠的容器,可以生产消息投递进去,也可以把消息取出来消费。队列在初始化的时候有自己的属性设置。
    来自:
  • 购买指南

    说明: 目前,腾讯云消息队列 CMQ 正在全面升级中(预计2021年9月完成),升级后将作为一款新型消息队列产品推出。 现阶段 CMQ 服务免费。您无需为队列服务和主题模式的请求次数、消息堆积支付费用。如需了解本产品更多详情,请 联系我们 获得支持。
    来自:
  • 生产消息

    登录 消息队列 CMQ 控制台,在左侧导航栏单击【队列服务】>【 队列】。在队列列表中选择目标队列,单击操作列的【发送消息】。填写消息内容,单击【发送】,向消息接收侧发送测试消息。消息内容:填写发送的内容,至少1Byte,最大长度受限于设置的队列消息最大长度属性。延迟发送:可开启延迟消息,开启后消息会在延迟时间后发送,延迟时间范围为1秒 - 1小时。
    来自:

扫码关注云+社区

领取腾讯云代金券