写点什么

消息中间件

0 人感兴趣 · 62 次引用

  • 最新
  • 推荐
https://static001.geekbang.org/infoq/d5/d5d77a65c7165a52a3724e43168b8174.jpeg?x-oss-process=image/resize,w_416,h_234

全网首发,纯手打“RocketMQ 笔记”,帮你解决 95% 以上的问题!

消息队列 RocketMQ 是阿里巴巴集团基于高可用分布式集群技术,自主研发的云正式商用的专业消息中间件,既可为分布式应用系统提供异步解耦和削峰填谷的能力,同时也具备互联网应用所需的海量消息堆积、高吞吐、可靠重试等特性,是阿里巴巴双 11 使用的核心产品

https://static001.geekbang.org/infoq/67/67d81fa511e5e8ef95ebdf3937dc9c3d.png?x-oss-process=image/resize,w_416,h_234

SAP CRM 中间件里的 CSA 队列有什么用

用户头像
Jerry Wang5 月 23 日

我们有时候会在中间件的事务码SMQ2即Inbound队列查看器里观察到以CSA开头的队列:

https://static001.geekbang.org/infoq/60/600606f8f80af3bb325a52da407b409d.webp?x-oss-process=image/resize,w_416,h_234

高可用角度观察 RabbitMQ、Kafka、RocketMQ 各自的实现思路

用户头像
程序员小毕5 月 11 日

本文从高可用的角度观察一下 RabbitMQ、Kafka、RocketMQ,看看它们各自的实现思路。

罗美琪和春波特的故事...

rocketmq-spring经过6个多月的孵化,作为Apache RocketMQ子项目正式毕业,发布第一个Release版本2.0.1。这个项目把RocketMQ的客户端使用Spring Boot的方式进行了封装,可让用户通过简单的annotation和标准的Spring Messaging API编写代码进行消息发送和消费。

KubeVela 1.0 :开启可编程式应用平台的未来

如果你对云原生领域不太关注,可能对 KubeVela 还没有做过太深入的了解。别着急,本文就借着 v1.0 发布之际,为你详细的梳理一次 KubeVela 项目的发展脉络,解读它的核心思想和愿景,领悟这个正冉冉升起的云原生应用管理平台之星背后的“道之所在”。

AI 事件驱动场景 Serverless 实践

事件驱动是指事件在持续事务管理过程中,进行决策的一种策略。可以通过调动可用资源执行相关任务,从而解决不断出现的问题。通俗地说是当用户触发使用行为时对用户行为的响应。在 Serverless 场景下,事件驱动完美符合其设计初衷之一:按需付费。

基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台

本文将对 RocketMQ-Exporter 的设计实现做一个简单的介绍,读者可通过本文了解到 RocketMQ-Exporter 的实现过程,以及通过 RocketMQ-Exporter 来搭建自己的 RocketMQ 监控系统。

nsqlookupd:高性能消息中间件 NSQ 解析

​​摘要: 本篇将会结合源码介绍 nsqlookupd 的实现细节。

阿里的 RocketMQ 如何让双十一峰值之下 0 故障?

2020 年双十一交易峰值达到 58.3 W 笔/秒,消息中间件 RocketMQ 继续数年 0 故障丝般顺滑地完美支持了整个集团大促的各类业务平稳。

https://static001.geekbang.org/infoq/4c/4c4f2e4fdaf60109374892b8003e0b96.png?x-oss-process=image/resize,w_416,h_234

Kafka 又出问题了!

用户头像
冰河4 月 3 日

估计运维年前没有祭拜服务器,Nginx的问题修复了,Kafka又不行了。今天,本来想再睡会,结果,电话又响了。还是运营,“喂,冰河,到公司了吗?赶紧看看服务器吧,又出问题了“。“在路上了,运维那哥们儿还没上班吗”? “还在休假。。。”, 我:“。。。”

https://static001.geekbang.org/infoq/61/614f7b7fc65db396e5a49fa3797b0260.png?x-oss-process=image/resize,w_416,h_234

蚂蚁二面:MQ 消费端遇到瓶颈除了横向扩容外还有其他解决办法?

用户头像
中间件兴趣圈3 月 20 日

个人博客:https://www.codingw.net/ 在面试过程中遇到结论性提问如何应对,以及详细介绍RocketMQ消息积压的原理、如何排查。

https://static001.geekbang.org/infoq/93/937b9b1463b69b9e44f8868ae715c782.png?x-oss-process=image/resize,w_416,h_234

阿里新产 Java 后端面试最全总结!25 个专题 + 十万字面试总结,金三银四刷这一份就够了!

用户头像
程序员小毕3 月 12 日

小编分享的这份春招Java后端开发面试总结包含了JavaOOP、Java集合容器、Java异常、并发编程、Java反射、Java序列化、JVM、Redis、Spring MVC、MyBatis、MySQL数据库、消息中间件MQ、Dubbo、Linux、ZooKeeper、 分布式&数据结构与算法等25个专题技术点,都是小

https://static001.geekbang.org/infoq/3e/3ec1969309146aa1a07497fa168c9618.jpeg?x-oss-process=image/resize,w_416,h_234

事务消息应用场景、实现原理与项目实战 (附全部源码)

从应用场景出发,给出解决方案与实现原理讲解,并提供整套源码实现(源码已上传到github仓库)

Kafka 架构中 ZooKeeper 以怎样的形式存在?

用户头像
码农架构3 月 8 日

在基于 Kafka 的分布式消息队列中,ZooKeeper 的作用有 Broker 注册、Topic 注册、Producer 和 Consumer 负载均衡、维护 Partition 与 Consumer 的关系、记录消息消费的进度以及 Consumer 注册等。

