rocketMQ(三) springboot整合rocketMQ
1:基础知识梳理 Message对象 topic: 主题名称 tag: 标签，用于过滤 key: 消息唯一标示，可以是业务字段组合 body: 消息体,字节数组 注意 发送消息到 ...
原文：RocketMQ
应用场景 主要作用解耦 滑峰填谷 异构系统的整合，这个问题比较容易理解，在原阿里SOA ESB比较火的年代，很多异构系统需要进行互联互通。 应用和应用之间的松耦合，这个在阿里巴巴内部很多的同步链路到异步链路里面，使用的非常多。 事件驱动机制和复杂事件架构模型里面的Backbone，底层的机制可以通过MQ来玩转。 数据复制通道，这个有很多比较典型的应用场景，比如模拟MySQL的binlog解析，将 ...
2018-08-01 16:18 0 919 推荐指数：
相关推荐
RocketMQ之七：RocketMQ管理与监控
前言 首先提出我们的监控诉求，出现如下情况时，希望能够及时接收到系统告警通知： RocketMQ 服务宕机 RocketMQ 消费者下线 RocketMQ 消息出现长时间或者大量堆积 本文将通过修改 rocketmq-console源码的方式，增加 ...
阿里rocketmq与自建rocketmq
一、搭环境 阿里rocketmq不用搭建， https://help.aliyun.com/document_detail/34411.html?spm=a2c4g.11186623.6.546.1787650eShM7ho 开源rocketmq（window+rocketmq ...
RocketMQ之一：RocketMQ整体介绍
常用MQ介绍及对比--《MQ详解及四大MQ比较》 RocketMQ环境搭建--《RocketMQ之三：RocketMQ集群环境搭建》 RocketMQ物理部署结构 RocketMQ的消息存储--《RocketMQ之六：RocketMQ消息存储》 RocketMQ各角色基本数 ...
rocketMQ 的 msgId
producer 在发送消息的时候，会生成一个 "唯一" 的 msgId，broker 会为这个 msgId 创建哈希索引 UNIQ_KEY 由客户端生成 msgId 由 前缀 + ...
RocketMq（一）初识
消息中间件基本上是互联网公司必用的一个中间件，为什么要使用MQ，当然是因为能给我们的系统带来很多好处。 消息队列简单来说是一种先进先出的数据结构，先简单认识下。 一、应用场景 消息中间件主要应用 ...
RocketMQ 零拷贝
一、零拷贝原理：Consumer 消费消息过程，使用了零拷贝，零拷贝包含以下两种方式： 1、使用 mmap + write 方式 （RocketMQ选择的方式：因为有小块数据传输的需求，效果会比 sendfile 更好） 优点：即使频繁调用，使用小块文件传输，效率也很高； 缺点：不能很好 ...
rocketmq 问题
1. 收不到消息-consumerOffset.json 信息错位 这种情况一般是，手动删除了store/commitlog目录里的数据等非常规手段造成了consumerOffset.json中记录的还是原来的信息，导致consumer收不到消息。 rocketmq的broker，一个消息主题 ...