今天使用rocketmq，消费者每消费一条消息都会产生info日志 搜索无果，查看源代码 所有日志名定义 配置 rocketmq.client.log.loadconfig rocketmq.client.log.configFile 日志级别 <Logger name="RocketmqClien ...
分类：
其他好文 时间：
2017-05-17 19:56:55
阅读次数：
797
了解RocketMQ的都知道，它会保存所有的消息到本地文件。这个文件就是 MappedFile,每一个文件对应一个MappedFile.默认情况下大小位1g。 在MessageStoreConfig中的mapedFileSizeCommitLog设置，当然一半情况下是通过配置文件来设置的。文件路劲也 ...
分类：
移动开发 时间：
2017-05-14 10:45:22
阅读次数：
569
RocketMQ有很多的线程服务，这些服务都继承自抽象类ServiceThread。 这个抽象类可以单独抽出来用到我们其他的项目中来，仅仅需要修改下日志模块： 使用方法： 继承这个类，需要实现两个方法，一个来自runnable接口的run方法，一个是来自ServiceThread 的getServi ...
分类：
编程语言 时间：
2017-05-14 10:35:23
阅读次数：
270
刚刚在研究rocketmq生成文件的源码。零时记录一下MapedFileQueue中属性AllocateMapedFileService allocateMapedFileService的初始化链。 首先这个服务实在DefaultMessageStore中初始化完成并启动的，然后DefaultMes ...
分类：
其他好文 时间：
2017-05-14 10:25:20
阅读次数：
116
看完了上一篇的《RocketMQ 拉取消息-通信模块》，请求进入PullMessageProcessor中，接着 PullMessageProcessor.processRequest(final ChannelHandlerContext ctx, RemotingCommand request) ...
分类：
其他好文 时间：
2017-05-10 15:41:07
阅读次数：
517
首先看server端：class NettyRemotingServer extends NettyRemotingAbstract implements RemotingServer 下面这个实现了com.alibaba.rocketmq.remoting.RemotingService中的sta ...
分类：
其他好文 时间：
2017-05-10 12:56:44
阅读次数：
512
MapedFile 和文件一对一关系 MapedFileQueue 管理mapedFile，新建、获取、删除mapedFile将消息写入文件 MapedFileQueue 管理mapedFile，新建、获取、删除mapedFile将消息写入文件 ...
分类：
其他好文 时间：
2017-05-10 11:17:03
阅读次数：
113
环境要求：需要安装jdk1.6以上，maven3.X以上，git一、maven安装1.下载软件：wgethttp://mirror.bit.edu.cn/apache/maven/maven-3/3.3.9/binaries/apache-maven-3.3.9-bin.tar.gz2.安装tarxfapache-maven-3.3.9-bin.tar.gz-C/usr/local
cd/usr/local
ln-svapache-maven-3.3.9ma..
分类：
其他好文 时间：
2017-05-10 09:38:19
阅读次数：
221
rocketmq通过netty获取到消息请求后，直接掉处理模块，比如：SendMessageProcessor 这个处理类主要负责处理客户端发送消息的请求。 这个类实现了com.alibaba.rocketmq.remoting.netty.NettyRequestProcessor接口。这个接口下 ...
分类：
其他好文 时间：
2017-05-08 01:17:51
阅读次数：
2392
此文档安装的是rocketmq当前最新版本rocketmqv4.0.0，当时阿里已经把rocketmq捐赠给了apache组织，为什么要特别指明这一点，因为在下载、安装和服务脚本中有个别不同的地方。这是本人第一篇博客，如果排版不是很清楚，请评论中指明，以纠正自己的编写习惯。一、安装rocketmq1、..
分类：
系统相关 时间：
2017-05-06 17:43:03
阅读次数：
400
