没有合适的资源?快使用搜索试试~ 我知道了~
RocketMQ源码
共601个文件
java:512个
sh:27个
xml:24个
5星 · 超过95%的资源 需积分: 10 94 下载量 176 浏览量
2015-10-22
11:22:20
上传
评论 2
收藏 903KB ZIP 举报
温馨提示
提供RocketMQ消息中间件的源码,另附RocketMQ的测试用例以及性能测试代码,对初学者有很大帮助
资源推荐
资源详情
资源评论
收起资源包目录
RocketMQ源码 (601个子文件)
38 688B
44 466B
50 650B
install.bat 71B
deploy.bat 33B
eclipse.bat 23B
.gitignore 2KB
ArrayUtil.java 183KB
StringUtil.java 150KB
MQClientAPIImpl.java 89KB
DefaultMessageStore.java 71KB
AdminBrokerProcessor.java 54KB
MQClientInstance.java 48KB
DefaultMQPushConsumerImpl.java 45KB
CommitLog.java 43KB
ClassUtil.java 41KB
DefaultMQProducerImpl.java 41KB
DefaultMQAdminExtImpl.java 36KB
RouteInfoManager.java 36KB
BrokerController.java 28KB
NettyRemotingClient.java 28KB
DefaultMQPullConsumerImpl.java 26KB
PullMessageProcessor.java 25KB
HAService.java 24KB
DefaultRequestProcessor.java 24KB
ConsumeMessageOrderlyService.java 21KB
ConsumeQueue.java 21KB
NettyRemotingAbstract.java 21KB
SendMessageProcessor.java 20KB
RebalanceImpl.java 20KB
StoreStatsService.java 19KB
MapedFileQueue.java 19KB
MQAdminExt.java 19KB
HAConnection.java 18KB
MQAdminImpl.java 18KB
TopicConfigManager.java 17KB
ScheduleMessageService.java 17KB
MixAll.java 17KB
ConsumeMessageConcurrentlyService.java 17KB
MessageStoreConfig.java 16KB
NettyRemotingServer.java 16KB
DynaCode.java 16KB
DefaultMQAdminExt.java 15KB
DefaultRequestProcessor.java 15KB
ClientManageProcessor.java 15KB
AbstractSendMessageProcessor.java 15KB
IndexService.java 15KB
ObjectUtil.java 14KB
MapedFile.java 14KB
Broker2Client.java 14KB
RemotingCommand.java 14KB
UtilAll.java 14KB
BrokerOuterAPI.java 14KB
MessageDecoder.java 13KB
DefaultMQPushConsumer.java 13KB
MonitorService.java 13KB
ExceptionHelper.java 12KB
ProcessQueue.java 12KB
DefaultMQPullConsumer.java 12KB
RebalanceLockManager.java 11KB
PullAPIWrapper.java 11KB
IndexFile.java 11KB
BrokerStartup.java 11KB
ConsumerRunningInfo.java 11KB
EndTransactionProcessor.java 11KB
DefaultMQProducer.java 10KB
ClientRemotingProcessor.java 10KB
BrokerConfig.java 10KB
ClusterListSubCommand.java 10KB
ConsumerProgressSubCommand.java 10KB
Store.java 10KB
KVConfigManager.java 10KB
TransactionProducer.java 10KB
AllocateMessageQueueAveragelyTest.java 10KB
RemoteBrokerOffsetStore.java 10KB
MQAdminStartup.java 9KB
ConsumerOffsetManager.java 9KB
ConsumerGroupInfo.java 9KB
Producer.java 9KB
ProducerManager.java 9KB
LocalFileOffsetStore.java 8KB
ConsumerManager.java 8KB
RequestCode.java 8KB
FiltersrvController.java 8KB
RemotingHelper.java 8KB
NettyRPCTest.java 8KB
RecoverTest.java 8KB
StatsItem.java 8KB
MQPullConsumerScheduleService.java 8KB
FiltersrvStartup.java 8KB
MapedFileQueueTest.java 8KB
RemotingUtil.java 7KB
UpdateTopicSubCommand.java 7KB
AllocateMapedFileService.java 7KB
QueryMsgByIdSubCommand.java 7KB
JDBCTransactionStore.java 7KB
NamesrvStartup.java 7KB
ChainedThrowableDelegate.java 7KB
QueryMessageProcessor.java 7KB
RebalancePushImpl.java 7KB
共 601 条
- 1
- 2
- 3
- 4
- 5
- 6
- 7
资源评论
- songlinnihao2016-04-26挺好的资源!
- 张小胖不胖2018-04-27不错的资源,歇息
- HaydenQ2016-02-29不错学习学习。。。
- languo2016-03-23不错的资源,多谢
- kingfish2017-12-11不错,很好的资源
zhouyaxiang
- 粉丝: 0
- 资源: 4
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功