文件名称:rocketmq-master
介绍说明－－下载内容均来自于网络，请自行研究使用
案例开源的java源码，基于netty实现的rocketmq(Case open source java source code, based on the realization of rocketmq netty)
相关搜索： rocketmq
(系统自动生成,下载前可以参看下载内容)
下载文件列表
| 文件名 | 大小 | 更新时间 |
|---|---|---|
| rocketmq-master\.github\PULL_REQUEST_TEMPLATE.md | 1524 | 2017-12-17 |
| rocketmq-master\.gitignore | 157 | 2017-12-17 |
| rocketmq-master\.travis.yml | 815 | 2017-12-17 |
| rocketmq-master\broker\pom.xml | 3166 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\BrokerController.java | 36687 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\BrokerPathConfigHelper.java | 1948 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\BrokerStartup.java | 11772 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\client\ClientChannelInfo.java | 3265 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\client\ClientHousekeepingService.java | 3881 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\client\ConsumerGroupEvent.java | 1109 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\client\ConsumerGroupInfo.java | 9031 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\client\ConsumerIdsChangeListener.java | 967 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\client\ConsumerManager.java | 8674 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\client\DefaultConsumerIdsChangeListener.java | 2643 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\client\net\Broker2Client.java | 14961 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\client\ProducerManager.java | 8657 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\client\rebalance\RebalanceLockManager.java | 10763 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\filter\CommitLogDispatcherCalcBitMap.java | 4443 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\filter\ConsumerFilterData.java | 4144 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\filter\ConsumerFilterManager.java | 18857 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\filter\ExpressionForRetryMessageFilter.java | 3829 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\filter\ExpressionMessageFilter.java | 6163 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\filter\MessageEvaluationContext.java | 1768 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\filtersrv\FilterServerManager.java | 6523 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\filtersrv\FilterServerUtil.java | 1578 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\latency\BrokerFastFailure.java | 5418 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\latency\BrokerFixedThreadPoolExecutor.java | 2694 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\latency\FutureTaskExt.java | 1347 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\longpolling\ManyPullRequest.java | 1584 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\longpolling\NotifyMessageArrivingListener.java | 1584 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\longpolling\PullRequest.java | 2552 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\longpolling\PullRequestHoldService.java | 7376 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\mqtrace\ConsumeMessageContext.java | 3961 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\mqtrace\ConsumeMessageHook.java | 1047 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\mqtrace\SendMessageContext.java | 5835 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\mqtrace\SendMessageHook.java | 1053 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\offset\ConsumerOffsetManager.java | 9464 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\out\BrokerOuterAPI.java | 13434 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\pagecache\ManyMessageTransfer.java | 2889 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\pagecache\OneMessageTransfer.java | 2657 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\pagecache\QueryMessageTransfer.java | 2913 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\plugin\AbstractPluginMessageStore.java | 7329 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\plugin\MessageStoreFactory.java | 2187 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\plugin\MessageStorePluginContext.java | 2212 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\processor\AbstractSendMessageProcessor.java | 15448 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\processor\AdminBrokerProcessor.java | 68745 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\processor\ClientManageProcessor.java | 9344 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\processor\ConsumerManageProcessor.java | 7521 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\processor\EndTransactionProcessor.java | 11053 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\processor\ForwardRequestProcessor.java | 1763 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\processor\PullMessageProcessor.java | 30934 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\processor\QueryMessageProcessor.java | 7391 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\processor\SendMessageProcessor.java | 27554 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\slave\SlaveSynchronize.java | 6448 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\subscription\SubscriptionGroupManager.java | 8187 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\topic\TopicConfigManager.java | 17513 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\transaction\jdbc\JDBCTransactionStore.java | 7679 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\transaction\jdbc\JDBCTransactionStoreConfig.java | 1827 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\transaction\TransactionRecord.java | 1293 | 2017-12-17 |
| rocketmq-master\broker\src\main\java\org\apache\rocketmq\broker\transaction\TransactionStore.java | 1180 | 2017-12-17 |
| rocketmq-master\broker\src\main\resources\transaction.sql | 902 | 2017-12-17 |
| rocketmq-master\broker\src\test\java\org\apache\rocketmq\broker\BrokerControllerTest.java | 1942 | 2017-12-17 |
| rocketmq-master\broker\src\test\java\org\apache\rocketmq\broker\BrokerStartupTest.java | 1656 | 2017-12-17 |
| rocketmq-master\broker\src\test\java\org\apache\rocketmq\broker\client\ProducerManagerTest.java | 3665 | 2017-12-17 |
| rocketmq-master\broker\src\test\java\org\apache\rocketmq\broker\filter\CommitLogDispatcherCalcBitMapTest.java | 6740 | 2017-12-17 |
| rocketmq-master\broker\src\test\java\org\apache\rocketmq\broker\filter\ConsumerFilterManagerTest.java | 9144 | 2017-12-17 |
| rocketmq-master\broker\src\test\java\org\apache\rocketmq\broker\filter\MessageStoreWithFilterTest.java | 15104 | 2017-12-17 |
| rocketmq-master\broker\src\test\java\org\apache\rocketmq\broker\latency\BrokerFastFailureTest.java | 2449 | 2017-12-17 |
| rocketmq-master\broker\src\test\java\org\apache\rocketmq\broker\processor\ClientManageProcessorTest.java | 6153 | 2017-12-17 |
| rocketmq-master\broker\src\test\java\org\apache\rocketmq\broker\processor\PullMessageProcessorTest.java | 11796 | 2017-12-17 |
| rocketmq-master\broker\src\test\java\org\apache\rocketmq\broker\processor\SendMessageProcessorTest.java | 11274 | 2017-12-17 |
| rocketmq-master\broker\src\test\resources\logback-test.xml | 1243 | 2017-12-17 |
| rocketmq-master\BUILDING | 997 | 2017-12-17 |
| rocketmq-master\client\pom.xml | 2523 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\admin\MQAdminExtInner.java | 883 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\ClientConfig.java | 6831 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\common\ClientErrorCode.java | 1189 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\common\ThreadLocalIndex.java | 1637 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\AllocateMessageQueueStrategy.java | 1654 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\DefaultMQPullConsumer.java | 12600 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\DefaultMQPushConsumer.java | 23749 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\listener\ConsumeConcurrentlyContext.java | 1929 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\listener\ConsumeConcurrentlyStatus.java | 1048 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\listener\ConsumeOrderlyContext.java | 1772 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\listener\ConsumeOrderlyStatus.java | 1237 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\listener\ConsumeReturnType.java | 1198 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\listener\MessageListener.java | 984 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\listener\MessageListenerConcurrently.java | 1555 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\listener\MessageListenerOrderly.java | 1569 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\MessageQueueListener.java | 1392 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\MessageSelector.java | 2163 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\MQConsumer.java | 2154 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\MQPullConsumer.java | 4797 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\MQPullConsumerScheduleService.java | 7922 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\MQPushConsumer.java | 3469 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\PullCallback.java | 1016 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\PullResult.java | 2299 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\PullStatus.java | 1143 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\PullTaskCallback.java | 1018 | 2017-12-17 |
| rocketmq-master\client\src\main\java\org\apache\rocketmq\client\consumer\PullTaskContext.java | 1403 | 2017-12-17 |