原文:RocketMQ学习分享

消息队列的流派 什么是 MQ Message Queue MQ ,消息队列中间件。很多人都说:MQ 通过将消息的发送和接收分离来实现应用程序的异步和解偶,这个给人的直觉是 MQ 是异步的,用来解耦的,但是这个只是 MQ 的效果而不是目的。MQ 真正的目的是为了通讯,屏蔽底层复杂的通讯协议,定义了一套应用层的 更加简单的通讯协议。一个分布式系统中两个模块之间通讯要么是 HTTP,要么是自己开发的 T ...

2019-02-28 18:42 1 1990 推荐指数:

查看详情

rocketmq学习(一) rocketmq介绍与安装

1.消息队列介绍   消息队列本质上来说是一个符合先进先出原则的单向队列:一方发送消息并存入消息队列尾部(生产者投递消息),一方从消息队列的头部取出消息(消费者消费消息)。但对于一个成熟可靠的消息队 ...

Fri Sep 20 06:05:00 CST 2019 0 1214
rocketmq学习笔记】rocketmq入门学习

基本介绍 rocketmq是阿里巴巴团队使用java语言开发的一款基于发布订阅模型的分布式消息队列中间件,是一款低延迟,高可用,拥有海量消息堆积能力和灵活拓展性的消息队列。 特点 可以实现集群无单点故障问题,节点高可用,水平可扩展; 支持消息存储,写入低延迟,支持实时消息查询 ...

Tue Feb 16 20:37:00 CST 2021 0 305
RocketMQ之NameServer学习笔记

org.apache.rocketmq.namesrv.NamesrvController NameserController,NameServer的核心控制类。 1.1 NamesrvConfig NamesrvConfig,主要指定nameserver的相关配置目录属性 ...

Sun Apr 28 15:45:00 CST 2019 0 1223
RocketMQ简单学习和使用

RocketMQ发送消息的三种方式: 同步发送(sync) 在消息完全发送完成之后才返回结果,此方式存在需要同步等待发送结果的时间代价。具有内部重试机制,即在主动声明本次消息发送失败之前,内部实现将重试一定次数,默认为2次。 rocketMQTemplate.syncSend ...

Thu Jan 13 00:58:00 CST 2022 0 1000
RocketMQ学习:Broker

Broker Broker充当着消息中转角色,负责存储消息、转发消息。 Broker在 Rocketmq系统中负责接收并存储从生产者发送来的消息,同时为消费者的拉取请求作准备。Broker同时也存储着消息相关的元数据,包括消费者组消费进度偏移 offset、主题、队列 ...

Tue Dec 07 23:48:00 CST 2021 0 999
RocketMQ学习笔记(15)----RocketMQ的消息模式

在前面学习ActiveMQ时,看到ActiveMQ可以是队列消息模式,也可以是订阅发布模式。   同样,在RocketMQ中,也存在两种消息模式,即是集群消费模式和广播消费模式。 1. 集群消费模式   跟AciiveMQ一样,当存在多个消费者时,消息通过一定负载均衡策略,将消息分发到多个 ...

Thu Nov 15 02:02:00 CST 2018 0 1651
RocketMQ学习笔记(8)----RocketMQ的Producer API简介

RocketMQ中提供了三种发送消息的模式:   1.NormalProducer(普通)   2.OrderProducer(顺序)   3.TransactionProducer(事务) 下面来介绍一下producer中的各个API的使用:   1. producerGroup ...

Wed Nov 14 04:58:00 CST 2018 0 1993
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM