xiaoming728

xiaoming728

RocketMq技术

RocketMQ消息幂等的通用解决方案

RocketMQ消息幂等的通用解决方案

来源:微信公众账号-架构师 日期:2月14日 链接:
31
0
0
2023-12-11
RocketMQ-延时消息实现原理分析

RocketMQ-延时消息实现原理分析

来源:CSDN-hosaos 链接:https://blog.csdn.net/hosaos/article/details/90577732
11
0
0
2023-12-11
DefaultMQPushConsumer使用与流程原理分析

DefaultMQPushConsumer使用与流程原理分析

DefaultMQPushConsumer使用示例 package com.swk.springboot.rocketmq; import java.util.List; import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer
18
0
0
2023-12-11
Spring Boot整合RocketMQ之事务消息

Spring Boot整合RocketMQ之事务消息

上次简单的了解了一下在Spring Boot下通过使用rocketmq-spring-boot-starter进行普通消息的发送、接收以及使用集群模式来模拟实现广播模式,文章链接。今天来学习一下RocketMQ事务消息的发送。 RocketMQ的事务消息分为3种状态,分别是提交状态、回滚状态、中间状
36
0
0
2023-12-11
RocketMQ如何保证消息的可靠性

RocketMQ如何保证消息的可靠性

导读:消息的发送方式有哪几种?存储消息的可靠性面临哪些挑战?消费消息的确认机制是怎样的?本文通过分析消息流转的整个过程,从消息发送、消息存储和消息消费三个阶段介绍RocketMQ是如何保证消息的可靠性的。 分布式系统中一个重要的前提假设是所有的网络传输都是不可靠的,在网络传输不可靠的情况下,保证消息
18
0
0
2023-12-11
RocketMQ中的Consumer

RocketMQ中的Consumer

MQ中有关Consumer简介 上述就是MQ中有关Consumer的类图,下面来介绍一下每个类: MQConsumer:Consumer公共的接口,常用的方法如下 1、MQAdmin:底层类</
15
0
0
2023-12-11
RocketMQ控制台使用文档

RocketMQ控制台使用文档

运维页面 你可以修改这个服务使用的namesrv的地址 你可以修改这个服务是否使用VIPChannel(如果你的mq server版本小于3.5.8,请设置不使用) 驾驶舱 查看broker的消息量(总量/5分钟图) 查看单一主题的消息量(总量/趋势图) 集群页面 查看集群的分布情况 cluster
15
0
0
2023-12-11
RocketMQ消息队列系统架构

RocketMQ消息队列系统架构

(1)RocketMQ整体架构 如今阿里的开源项目越来越多,比如消息中间件领域的RocketMQ,分布式事务领域的Fescar,熔断限流领域的Sentinal,微服务领域的Dubbo、Nacos等等。 而现在越来越多的中小型公司也开始使用阿里开源的各种技术到自己的系统,因此有必要对阿里开源的一些技术
24
0
0
2023-12-11
RocketMQ 解决:There is insufficient memory for the Java Runtime Environment to continue

RocketMQ 解决:There is insufficient memory for the Java Runtime Environment to continue

1.场景描述 linux 安装 rocketmq 启动 mqnameserver、mqbroker 以及运行测试类生产者时报错。 运行命令为: nohup sh bin/mqnamesrv & 或者 nohup sh bin/mqbroker -n localhost:9876 & 或者 s
11
0
0
2023-12-11