1. Rocketmq消费模型(实时性) 常见的数据同步方式有这几种： push：producer发送消息后，broker马上把消息投递给consumer。这种方式好在实时性比较高，但是会增加broker的负载；而且消费端能力不同，如果push推送过快，消费端会出现很多问题。 pull：produc ...
分类：
其他好文 时间：
2019-05-19 19:23:56
阅读次数：
218
安装zip和mavenyum install -y unzip zip wget http://repos.fedorapeople.org/repos/dchen/apache-maven/epel-apache-maven.repo -O /etc/yum.repos.d/epel-apache ...
分类：
其他好文 时间：
2019-05-18 00:26:41
阅读次数：
321
RocketMQ源码解析 消息消费 1.消费者相关类 2.消费者的启动 3.消息的拉取 4.消费者的负载均衡 5.消息的消费 6.消费进度管理 看了很多遍的代码，还是决定动手把记录下来，梳理一下整体结构和实现细节，给大家一个参考，写的不好的地方请多多指教 RocketMQ中消息的消费分为2种方式，一 ...
分类：
其他好文 时间：
2019-05-04 09:52:58
阅读次数：
155
最近在使用rocketmq 发送消息，出现了No route info of this topic 异常，但奇怪的是我的其它的服务都可以成功发送，唯有crs服务不能成功发送，在网上搜索的解决方式基本上都是： ocketmq运行时提示 No route info of this topic 异常产生的 ...
分类：
其他好文 时间：
2019-04-29 15:54:12
阅读次数：
199
小结： 1、 https://mp.weixin.qq.com/s/v6NM3UgX-qTI7yO1QPCJrw 滴滴出行基于RocketMQ构建企业级消息队列服务的实践 原创： 江海挺 阿里巴巴中间件 2018-11-01 ...
分类：
其他好文 时间：
2019-04-27 22:52:00
阅读次数：
260
原文链接：http://www.cnblogs.com/xiaodf/p/5075167.html 简介 官方简介： 能够保证严格的消息顺序 提供丰富的消息拉取模式 高效的订阅者水平扩展能力 实时的消息订阅机制 亿级消息堆积能力 二、网络架构 三、特性 1. nameserver 相对来说，name ...
分类：
其他好文 时间：
2019-04-27 13:13:44
阅读次数：
118
[TOC] 一、引言 本文只站在一个java程序员角度上，去了解Rocketmq和具体使用，不讲搭建，这是运维人的事情。详细官方文档参考https://helpcdn.aliyun.com/document_detail/29543.html 二、介绍 （1）RocketMQ 不遵循任何规范，但是参 ...
分类：
其他好文 时间：
2019-04-26 16:40:01
阅读次数：
150
由于一些原因，我需要RocketMQ消费的时候，一批拉400条，一批处理400条。设置如下： 为了简单验证是否正确，消费如下： 直接通过打印msgs.size()观察情况即可。 现象 实验的topic里面的消息数量很多很多，但是启动消费端，消费端的日志如下： 奇怪啦，明明已经进行了修改 为什么还是每 ...
分类：
其他好文 时间：
2019-04-20 00:18:47
阅读次数：
166
原文:使用内存映射开发高性能进程间消息通信组件一、背景 项目开发中免不了各模块或系统之间进行消息通信，目前热门的消息中间件有Redis、RabbitMQ、Kafka、RocketMQ等等。 以上几种组件中Redis在消息队列方面表现还可以，但是如果涉及发布订阅功能，就不行了，最近项目就使用了redi... ...
分类：
系统相关 时间：
2019-04-15 23:03:30
阅读次数：
198
RabbitMQ即一个消息队列，主要是用来实现应用程序的异步和解耦，同时也能起到消息缓冲，消息分发的作用。消息中间件在互联网公司的使用中越来越多，刚才还看到新闻阿里将RocketMQ捐献给了Apache，当然了今天的主角还是讲RabbitMQ。消息中间件最主要的作用是解耦，中间件最标准的用法是生产者生产消息传送到队列，消费者从队列中拿取消息并处理，生产者不用关心是谁来消费，消费者不用关心谁在生产消
分类：
编程语言 时间：
2019-04-11 19:50:09
阅读次数：
192
