Rocketmq 源码-00-为什么学习源码
原因
其实接触 mq 已经多年了,但是一直停留在用的表面。
比如原理是什么?
两次 rpc + Broker 持久化 + 服务发现
如何保证不丢消息
如何提升性能
如何实现顺序消息?事务消息?
预测未来最好的方式
预测未来最好的方式就是去创造它。
无论是 active mq、kafka、pulsar。所有的...
2022-03-18 13:01:55 |
Apache
Rocketmq-ONS spring 整合
spring 版本整合
显示文件信息
tree /f
文件目录如下
└─src
├─main
│ ├─java
│ │ └─com
│ │ └─github
│ │ └─houbb
│ │ └─spring
│ │ C...
2022-03-18 13:01:55 |
Apache
Rocketmq-ONS 入门案例
Message ONS
maven 依赖
<dependency>
<groupId>com.aliyun.openservices</groupId>
<artifactId>ons-client</artifactId>
<version>1.8.0.Final</version&g...
2022-03-18 13:01:55 |
Apache
Rocketmq-03-java hello world 入门案例
从零手写实现 mq
rocketmq java 入门案例
整体结构
|____src
| |____main
| | |____java
| | | |____com
| | | | |____ryo
| | | | | |____rocket
| | | | | | |____demo
| | | | | | | |____common
| | | | | | | | |__...
2022-03-18 13:01:55 |
Apache
Rocketmq-02-mac/linux 安装笔记
从零手写实现 mq
Quick Start
quick start
需要
64位操作系统,最好是Linux/Unix/Mac;
64位JDK 1.6+;
Maven 3.x
Git
Screen
JDK
houbinbindeMacBook-Pro:aliyun-ons-client-java houbinbin$ java -version
java version ...
2022-03-18 13:01:55 |
Apache
Rocketmq-01-入门介绍
Message Queue
消息队列(Message Queue,简称 MQ)是阿里巴巴集团中间件技术部自主研发的专业消息中间件。
产品基于高可用分布式集群技术,提供消息发布订阅、消息轨迹查询、定时(延时)消息、资源统计、监控报警等一系列消息云服务,是企业级互联网架构的核心产品。
为分布式应用系统提供异步解耦、削峰填谷的能力,同时具备海量消息堆积、高吞吐、可靠重试等互联网应用所需的特性...
2022-03-18 13:01:55 |
Apache
RocketMQ-12-api 消费者接口文档
DefaultPullConsumer
类简介
DefaultMQPullConsumer extends ClientConfig implements MQPullConsumer
DefaultMQPullConsumer主动的从Broker拉取消息,主动权由应用控制,可以实现批量的消费消息。Pull方式取消息的过程需要用户自己写,首先通过打算消...
2022-03-18 13:01:55 |
MQ
RocketMQ-11-api 生产者接口文档
DefaultMQProducer
类简介
public class DefaultMQProducer
extends ClientConfig
implements MQProducer
DefaultMQProducer类是应用用来投递消息的入口,开箱即用,可通过无参构造方法快速创建一个生产者。主要负责消息的发送,支持同步/异步/oneway的发送方式,这些发送方式均支...
2022-03-18 13:01:55 |
MQ