李锋镝的博客 - LiFengdi.Com

  • 首页
  • 时间轴
  • 留言
  • 左邻右舍
  • 我的日常
  • 关于我
RocketMQ
技术

RocketMQ入门级教程

前言 RocketMQ是阿里巴巴旗下一款开源的MQ框架,经历过双十一考验、Java编程语言实现,有非常好完整生态系统。RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件,支持事务消息、顺序消息、批量消息、定时消息、消息回溯等,总之就是葛大爷的一句话 核心概念 NameServer:可以理解为是一个注册中心,主要是用来保存topic路由信息,管理Broker。在NameServer的集群中,NameServer与NameServer之间是没有任何通信的。 Broker:核心的一个角色,主要是用来保存…

2022年8月16日 0条评论 825点热度 0人点赞 阅读全文
技术

RocketMQ的push消费方式实现详解

MQ消费方式 消费方式就是指消费者如何从MQ中获取到消息,分为两种方式,push(推方式)和pull(拉方式)。 1、push(推方式) push,顾名思义,就是推的意思。就是当MQ收到生产者产生的消息的时候,会主动将消息推送到消费者进行消费,这种模式就叫push,也就是MQ将消息推给到消费者的意思。 push模式 push这种模式的好处就是响应快,消息的实时性比较高,一旦消息MQ收到消息,那么就能立马将消息推送给消费者,消费者也就能立马收到消息进行消费。 但是这种push的模式,有个缺点就是一旦消息量比较大时,对…

2022年8月9日 3条评论 887点热度 0人点赞 阅读全文
原创

使用RocketMQ时,服务启动过程中,Consumer在服务未启动时消费消息问题处理

背景 我们使用RocketMQ时,一般Consumer启动都是使用的@PostConstruct注解。(@PostConstruct:用于在执行任何初始化时执行依赖注入后需要执行的方法。),或者使用bean的方式配置。 配置如下: 生产者配置 在配置类中配置所有生产者,在业务中注入使用,将生产者的启动和销毁绑定到 Bean 的初始化和销毁上: @Configuration public class MQProducerConfig { // 第一个生产者 @Bean(initMethod = "start…

2022年6月23日 0条评论 1897点热度 0人点赞 阅读全文
技术

MQ消费端遇到瓶颈该怎么办?

1、面试场景与面试技巧 金三银四招聘季,一位粉丝朋友最近在蚂蚁金服第二轮面试时遇到这样一个问题:如果MQ消费遇到瓶颈时该如何处理?。 横向扩容,相比很多读者与我这位朋友一样会脱口而出,面试官显然不会满意这样的回答,然后追问道:横向扩容是堆机器,还有没有其他办法呢? 在面试过程中,个人建议大家在听到问题后稍作思考,不要立马给出太直接的答案,而是应该与面试官进行探讨,一方面可更深刻的理解面试官的出题初衷,同时可以给自己梳理一下思路。 消费端遇到瓶颈,这是一个结果,但引起这个结果的原因是什么呢?在没有弄清楚原因之前谈优化…

2021年3月19日 0条评论 13709点热度 0人点赞 阅读全文
网站统计
  • 文章总数:304 篇
  • 评论总数:456 篇
  • 标签数量:226 个
  • 最后更新:2023年01月29日
  • 建站日期:2016年6月6日

雨打梨花深闭门,忘了青春,误了青春。
赏心乐事共谁论?花下销魂,月下销魂。
愁聚眉峰尽日颦,千点啼痕,万点啼痕。
晓看天色暮看云,行也思君,坐也思君。

最新 热点 随机
最新 热点 随机
开工啦~ 今晚,回家过年! 图数据库选型:Neo4j、Janus、HugeGraph Redisson分布式锁的watch dog自动续期机制 哀莫大于心死 你好,2023
居家办公了~C# 11 的这个新特性,我愿称之最强!看病难~取药难~~RocketMQ的push消费方式实现详解国庆节过的也很累~~开工啦~
分布式、多线程、高并发概念与区别 PHP版本怎么更新啊…… CPU飙高,系统性能问题如何排查? Docker打包部署示例 Spring中@NotNull、@NotBlank、@NotEmpty的区别 一线技术人的成长思考总结
最近评论
dd 发布于 2 小时前(02月06日) 请问idea2022 myBatiscodehelperpro 3.1.5激活码?
Frankie Bridge 发布于 9 小时前(02月06日) I really like your writing style..Its so easily un...
Frankie Bridge 发布于 2 天前(02月05日) Hi! Just wondering- what template did you use for ...
lyshark 发布于 3 周前(01月18日) 已添加贵站,申请交换友链:) name: LyShark - 孤风洗剑 link: https:...
poetry 发布于 1 个月前(01月05日) 感谢分享
友情链接
  • 志文工作室
  • 临窗旋墨
  • 旧时繁华
  • 城南旧事
  • 强仔博客
  • 林三随笔
  • 徐艺扬的博客
  • 云辰博客
  • 韩小韩博客
  • 知向前端
  • 阿誉的博客
  • 林羽凡
  • 情侣头像
  • 周良博客
  • 马内
  • 哥斯拉
  • LyShark - 孤风洗剑
标签云

Your browser doesn't support the HTML5 CANVAS tag.

  • K8s
  • 程序员
  • SQL
  • IDEA
  • 高并发
  • Git
  • 分布式
  • MQ
  • 架构
  • 数据库
  • Linux
  • SpringBoot
  • UML
  • 重构
  • Visual Studio
  • hbase
  • 妹妹的画
  • Spring Cloud
  • 程序人生
  • 微服务
  • Redis
  • 领域模型
  • 博客
  • Zookeeper
  • 面试
  • 面向对象
  • Excel
  • RocketMQ
  • MySQL
  • SEO
  • 文档
  • JVM
  • Xshell
  • 搜索
  • Python
  • 日常
  • docker
  • 多线程
  • Eclipse
  • Spring Cloud Gateway
  • JAVA
  • 锁
  • 分布式锁
  • Spring
  • https
  • 设计模式
  • ElasticSearch
  • 散文
  • 文学
  • 教程

COPYRIGHT © 2022 lifengdi.com. ALL RIGHTS RESERVED.

Theme Kratos Made By Seaton Jiang

豫ICP备16004681号-2