• 西安小伙伴们,躁起来...|Apache RocketMQ开发者沙龙
    具有多年分布式消息系统等中间件架构设计及研发经验,目前负责RocketMQ的研发以及社区生态建设。基于RocketMQ的调度引擎RocketMQ Runtime设计与实现。基于RocketMQ+RocketMQ Connecotr的相关异构系统整合和扩展RocketMQ Connect生态的现状及未来。《Apache RocketMQ在即时通讯的应用实践》邱博文,Apache RocketMQ 西安社区联合发起人内容简介:众所周知IM系统对并发和消息吞吐都有严格的要求,而消息中间件是个很重要的基础设施。本次分享将结合海尔自身业务特点,从消息中间件的选型及实践两个方面介绍RocketMQ的落地。
  • 技术直播第20期:揭秘RocketMQ在Kubernetes平台管理工具—RocketMQ Operator
    分享题目:揭秘RocketMQ在Kubernetes平台管理工具—RocketMQ Operator直播方式:钉钉群直播,群号分享时间:2019-10-16(本周三) 20:00-21:30分享讲师:刘睿内容简介:介绍Operator相关概念讲解Operator的在Kubernetes集群上的具体使用方法演示Operator的使用,包括RocketMQ集群的部署、扩容等讲师简介:本期分享讲师为刘睿,清华大学大数据国家工程实验室IoTDB团队成员,RocketMQ-Operator项目核心贡献者,感兴趣领域包括时序数据库、消息中间件、系统参数调优、云原生技术、AI+DevOps等温馨提示:RocketMQ-Operator地址请点击文末阅读原文。有兴趣观看直播的开发者建议先加入RocketMQ官方钉钉群,群号。打开钉钉 APP 在搜索中直接输入群号 ,点击“网络查找公开群组”。
  • 私有软件的消亡与开源软件的崛起
    随着RedHat,Elastic,MongoDB,Github,Pivotal,Greenplum等开源软件的成熟,整个软件行业也正在发生巨大的变化。然而今天,私有软件行业既是捕食者又是猎物,因为另一种软件开发、分销、商业化的模式已经趋于成熟。2018年:开源软件年 让我们回顾一下今年的几个事实,有些人指出今年甚至可以称为开源软件年。RedHat是第一家在开源软件基础上成功建立企业的公司,它持续蓬勃发展,市值超过200亿美元,目前收入接近30亿美元。对于这些软件工程师,需要一种新的开源许可证。(自由软件必定开源,开源软件未必自由,有些开源许可证对用户过于苛刻,它们就没有被列为自由软件。
  • Apache RocketMQ原理(7)——消息高可靠
    Apache RocketMQ broker服务端以组为单位提供服务的,拥有着一样的brokerName则认为是一个组。在Broker配置中,如果是有三个可选的brokerRole:ASYNC_MASTER、SYNC_MASTER、SLAVE。也就是说Master其实是分两种,决定其不同消息同步方式。ASYNC_MASTER是异步复制的方式,生存者写入消息到Master后无需等待消息复制到slave即可返回,消息的复制由旁路线程进行异步复制。相关源码如下:public boolean isSlaveOK { boolean result = this.connectionCount.get() > 0; result = result && ; return result;}殊途同归虽然看似两个完全不一样的同步策略,但实际上从实现上,在消息同步的实现上两者没有任何区别。
  • 社区活动 | Apache RocketMQ × Apache Kylin Meetup 深圳站
    9 月 7 日,Apache RocketMQ Meetup 即将走进深圳!本次 Meetup 由 Apache RocketMQ 与 Apache Kylin联合举办,邀请到来自阿里 、腾讯、平安云以及 Kyligence 等六位技术专家为大家呈现RocketMQ与Kylin的精彩应用案例与实践。《基于 RocketMQ Connect 构建全新数据流转处理平台》周波高级工程师个人简介:Apache RocketMQ 深圳社区联合发起人 & Contributor,RocketMQ Connect 项目核心贡献者,开源爱好者。《Kylin精确去重及在用户行为分析中的应用》史少锋Kyligence 首席架构师个人简介:Apache Kylin Committer & PMC;负责 Kyligence 业务技术方案,以及 Apache Kylin 社区发展。Apache Flink 及 Hudi活跃贡献者、布道者,Apache Kylin 的 Flink Cube Engine 作者。
  • 技术直播第19期:基于RocketMQ开源客户端的混合云实践与案例解析
    分享题目:基于RocketMQ开源客户端的混合云实践与案例解析直播方式:钉钉群直播,群号(21791227、21909963)分享时间:2019-08-28 (本周三) 20:00:00-21:30分享讲师:武文良内容简介:讲解Java开源客户端在混合云场景的使用方法;解读Java开源客户端 混合云、测试/线上一体化等使用场景;基于开源客户端的“电商秒杀系统" 混合云案例解析;讲师简介:本期分享讲师为武文良,中间件发烧友,RocketMQ北京社区联合发起人,社区布道师。专注于后端分布式领域,对分布式架构、中
  • Apache RocketMQ原理(6)——通信协议
    ApacheRocketMQ的通信协议其实并不是非常复杂,但是无论是官方的用户手册,还是网上的博客,并没有很清晰简单地把其中所有的内容和原理讲明白。无论是发送消息,拉取消息,还是发送心跳等所有的网络通讯层协议都使用一套一样的协议。响应码则在ResponseCode.java中。第0位标识是这次通信是request还是response,0标识request, 1 标识response。第1位标识是否是oneway请求,1标识oneway。应答方在处理oneway请求的时候,不会做出响应,请求方也无序等待应答方响应。常见的如存放一些broker/nameserver返回的一些异常信息,方便开发人员定位问题。
  • Apache RocketMQ原理(5)——客户端配置
    ApacheRocketMQ的客户端和服务端采取完全不一样的配置机制——客户端没有配置文件,所有的配置选项需要开发者使用对应的配置的setter进行设置。由于现在网上基本找不到一套较为完善的配置文档,今天来讲讲截止至RocketMQ 4.0,客户端已有的所有配置的含义。pollNameServerInterval*配置说明:轮询从NameServer获取路由信息的时间间隔默认值:30000,单位毫秒客户端依靠NameServer做服务发现,这个间隔决定了新服务上线/下线,客户端最长多久能探测得到。
  • Apache RocketMQ原理(4)——消息文件过期原理
    在上期文章《Apache RocketMQ原理——消息ACK机制及消费进度管理》中提过,所有的消费均是客户端发起Pull请求的,告诉消息的offset位置,broker去查询并返回。但消息既然一直没有删除,那RocketMQ怎么知道应该投递过的消息就不再投递?由于消费从哪里消费的决定权一直都是客户端决定,所以只要消息还在,就可以消费到,这使得RocketMQ可以支持其他传统消息中间件不支持的回溯消费。RocketMQ官方建议Linux下文件系统改为Ext4,对于文件删除操作,相比Ext3有非常明显的提升。但对于已存在的消费组,RocketMQ没有内置的实现,但有以下手段可以解决:1.自身的消费代码按照日期过滤,太老的消息直接过滤。
个人资料

品味RocketMQ设计哲学,分享全球社区趣闻,传播分布式软件深度好文。