| 共 12 篇文章 |
|
分布式消息队列RocketMQ部署与监控。# mv alibaba-rocketmq alibaba-rocketmq-3.1.7.# ln -s alibaba-rocketmq-3.1.7 rocketmq.export ROCKETMQ_HOME=/usr/local/rocketmq.# cd /usr/local/rocketmq/bin &&sh os.sh.# vim /usr/local/rocketmq/conf/2m-noslave/broker-a.properties.*/2 * * * * (flock --timeout=0 /var/run/check_roc... 阅625 转1 评0 公众公开 17-07-06 15:41 |
消息发送成功，但是服务器刷盘超时，消息已经进入服务器队列，只有此时服务器宕机，消息才会丢失。消息发送成功，但是此时slave不可用，消息已经进入服务器队列，只有此时服务器宕机，消息才会丢。消息消费RT.绝大部分消息消费行为属于IO密集型，即可能是操作数据库，或者调用RPC，这类消费行为的消费速度在于后端。在线下压测消费过程中，db表... 阅928 转1 评0 公众公开 17-07-06 15:36 |
RocketMQ除了支持普通消息，顺序消息，另外还支持事务消息。Consume Queue中存储单元是一个20字节定长的二进制数据，顺序写顺序读，如下图所示：consumequeue文件存储单元格式CommitLog Offset是指这条消息在Commit Log文件中的实际偏移量 Size存储中消息的大小 Message Tag HashCode存储消息的Tag的哈希值：主要用于订阅时消息过滤（订阅时如... 阅20 转0 评0 公众公开 17-07-06 15:26 |
RocketMQ开发挃南。项目开源主页：https://github.com/alibaba/RocketMQ.5.2RocketMQ物理部署结构...............................................................................................................................118RocketMQ消息过滤..................................................................................... 阅804 转1 评0 公众公开 17-07-06 15:18 |
下载代码：gitclonehttps://github.com/tgou/RocketMQ1.该配置首先从java属性rocketmq.home.dir中获取，如果没有获取到从系统环境变量ROCKETMQ_HOME中获取1)虽然该配置是可选，但是前提是已经配置了rocketmq.home.dir或者ROCKETMQ_HOME2)该配置首先从java属性rocketmq.namesrv.addr中获取，如果没有获取到从系统环境变量NAMESRV_ADDR中获取1)br... 阅2365 转0 评0 公众公开 17-07-06 15:17 |
MQ产品比较-ActiveMQ-RocketMQ 几种MQ产品说明：ActiveMQ: 历史悠久的开源项目，已经在很多产品中得到应用，实现了JMS1.1规范，可以和spring-jms轻松融合，实现了多种协议，不够轻巧（源代码比RocketMQ多）.，支持持久化到数据库，对队列数较多的情况支持不好，不过我们的项目中并不会建很多的队列.RocketMQ: 阿里巴巴的MQ中间件，在其多个... 阅114 转0 评0 公众公开 17-07-06 15:15 |
