学习
实践
活动
专区
工具
TVP
写文章
首页标签消息队列

#消息队列

浅谈RocketMQ、Kafka、Pulsar的事务消息

ruoyuliu

腾讯 · 后台开发工程师 (已认证)

事务是一个程序执行单元,里面的所有操作要么全部执行成功,要么全部执行失败。RocketMQ、Kafka和Pulsar都是当今业界应用十分广泛的开源消息队列(MQ...

310

如何快速实现一个定时器

ruoyuliu

腾讯 · 后台开发工程师 (已认证)

下面我们谈谈定时器的数据结构。定时器通常与延迟队列密不可分,延时队列是什么?顾名思义它是一种带有延迟功能的消息队列。而延迟队列底层通常可以采用以下几种数据结构之...

3910

到底什么才是面向消息的分布式架构呢?看完之后我终于明白了

愿天堂没有BUG

·解耦。生产者把消息发送到消息队列中,这个过程就结束了。至于谁会从消息队列中取消息、消费消息,这个生产者是无须关心的。这样就实现了生产者和消费者的解耦。

6120

订单支付超时,自动关闭订单实现

冯文议

今天跟大家一起探讨一个场景:用户对商品下单,约定30分钟没支付,超时订单将被系统自动关闭。

7110

不背锅运维:消息队列概念、kafka入门、Kafka Golang客户端库

不背锅运维

消息队列是一种在应用程序之间进行通信的技术,允许将消息从一个应用程序发送到另一个应用程序,而无需明确的连接这些应用程序。消息队列中的消息被存储在一种称为队列的数...

7700

工作十年,在腾讯沉淀的高可用系统架构设计经验

腾讯云开发者

架构层面的异步解耦方式就是采用消息队列(比如常见的 Kafka),并且同时消息队列还有削峰的作用,这两者都可以提高系统的架构可用性:

34660

RabbitMQ的基本使用

前端小鑫同学

7930

kafka 笔记(一)

小石头

点对点模型:也叫消息队列模型。如果拿“民间版”的定义来说,那么系统 A 发送的消息只能被系统 B 接收,其他任何系统都不能读取 A 发送的消息。...

8810

一份完整的亿级消息中心架构方案

用户4283147

技术目标: 上行到消息队列api吞吐量10000条/秒,下发第三方平台1000条/秒(仅平台自身处理能力,第三方看第三方处理能力极限指标为准);保证消息中心10...

17330

进程间通信详解

tunsuy

进程间通信(IPC,InterProcess Communication)是指在不同进程之间传播或交换信息。 IPC的方式通常有管道(包括无名管道和命名管道)、...

10620

RabbitMq延迟队列

写一点笔记

在JUC中我们知道有延迟队列,在MQ中的延迟队列主要是用来存储延迟消息的,“延迟消息”就是指消息被发送以后,并不想让消费者立即拿到消息,而是等待特定的时间之后,...

12930

RabbitMq设置TTL

写一点笔记

设置消息的ttl有两种方式,一种是针对一条消息,第二种是针对队列中的所有消息。如果两种ttl都设置了,那么就选择tll小的执行。如果消费时间超过ttl,那么消息...

39820

rabbitmq消息发布mandatory参数

码农小麦

mandatory为true时,表示如果消息没有被正确路由,消息将退回消息的生产者,生产者需要添加监听器:

26120

Springboot整合adiveMQ Demo

暴躁的程序猿

非常入门的一个小整合demo 首先 没用过springboot的可以先看看这个 springboot介绍

11420

com.alibaba.fastjson.JSONException: illegal identifier : pos 3, json

时间静止不是简史

1.1K20

Task之消息队列示例

Taishan3721

https://pan.baidu.com/s/1CskUTsGYrTyVAJmZ4JEyNQ

23020

C++编程经验(10):无锁编程其实没那么玄乎

看、未来

曾经有个人,问我对无锁队列的实现是怎么想的。我想了一会儿,还是纳闷儿,无锁,也能做消息队列吗?然后他让我回去好好查查。没错,他就是面试官。

17410

RabbitMQ入门之HelloWorld

兮动人

16220

UNIX(多线程):05---创建多个线程、数据共享问题分析及案例

用户3479834

24530

PHP-Beanstalkd消息队列 延迟队列的搭建使用

sinnoo

41310

扫码关注腾讯云开发者

领取腾讯云代金券