1. 阿里云>
  2. 云栖社区>
  3. 主题地图>
  4. R>
  5. rocketmq prepare消息

当前主题:rocketmq prepare消息

rocketmq prepare消息相关的博客

查看更多 写博客

2019java开发面试问答合集(附答案)

10G整数文件中寻找中位数或者第K大数 采用基于字节的桶排序将数字分到不同的桶中,比如找到第k大数,则先找出每个桶中的第k大数,在比较。 整形是4byte,有32位,先按高八位建255个桶 如果内存只有2g,则每次读取2g的数据遍历放到255个桶中,并统计2

阅读全文

源码分析 RocketMQ DLedger 多副本即主从切换实现原理

DLedger 基于 raft 协议,故天然支持主从切换,即主节点(Leader)发生故障,会重新触发选主,在集群内再选举出新的主节点。 RocketMQ 中主从同步,从节点不仅会从主节点同步数据,也会同步元数据,包含 topic 路由信息、消费进度、延迟队

阅读全文

分布式事务解决方案,中间件 Seata 的设计原理详解

作者:张乘辉 前言 在微服务架构体系下,我们可以按照业务模块分层设计,单独部署,减轻了服务部署压力,也解耦了业务的耦合,避免了应用逐渐变成一个庞然怪物,从而可以轻松扩展,在某些服务出现故障时也不会影响其它服务的正常运行。总之,微服务在业务的高速发展中带给我们

阅读全文

RocketMQ与MYSQL事务消息整合

1、基础理论知识篇“两阶段提交”如果你了解可以跳过这段,当然如果你想深入了解你可以购买相关书籍或去搜索相关资料阅读   两阶段提交分为 正常提交和异常提交或异常回滚 上面是正常提交的示意图,协调者发起预提交请求,参与者回复成功之后协调者再次发起commit请

阅读全文

开发者说 | 分布式事务中间件 Seata 的设计原理

导读 微服务架构体系下,我们可以按照业务模块分层设计,单独部署,减轻了服务部署压力,也解耦了业务的耦合,避免了应用逐渐变成一个庞然怪物,从而可以轻松扩展,在某些服务出现故障时也不会影响其它服务的正常运行。总之,微服务在业务的高速发展中带给我们越来越多的优势,

阅读全文

Jstorm最佳实践

在拓扑提交过程中,不能实例化没有实现序列化接口的对象。可以通过传递参数的方式,在bolt的prepare中实例化 推荐一个worker运行2个task 减少拓扑层数,随着拓扑层数的增加,系统吞吐率下降,同时CPU利用率一直在上升,网络带宽未达到极限; 最好设

阅读全文

RocketMQ源码分析之RocketMQ事务消息实现原理上篇(二阶段提交)

在阅读本文前,若您对RocketMQ技术感兴趣,请加入 RocketMQ技术交流群 根据上文的描述,发送事务消息的入口为: TransactionMQProducer#sendMessageInTransaction: public TransactionS

阅读全文

RocketMQ源码分析之RocketMQ事务消息实现原下篇(事务提交或回滚)

若您对RocketMQ技术感兴趣,请加入 RocketMQ技术交流群 本文将重点分析RocketMQ Broker如何处理事务消息提交、回滚命令,根据前面的介绍,其入口EndTransactionProcessor#processRequest: Opera

阅读全文