一.基本概念Producer消息生产者，负责产生消息，一般由业务系统负责产生消息Consumer消息消费者，负责消费消息，一般是后台系统负责异步消费PushConsumerConsumer的一种，应用通常向Consumer对象注册一个Listener接口，一旦收到消息，Consumer对象立刻回调Listener接口方法Pull..
分类：
其他好文 时间：
2015-07-12 15:54:42
阅读次数：
174
1.rocketmq1)Maven环境a.下载apache-maven-3.3.3-bin.tar.gzb.解压tar-zxfapache-maven-3.3.3-bin.tar.gzc.加入环境变量MAVEN="/data/Application/apache-maven/bin"
JAVA_HOME="/usr/java/jdk1.7.0_45/"
exportPATH=$MAVEN:/usr/java/jdk1.7.0_45/bin/:/usr/local/mysql/bin/:..
分类：
其他好文 时间：
2015-07-12 15:53:54
阅读次数：
179
一.RocketMQ网络部署特点（1）NameServer是一个几乎无状态的节点，可集群部署，节点之间无任何信息同步（2）Broker部署相对复杂，Broker氛围Master与Slave，一个Master可以对应多个Slaver，但是一个Slaver只能对应一个Master，Master与Slaver的对应关系通过指定相同的BrokerNam..
分类：
其他好文 时间：
2015-07-12 15:53:52
阅读次数：
218
此篇博文主要会描述使用过程中遇到的各种问题以及从官网上收集到的需要注意的重点，后期会持续更新。1）RocketMQ故障之-在压力测试下无法启动在压力之下，MQ会堆积，如果堆积太多，会导致MQ同步offset的问题，需要清空：1.停止rocketmq：kill-9进程号2.删除/root下的/logs/rock..
分类：
其他好文 时间：
2015-07-12 15:53:40
阅读次数：
735
此优化脚本包在安装包的/bin下面贴出源码中的优化脚本:#!/bin/sh
#
#ExecuteOnlyOnce
#
echo‘vm.overcommit_memory=1‘>>/etc/sysctl.conf
echo‘vm.min_free_kbytes=5000000‘>>/etc/sysctl.conf
echo‘vm.drop_caches=1‘>>/etc/sysctl.conf
echo‘vm.zone_recla..
分类：
其他好文 时间：
2015-07-12 15:53:31
阅读次数：
205
1. 消息中间件简介目前主要提供了无序事务性高性能消息队列Notify与有序高性能消息队列RocketMQ(MetaQ)两大类产品，目前RocketMQ已经开源（https://github.com/alibaba/RocketMQ），产品被包括核心交易在内的几乎所有的应用所使用，每秒钟消息量80W...
分类：
其他好文 时间：
2015-07-11 11:46:17
阅读次数：
1120
在互联网和大并发的企业级应用中，kafka会越来越重要，会被更多的人重视，就算是不用kafka，也会有跟kafka类似的架构模式、原理差不多的MQ,类似于rocketMQ。现在差的，就是被更多的企业使用，更复杂的场景证明。...
分类：
其他好文 时间：
2015-06-04 08:38:01
阅读次数：
310
在上家公司工作时，设计的日志收集与实时分析架构，还是比较简单的:flume-ng+rocketmq+storm+redis+前端展示消息队列部分，我们刚开始采用的是kafka，但kafka在支持回溯消费和重复消费方面比较弱，同时在数据安全方面也相对弱一些，后来我们改为阿里的rocketmq。考虑到我们的数..
分类：
其他好文 时间：
2015-05-09 20:31:03
阅读次数：
1639
转自：https://github.com/alibaba/RocketMQ/wiki/rmq_vs_kafka淘宝内部的交易系统使用了淘宝自主研发的Notify消息中间件，使用Mysql作为消息存储媒介，可完全水平扩容，为了进一步降低成本，我们认为存储部分可以进一步优化，2011年初，Linkin...
分类：
其他好文 时间：
2015-04-20 00:06:57
阅读次数：
151
大家好，上一次分析了注册流程这次就开始分析下接收处理过程。贴图
分类：
其他好文 时间：
2015-04-19 06:46:50
阅读次数：
144