Serverless 极致弹性解构在线游戏行业痛点

本文将通过剖析一个个具体的场景案例,以期望给相关的游戏开发同学带来共鸣,同时也希望能给非游戏行业的同学带来一些启发。

https://static001.geekbang.org/infoq/43/4340573248a58ab7ca98161499691669.png?x-oss-process=image/resize,w_416,h_234

理解 RocketMQ

用户头像
awen2 月 26 日

RocketMQ 是一个队列模型的消息中间件,具有高性能、高可靠、高实时、分布式的特点。它是一个采用 Java 语言开发的分布式的消息系统,由阿里巴巴团队开发,在 2016 年底贡献给 Apache,成为了后者 的一个顶级项目。本文是对Apache RocketMQ官网部分内容翻译。

在游戏运营行业,Serverless 如何解决数据采集分析痛点?

众所周知,游戏行业在当今的互联网行业中算是一棵常青树。在疫情之前的 2019 年,中国游戏市场营收规模约 2884.8 亿元,同比增长 17.1%。2020 年因为疫情,游戏行业更是突飞猛进。玩游戏本就是中国网民最普遍的娱乐方式之一,疫情期间更甚。

Kafka 生产者哪些重要的参数是我们需要注意的?

用户头像
码农架构2 月 5 日

在 KafkaProducer 中大部分的参数都有合理的默认值,一般不需要修改它们。不过了解这些参数可以让我们更合理地使用生产者客户端,其中还有一些重要的参数涉及程序的可用性和性能,如果能够熟练掌握它们,也可以让我们在编写相关的程序时能够更好地进行性能调

Kafka 在哪些场景下会造成重复消费或消息丢失?

用户头像
码农架构2 月 5 日

kafka消费者在消费的时候对于位移提交的具体时机的把握也很有讲究,有可能会造成重复消费和消息丢失的现象。

Kafka 消费者提交消费位移时提交的是当前消费到的最新消息的 offset 还是 offset+1?

用户头像
码农架构2 月 5 日

对于 Kafka 中的分区而言,它的每条消息都有唯一的 offset,用来表示消息在分区中对应的位置。对于消费者而言,它也有一个 offset 的概念,消费者使用 offset 来表示消费到分区中某个消息所在的位置。

怎么理解 Kafka 消费者与消费组之间的关系?

用户头像
码农架构1 月 29 日

与生产者对应的是消费者,应用程序可以通过 KafkaConsumer 来订阅主题,并从订阅的主题中拉取消息。不过在使用 KafkaConsumer 消费消息之前需要先了解消费者和消费组的概念,否则无法理解如何使用KafkaConsumer。

https://static001.geekbang.org/infoq/8a/8a8e468851118a9cd3f8f291e6f96c00.jpeg?x-oss-process=image/resize,w_416,h_234

图解分析:Kafka 生产者客户端工作原理

用户头像
码农架构1 月 27 日

消息在真正发往 Kafka 之前,有可能需要经历拦截器、序列化器和分区器等一系列的作用,前面已经做了一系列分析。那么在此之后又会发生什么呢?先看一下生产者客户端的整体架构,如下图所示。

https://static001.geekbang.org/infoq/59/59cb44fa5b33325ed38fc4e70ba04e18.jpeg?x-oss-process=image/resize,w_416,h_234

阿里首推 Java 微服务架构实战宝典开源,SpringBoot/Cloud+Docker+RabbitMQ 彻底玩转微服务!

用户头像
程序员小毕1 月 25 日

微服务架构的演进并非一蹴而就,过于保守或激进都不是解决之道。长期修行,苦练内功,或许才是微服务架构的前路方向。

https://static001.geekbang.org/infoq/09/0916b24754c97ebe9f6f3eb45dc7236e.jpeg?x-oss-process=image/resize,w_416,h_234

都在用 Kafka ! 消息队列序列化怎么处理?

用户头像
码农架构1 月 25 日

生产者需要用序列化器(Serializer)把对象转换成字节数组才能通过网络发送给Kafka。而在对侧,消费者需要用反序列化器(Deserializer)把从 Kafka 中收到的字节数组转换成相应的对象。

使用 Docker 部署 RabbitMQ 没有日志?添加这两条配置,轻松搞定

用户头像
AlwaysBeta1 月 23 日

使用 Docker 部署完 RabbitMQ 服务,到 /var/log/rabbitmq 目录下一看,空空如也,并没有日志文件生成。

如何开发一个完善的 Kafka 生产者客户端?

用户头像
码农架构1 月 22 日

Kafka 起初是 由 LinkedIn 公司采用 Scala 语言开发的一个多分区、多副本且基于 ZooKeeper 协调的分布式消息系统,现已被捐献给 Apache 基金会。目前 Kafka 已经定位为一个分布式流式处理平台,它以高吞吐、可持久化、可水平扩展、支持流数据处理等多种特性而

https://static001.geekbang.org/infoq/96/96e0564eb2397319d5fd9f3912039b30.jpeg?x-oss-process=image/resize,w_416,h_234

Pulsar vs Kafka,CTO 如何抉择?

用户头像
Apache Pulsar1 月 22 日

本文以三个实际使用场景为例,从 CTO 的视角出发,在技术等方面对比 Kafka 和 Pulsar。

Alibaba 开发十年,写出这本“MQ 技术手册”,看完我愣住了

消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能,成为异步RPC的主要手段之一。虽然说,目前状况是Kafka更为火热,但更为广泛的应该还属老牌的RabbtiMQ和Alibaba自主研发的RocketMQ。

消息中间件_消息中间件资料文章-InfoQ写作平台