- 综合排序
- 最热优先
- 最新优先
- 来自专栏云服务器购买
消息队列-腾讯云消息队列 CKafka
腾讯云消息队列 CKafka，分布式、高吞吐量、高可扩展性的消息服务，100%兼容开源 Apache Kafka 0.9 0.10 腾讯云消息队列 CKafka点击查看详情 消息队列 CKafka 简介 消息队列 CKafka（Cloud Kafka）是一个分布式、高吞吐量、高可扩展性的消息系统，100%兼容开源 Kafka API（0.9、0.10版本）。 腾讯云消息队列 CKafka 的特性 兼容开源 100% 兼容 Apache Kafka 0.9 0.10版本，迁移上云0成本。 高可靠 消息队列 CKafka 集群性能强劲，生产性超越开源方案；此外，消息队列 CKafka 分布式的部署，集群稳定性也有很好的保障。 统一运维监控 提供腾讯云平台整套的运维服务，包括租户隔离、权限控制、消息堆积查询、消费者详情查看等多维度监控告警等运维服务。
7.7K60发布于 2019-08-06 - 来自专栏腾讯云存储
云消息队列备份 | CKafka、TDMQ 消息队列数据备份到 COS
为了解决应用耦合，合理进行流量削锋，腾讯云提供了包括 CKafka 和 TDMQ 在内的一系列消息队列中间件。 为了更方便地对消息队列中的数据进行转存和持久化，腾讯云对象存储 COS 为用户提供了云消息队列备份的能力。 COS 应用集成提供了云消息队列备份的能力，开发者可以轻松配置定时备份任务，将云消息队列中的消息记录以文件的形式转至对象存储，以便进行持久化保存。 ：可按分钟维度聚合消息记录，并支持修改时间粒度； 自动化执行：云函数自动完成云消息队列CKafka / TDMQ 的数据备份，中间过程无需任何人工操作； 三、云消息队列介绍 消息队列 CKafka（Cloud c.时间粒度：根据消息量的大小，选取汇聚消息的时间间隔，时间间隔为5 - 15分钟不等。为保证转存性能，聚合文件数量与 Partition 数量、partition_max 设置数值有关。
2.3K20编辑于 2022-01-13 - 来自专栏用户5909132的专栏
云消息队列备份 | CKafka、TDMQ 消息队列数据备份到 COS
为了更方便地对消息队列中的数据进行转存和持久化，腾讯云对象存储 COS 为用户提供了云消息队列备份的能力。 COS 应用集成提供了云消息队列备份的能力，开发者可以轻松配置定时备份任务，将云消息队列中的消息记录以文件的形式转至对象存储，以便进行持久化保存。 ，并支持修改时间粒度； 自动化执行：云函数自动完成云消息队列CKafka / TDMQ 的数据备份，中间过程无需任何人工操作； 三、云消息队列介绍 消息队列 CKafka（Cloud Kafka）是一个分布式 时间粒度：根据消息量的大小，选取汇聚消息的时间间隔，时间间隔为5 - 15分钟不等。为保证转存性能，聚合文件数量与 Partition 数量、partition_max 设置数值有关。 4.云查毒：避免恶意程序入侵的正确姿势； 5.疫情反复，这里有一个助力远程办公的贴心助手； 6.COS 音视频实践｜播放多场景下的 COS 视频文件； — END — 真诚推荐您关注 点击“阅读原文
3.1K20编辑于 2022-01-14 - 来自专栏腾讯云开发者社区头条
腾讯云 CMQ 消息队列测试
队列名称是一个不超过64个字符的字符串，必须以字母为首字符，剩余部分可以包含字母、数字和横划线(-) 进行了简单的测试，队列名称都是符合文档规则 发送消息 batch批量发送消息 消息正文。 目前批量消息数量不能超过 16 条 这块有个问题就是：都是编译成功了的 自己写了批量发送消息循环，当发送消息数最大值为1000时候，会直接报异常 当消息数最大值为10000时候，隔了5s左右，报出异常 当消息数最大值为100000时候，等了5分钟还是没有报异常出现。 快速报出exception 在linux服务器上也进行了测试： 接受消息 (BatchReceiveMessage) 用于消费队列中的多条（目前最多16条）消息 在api可以正常获取到 因接受消息时 备注 今天收到腾讯云 CMQ 产品经理针对文章里的问题特意发来的邮件回复： 同时谢谢腾讯云提供CMQ的内测体验资格！
14.9K00发布于 2016-10-09 - 来自专栏开源技术小栈
TP5系列 | Queue消息队列
ThinkPHP5 Queue消息队列 优点 1、Queue内置了 Redis，Database，Topthink ，Sync这四种驱动，本文使用Redis驱动 2、Queue消息队列适用于大并发或者返回结果 但是推送消息依然是成功的。这个就是中间件的优势。他连接两个系统，但是又不会互相耦合，生产者并不会因为消费者的异常而影响到自己。 3、消息推送成功之后，如果没有消费者，消息会堆积在队列中。 27@qq.com 邮件发送成功了 Processed: app\common\queue\TestQueue 这里每消费掉一条消息，Redis数据库中将会减少一条消息 查看Redis队列消息 127.0.0.1 2、一开始监听队列。刚刚在队列中堆积的消息立刻就被获取到，开始执行了代码。最后执行完成，删除了消息。 3、在 queue:work--daemon 单进程循环消费的时候，改了代码是不会生效的。 这种业务就非常适合使用消息队列系统来异步处理，使性能提升。
4.8K52发布于 2019-08-06 - 来自专栏编程
5. 消息队列中，如何保证消息的顺序性？
消息队列中，如何保证消息的顺序性？ 面试官心理分析 其实这个也是用 MQ 的时候必问的话题，第一看看你了不了解顺序这个事儿？第二看看你有没有办法保证消息是有顺序的？这是生产系统中常见的问题。 比如，生产者向 RabbitMQ 里发送了三条数据，顺序依次是 data1/data2/data3，压入的是 RabbitMQ 的一个内存队列。 接着，我们在消费者里可能会搞多个线程来并发处理消息。因为如果消费者是单线程消费处理，而处理比较耗时的话，比如处理一条消息耗时几十 ms，那么 1 秒钟只能处理几十条消息，这吞吐量太低了。 拆分多个 queue，每个 queue 一个 consumer，就是多一些 queue 而已，确实是麻烦点；或者就一个 queue 但是对应一个 consumer，然后这个 consumer 内部用内存队列做排队
60210编辑于 2024-11-01 - 来自专栏决胜机器学习
消息队列（一） MySQL实现消息队列
消息队列（一）MySQL实现消息队列 （原创内容，转载请注明来源，谢谢） 一、概述 消息队列（MessageQueue，通常简称MQ）是一种进程间通信或同一进程的不同线程间的通信方式，是分布式应用间交换信息的一种技术 通过消息队列，应用程序可独立地执行，它们不需要知道彼此的位置、或在继续执行前不需要等待接收程序接收此消息。 消息队列有多种实现方式，可以用关系型数据库（如Mysql）、Nosql（如redis）、现有框架（如rabbitMQ）等。 Mysql处理消息队列的场景：主要是在数据处理量大、耗时久、处理流程繁杂、处理内容多、需要持久化（入库）、业务处理要求相对不实时的场景，如发邮件、发短信、订单后续处理、操作数据记录日志等。 因此，此场景就非常适合于用Mysql解决此消息队列。
16.6K41发布于 2018-03-07 - 来自专栏曾令武的专栏
消息队列及常见消息队列介绍
最近组内需要做流水server的选型升级，这里对消息队列及常见的消息队列进行了一次调研，整理了相关资料，分享给大家。 二、消息队列使用场景 消息队列在实际应用中包括如下四个场景： 应用耦合：多应用间通过消息队列对同一消息进行处理，避免调用接口失败导致整个过程失败； 异步处理：多应用对消息队列中同一消息进行处理，应用间并发处理消息 而加入消息队列后，系统可以从消息队列中取数据，相当于消息队列做了一次缓冲。 这三个子系统间由消息队列连接起来，前一个阶段的处理结果放入队列中，后一个阶段从队列中获取消息继续处理。 ； 目前重心放到activemq6.0产品-apollo，对5.x的维护较少； 不适合用于上千个队列的应用场景； 4.3 RocketMQ RocketMQ出自 阿里公司的开源产品，用 Java 语言实现
53.2K2714发布于 2017-09-29 - 来自专栏crmeb
thinkphp5的消息队列详细教程
消息队列的概念、原理和场景 在高并发的时候，程序往往无法做到及时的处理。我们引入一个中间的系统，来进行分流和减压。 所以从本质上讲：消息队列就是一个队列结构的中间件。 1、队列结构的中间件 2、消息放入后，不必立即处理 3、由订阅者/消费者按顺序处理 也就是说：当遇到一个比较大或者耗时比较长的环节的时候，而同时你的业务又不需要立即知道这个环节的结果，使用消息队列是好的选择 知识付费的拼团功能使用的就是消息队列功能；把每个拼团订单都储存在消息队列中，拼团完成或拼团结束就可以自动处理这个订单。 $data['pink_time']) return true; $timewait = $data['pink_time'] + 300; // 4.将该任务推送到消息队列 do_job_pink,’名称’); application\index\job\PullDoPink： private function 名称($data) { return true; } 完成后重新启动消息队列
1.7K20编辑于 2022-05-05 - 来自专栏java思维导图
消息队列探秘 – RabbitMQ 消息队列介绍
在2013年5月被并入Pivotal。其实VMWare，Pivotal和EMC本质上是一家的。不同的是VMWare是独立上市子公司，而Pivotal是整合了EMC的某些资源，现在并没有上市。 5）如何有效的将数据发送到相关的接收者？也就是说将接收者subscribe 不同的数据，如何做有效的filter。 6）如何做到可扩展，甚至将这个通信模块发到cluster上？ Broker： 简单来说就是消息队列服务器实体。 Exchange： 消息交换机，它指定消息按什么规则，路由到哪个队列。 Queue： 消息队列载体，每个消息都会被投入到一个或多个队列。 Queue Queue（队列）是RabbitMQ的内部对象，用于存储消息，用下图表示。 queue ? ，根据其中的correlationId属性分析哪条请求被执行了，根据执行结果进行后续业务处理 5.
4.8K20发布于 2019-11-05 - 来自专栏互联网技术栈
消息队列探秘-RabbitMQ消息队列介绍
在2013年5月被并入Pivotal。其实VMWare，Pivotal和EMC本质上是一家的。不同的是VMWare是独立上市子公司，而Pivotal是整合了EMC的某些资源，现在并没有上市。 5）如何有效的将数据发送到相关的接收者？也就是说将接收者subscribe 不同的数据，如何做有效的filter。 6）如何做到可扩展，甚至将这个通信模块发到cluster上？ ---- Broker： 简单来说就是消息队列服务器实体。 Exchange： 消息交换机，它指定消息按什么规则，路由到哪个队列。 Queue： 消息队列载体，每个消息都会被投入到一个或多个队列。 Queue Queue（队列）是RabbitMQ的内部对象，用于存储消息，用下图表示。 queue ? 指定的Queue，从中收到服务器的应答消息后，根据其中的correlationId属性分析哪条请求被执行了，根据执行结果进行后续业务处理 5.
4.3K30发布于 2018-12-12 消息队列
消息队列中间件、分布式面向对象中间件和事务处理中间件等。 消息队列服务是一种松耦合的分布式应用集成形式。 消息队列分为用户创建队列和系统队列，用户队列分为： 1)“公共队列”在整个可传送消息的“消息队列”网络中复制并传输，并且有可能由网络连接的所有站点访问。 2)“专用队列”不在整个网络中发布。 系统队列分为： 1)“日记队列”可选的存储发送消息的副本和从队列中溢出的消息副本。 2)“死信队列”存储无法传送或已过期的消息的副本。 消息队列服务系统处理高并发服务是又一技术难点，服务器由原来处理5个并发任务到16并发任务，再到2000并发任务一直不断的改进。 MB消息路由和数据转换。 消息队列技术是分布式应用间交换信息的一种技术。消息队列可驻留在内存或磁盘上,队列存储消息直到它们被应用程序读走。
41110编辑于 2025-08-29消息队列
什么是消息队列？消息队列是一种异步通信（Asynchronous Communication）的服务或组件。 它充当了消息的中介：发送方（生产者，Producer）将消息发送到队列中，接收方（消费者，Consumer）从队列中获取并处理消息。 核心特点是解耦：生产者和消费者不需要知道彼此的存在，它们只与消息队列交互。消息队列是解决高并发问题的关键技术之一。2.解决了什么问题？ 消息队列主要解决了分布式系统中的三大核心问题：解耦（Decoupling）：问题：系统间存在强依赖关系。解决：将消息的发送和接收分离开。 2.Broker 真正的 “消息存储 & 转发节点”：存储生产者发送的消息，给消费者提供消息读取；管理 Topic（消息主题）、Queue（消息队列）等元数据。
49210编辑于 2025-11-11- 来自专栏晨曦破晓の家
消息队列
啥是消息队列 一般来说，消息队列是一种异步的服务间通信方式，是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。 通过使用消息队列，我们可以异步处理请求，从而缓解系统的压力。 消息队列有哪些 Kafka RocketMQ RabbitMQ pulsar activeMQ verneMQ 一个大型的分布式系统，通常都会异步化，走消息总线。 消息队列作为最主要的基础组件，在整个体系架构中，有着及其重要的作用。异步通常意味着编程模型的改变，时效性会降低。 kafka是目前最常用的消息队列，尤其是在大数据方面，有着极高的吞吐量。 而rocketmq和rabbitmq，都是电信级别的消息队列，在业务上用的比较多。相比较而言，ActiveMQ使用的最少，属于较老一代的消息框架。
4.7K30发布于 2020-09-11 消息队列
消息队列 前言： 说实话，最近还是比较忙的，手上素材倒是一大把，但是大多只是初步整理了。但是博客这种东西还是要写的，果然后面还是要放低一下排版要求（扩展性的一些东西也少提一些）。 简介： 消息队列这个东西，其实网上的资料还是很多的。我就简单说一些自己的认识与源代码哈。 演变： 我是很喜欢了解技术演进的，因为演进的过程展现了前辈们的智慧。 最早的程序串行执行就不说了。 当然了，在本篇中，只简单谈一下异步通信的主流实现-消息队列。 选择： 选择方面，我就不多说了，目前只用过RabbitMq,RocketMq,Kafka。 网上有关消息队列选择的文章很多，很细致，我就不赘述了。 代码实现： 这里贴出来的都是实际生产代码（如果内部版本也算的话，嘿嘿），所以如果有一些不是很熟悉的类，请查看import，是否是项目自身的类。 virtual-host: "/" connection-timeout: 15000 小结： 这里不得不赞一下Spring，它通过提供RabbitMq地封装API-ampq，极大地简化了消息队列的代码
26210编辑于 2025-08-26消息队列
二、使用场景异步处理发送者将消息发送给消息队列之后，不需要同步等待消息接收者处理完毕，而是立即返回进行其它操作。消息接收者从消息队列中订阅消息之后异步处理。 例如在注册流程中通常需要发送验证邮件来确保注册用户身份的合法性，可以使用消息队列使发送验证邮件的操作异步处理，用户在填写完注册信息之后就可以完成注册，而将发送验证邮件这一消息发送到消息队列中。 可以将请求发送到消息队列中，服务器按照其处理能力从消息队列中订阅消息进行处理。 通过使用消息队列，一个模块只需要向消息队列中发送消息，其它模块可以选择性地从消息队列中订阅消息从而完成调用。三、可靠性发送端的可靠性发送端完成操作后一定能将消息成功发送到消息队列中。 事务提交成功后，将消息表中的消息转移到消息队列中，若转移消息成功则删除消息表中的数据，否则继续重传。接收端的可靠性接收端能够从消息队列成功消费一次消息。
1.2K30编辑于 2024-05-15- 来自专栏全栈程序员必看
消息队列
消息队列 一、消息模型 点对点 消息生产者向消息队列中发送了一个消息之后，只能被一个消费者消费一次。 发布/订阅 消息生产者向频道发送一个消息之后，多个消费者可以从该频道订阅到这条消息并消费。 二、使用场景 异步处理 发送者将消息发送给消息队列之后，不需要同步等待消息接收者处理完毕，而是立即返回进行其它操作。消息接收者从消息队列中订阅消息之后异步处理。 可以将请求发送到消息队列中，服务器按照其处理能力从消息队列中订阅消息进行处理。 通过使用消息队列，一个模块只需要向消息队列中发送消息，其它模块可以选择性地从消息队列中订阅消息从而完成调用。 三、可靠性 发送端的可靠性 发送端完成操作后一定能将消息成功发送到消息队列中。 事务提交成功后，将消息表中的消息转移到消息队列中，若转移消息成功则删除消息表中的数据，否则继续重传。 接收端的可靠性 接收端能够从消息队列成功消费一次消息。
4.2K20发布于 2021-04-07 - 来自专栏腾讯云可观测专栏
腾讯云消息队列（Ckafka）监控最佳指南
作者：朱丹阳，腾讯云监控开发工程师 腾讯云消息队列 CKafka 简介 消息队列 CKafka（Cloud Kafka）是基于开源 Apache Kafka 消息队列引擎，提供高吞吐性能、高可扩展性的消息队列服务 配置告警 https://console.cloud.tencent.com/monitor/overview 进入腾讯云监控，选择告警配置下告警策略，并新建告警策略。 设置消息队列告警： 1. 选择消息队列 Ckafka 实例 5. 设置告警指标及触发条件 6. 选择告警渠道，包括接收对象，接收渠道，有效时段，接收语言 7. 保存 ? 配置的 Ckafka 实例告警总览 ? 2. 进入腾讯云监控，选择 Dashboard，然后选择预设 Dashboard 下的消息队列 CKafka 预设面板。 消息队列 CKafka 预设面板 总览： ? 欢迎联系云监控小助手微信号，加群讨论：） ?
4.5K20发布于 2020-12-18 - 来自专栏A周立SpringCloud
网易云音乐的消息队列改造之路
本文整理自网易云音乐消息队列负责人林德智在近期 Apache Flink&RocketMQ Meetup 上海站的分享，通过该文，您将了解到： 网易云音乐消息队列改造背景 网易云音乐业务对消息队列要求 网易云音乐消息队列架构设计 网易云音乐消息队列部分高级特性介绍 网易云音乐消息队列落地使用情况 网易云音乐消息队列未公开规划 背景 ---- 网易云音乐从13年4月上线以来，业务和用户突飞猛进。 消息队列在云音乐的使用情况 ---- ? 截止目前为止，基于 RocketMQ 改造实现的消息队列在网易云音乐生产环境已经有 6 个集群。涉及顺序消息，普通消息，多种高可用高可靠要求。 我们期望云音乐的消息队列能够拓展到日志方面，将消息队列具备的完善监控告警等能力赋能到大数据，NDC 订阅（数据库更新订阅服务）。同时增加路由能力减少多机房间跨机房访问。 另外，消息队列 RocketMQ 在整个网易除云音乐外并没有其他大产品在使用，未来我们会联合杭研，将消息队列推广到其他大产品线，将云音乐对消息队列的改进和特性普惠到其他大产品。
75730发布于 2019-08-01 - 来自专栏Owen's World
消息队列
为什么使用消息队列 其实就是问问你消息队列都有哪些使用场景，然后你项目里具体是什么场景，说说你在这个场景里用消息队列是什么？ 先说一下消息队列常见的使用场景吧，其实场景有很多，但是比较核心的有 3 个：解耦、异步、削峰。 解耦 看这么个场景。A 系统发送数据到 BCD 三个系统，通过接口调用发送。 如果使用 MQ，那么 A 系统连续发送 3 条消息到 MQ 队列中，假如耗时 5ms，A 系统从接受一个请求到返回响应给用户，总时长是 3 + 5 = 8ms，对于用户而言，其实感觉上就是点个按钮，8ms 所以说，只要高峰期一过，A 系统就会快速将积压的消息给解决掉。 消息队列有什么优缺点 优点上面已经说了，就是在特殊场景下有其对应的好处，解耦、异步、削峰。 如何保证消息队列的高可用，可以点击这里查看。 系统复杂度提高 硬生生加个 MQ 进来，你怎么保证消息没有重复消费？怎么处理消息丢失的情况？怎么保证消息传递的顺序性？
3.1K40编辑于 2021-12-08
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号