加载中
rocketmq 消费重试测试

非顺序消息,默认重试16次看日志 SendResult [sendStatus=SEND_OK, msgId=C0A8023C5C746D06D69C74F6ACA00000, offsetMsgId=null, messageQueue=MessageQueue [topic=test-transaction3, brok...

2018/08/23 17:13
788
rocketmq autoCreateTopicEnable

autoCreateTopicEnable=true;默认。当topic不存在时,会默认创建。线上一般是false。 测试环境测试autoCreateTopicEnable=true 普通消息可以。 事物消息不行......

2018/08/17 17:48
285
rocketmq springboot

package com.test.mq; import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.client.producer.TransactionMQProducer; import org.apache.rocketmq.common.m...

2018/08/17 15:05
158
rocketmq 事物消息压测

同步master,同步刷盘 。broker8G [root@dev-mysql-16-103 ~]# java -cp rocketmq-example.jar org.apache.rocketmq.example.benchmark.TransactionProducer 1 20 true true Send TPS: 438 ...

2018/08/16 17:53
80
rocketmq 主从高可用测试

rocketmq 主从高可用测试 SYNC_MASTER SYNC_FLUSH 1.场景一:slave停掉 普通消息: 生产者发送消息:返回内容 SendResult [sendStatus=SLAVE_NOT_AVAILABLE, msgId=C0A8023C387418B4AAC25093...

2018/08/16 15:36
94
rocketmq 主从同步,主从替换问题分析

rocketmq 主从同步,主从替换问题分析 borker put消息: org.apache.rocketmq.store.CommitLog.putMessage(MessageExtBrokerInner) public PutMessageResult putMessage(final MessageExtBro...

2018/08/15 11:52
197
源码分析RocketMQ刷盘机制

刷盘机制支持同步刷盘和异步刷盘。为了了解其具体事项,我们以Commitlog的存储为例来说明RocketMQ是如何进行磁盘读写。 Comitlog#putMessage 首先,主要是将消息写入到MappedFile,内存映射文...

2018/08/15 10:59
81
天池中间件大赛——单机百万消息队列存储分享(作者:我的 96 年表弟)

这次天池中间件性能大赛初赛和复赛的成绩都正好是第五名,本次整理了复赛《单机百万消息队列的存储设计》的思路方案分享给大家,实现方案上也是决赛队伍中相对比较特别的。 赛题回顾 实现一个...

2018/08/15 10:00
79
事物解决方案

1.持久化mq消息(可持久化到本地,分布式存储) 2.执行本地事物 3.发送mq消息(发送成功删除持久化mq消息) 4.如果执行完2突然断电。则有定时任务定时扫描持久化mq消息发送 伪代码: 1.storeM...

2018/05/22 10:26
14
kafka精确一次投递和事务消息学习整理

概述 今年6月发布的kafka 0.11.0.0包含两个比较大的特性,exactly once delivery和transactional transactional messaging。之前一直对事务这块比较感兴趣,所以抽空详细学习了一下,感觉收获...

2018/05/22 09:48
3.8K
Kafka事务简介

说明:本文翻译Confluent官网,原文地址: https://www.confluent.io/blog/transactions-apache-kafka/ 在之前的博客文章(见尾部链接)中,我们介绍了ApacheKafka的exactly once语义,介绍了...

2018/05/22 09:46
46
Kafka设计解析(八)- Kafka事务机制与Exactly Once语义实现原理

写在前面的话 本文所有Kafka原理性的描述除特殊说明外均基于Kafka 1.0.0版本。 为什么要提供事务机制 Kafka事务机制的实现主要是为了支持 Exactly Once即正好一次语义 操作的原子性 有状态操...

2018/05/22 09:39
59
Spring Boot 中使用@KafkaListener批量接收消息ack

之前介绍了如何在SpringBoot中集成Kafka,但是默认情况下,@KafkaListener都是一条一条消费,如果想要一次消费一个批量的话,我们都知道,在kafka原生的API可以通过poll(num)来获取一次获取n...

2018/05/14 11:55
1K
学习Spring Boot:(二十六)使用 RabbitMQ 消息队列(消息确认ack,rpc)

正文 我这里测试都是使用的是 topic 交换器,Spring Boot 2.0.0, jdk 1.8 配置 Spring Boot 版本 2.0.0 在 pom.xml 文件中引入 AMQP 的依赖   1 2 3 4   <dependency> <groupId>org.spri...

2018/05/14 10:37
1K
《RocketMq》一、网络传输篇

你是否想知道一个分布式系统的网络传输解决方案,那你可以学习下RocketMQ的网络传输原理,从RocketMQ的Remoting网络处理部分,可以学习到如何进行高效的网络传输,这些思想可以应用到不同的业...

2018/05/13 21:15
50
RabbitMQ之RPC实现

什么是RPC? RPC是指远程过程调用,也就是说两台服务器A,B,一个应用部署在A服务器上,想要调用B服务器上应用提供的函数/方法,由于不在一个内存空间,不能直接调用,需要通过网络来表达调用...

2018/05/13 20:34
76
【RabbitMQ】6、rabbitmq生产者的消息确认

通过Publisher Confirms and Returns机制,生产者可以判断消息是否发送到了exchange及queue,而通过消费者确认机制,Rabbitmq可以决定是否重发消息给消费者,以保证消息被处理。 1.什么是Pub...

2018/05/13 20:25
558
RabbitMQ的transaction、confirm、ack三个概念的解释,kafka ack

在使用RabbitMQ的过程中,肯定会遇到这样的几个概念:transaction、confirm、ack。本文介绍一下这几个概念,以及他们之间的关系。 RabbitMQ是采用的AMQP协议,AMQP协议定义了”确认”(ackno...

2018/05/13 20:23
337
ActiveMQ RabbitMQ KafKa对比

前言: ActiveMQ和 RabbitMq 以及Kafka在之前的项目中都有陆续使用过,当然对于三者没有进行过具体的对比,以下摘抄了一些网上关于这三者的对比情况,我自己看过之后感觉还 是可以的,比较清...

2018/05/11 16:29
369
Spring Boot与RabbitMQ结合实现延迟队列的示例

背景 何为延迟队列? 顾名思义,延迟队列就是进入该队列的消息会被延迟消费的队列。而一般的队列,消息一旦入队了之后就会被消费者马上消费。 场景一:在订单系统中,一个用户下单之后通常有...

2018/05/11 15:29
670

没有更多内容

加载失败,请刷新页面

返回顶部
顶部