Coin163

  • RocketMQ使用笔记

    1、将alibaba-rocketmq-3.2.2.tar.gz解压 2、设置/app/alibaba-rocketmq/bin目录下执行脚本的权限:chmod +x ./bin/*.sh 3、启动nameserver(192.168.232.147

    日期:2015年02月04日
  • rocketmq 延迟队列的实现

    个consumer)消费延迟消息,如果到达延迟时间,将消息取出,改回原来的topic和queueId,放入到commitLog中,然后被真正的消费者. 疑难点:  问: 如何保证rocketMq的offset移动和延迟消息不冲突?  答: rocketMq当消息真正要消费

    日期:2016年04月19日
  • 《RocketMq》六、Broker中心节点

    由于之前已经把存储,网络分解出来进行了详细的分析,因此Broker部分变得较简单,这里主要分为以下几个部分来说: 一、Broker与NameSrv交互 Broker会不断发送register信息给NameSrv,将自身的clusterName,brokerName,topic信息发送到Namesrv;而Consumer和Producer则会通过Namesrv获取信息,这里最主要的数据结构是: TopicConfig { public static int DefaultReadQueueNums = 16; public static int DefaultWriteQueue

    日期:2015年12月29日
  • RocketMQ消费者,设置setConsumeFromWhere无效的问题

    今天用了阿里开源的RocketMQ,第一次消费,使用新的consumserGroup消费,设置 consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET); 但是结果

    日期:2016年06月16日
  • rocketmq问题汇总-instanceName参数何时该设置?

    以下只针对集群模式: 1 producer 默认情况下不需要设置instanceName,rocketmq会使用ip@pid(pid代表jvm名字)作为唯一标示 如果同一个jvm中,不同的producer需要往不同的rocketmq集群发送消息,需要设置不同

    日期:2016年02月14日
  • Centos7安装RocketMQ及配置测试

    环境 Centos7 RocketMQ 3.2.6 安装位置 /usr/local/alibaba-rockermq 外网ip 182.254.145.66 内网ip 10.105.23.114 安装 wget https://github.com

    日期:2016年05月27日
  • RocketMQ原理解析-consumer 7.shutdown

    DefaultMQPushConsumerImpl  关闭消费端          关闭消费线程          将分配到的Set<MessageQueue>的消费进度保存到broker 利用DefaultMQPushConsumerImpl获取ProcessQueueTable<MessageQueue,ProcessQueue>的keyset的messagequeue去获取 RemoteBrokerOffsetStore.offsetTable<MessageQueue,AutomicLong>Map中的消费进度, offsetTable中的messagequeue的值,在update的

    日期:2014年09月09日
  • rocketmq 的cluster模式下确保消息不丢失之消费进度维护

    rocketmq 保证消息不丢失,如何做到,需要研究下如何维护消费进度的. 会会导致重复消费. 本文不考虑broker宕机无法启动,热备等情况 首先最终根数据保持在每个broker中的ConsumerOffsetManager类 * Consumer消费

    日期:2016年04月26日
  • RocketMQ原理解析-producer 5.消息在broker落地之普通消息

    Broker根据producer请求的RequestCode.SEND_MESSAGE选择对应的处理器SendMessageProcessor          根据请求消息内容构建消息内部结构MessageExtBrokerInner          调DefaultMessageStore加消息写入commitlog

    日期:2014年09月08日
  • RocketMQ原理解析-producer 6.消息在broker落地之事物消息

    1. 消息落地 commitLog针对事物消息的处理,消息的第20位开始的八位记录是的消息在逻辑队列中的queueoffset,但是针对事物消息为preparedType和rollbackType的存储的是事物状态表的索引偏移量 2. 分发事物消息:          分发消息位置信息到ConsumeQueue: 事物状态为preparedType和rollbackType的消息不会将请求分发到ConsumeQueue中去,即不处理,所以不会被消息          更新transactionstable table:如果是prepared消息记,通过TransactionStateServi

    日期:2014年09月08日