CDN加速镜像 | 设为首页 | 加入收藏夹
登陆 | 会员注册
当前位置： 首页 资源下载 源码下载 Windows编程 其他小程序
收藏

文件名称:rocketmq-master

  • 所属分类：
    其他
  • 标签属性：
    [Java] [源码]
  • 上传时间：
    2018-01-12
  • 文件大小：
    1.29mb
  • 已下载：
    0次
  • 提 供 者：
    打烂你***
  • 相关连接：
    无
  • 下载说明：
    别用迅雷下载，失败请重下，重下不扣分！
修正介绍说明

介绍说明－－下载内容来自于网络，使用问题请自行百度

案例开源的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

相关说明

  • 本站资源为会员上传分享交流与学习,如有侵犯您的权益,请联系我们删除.
  • 搜珍网是交换下载平台，只提供交流渠道，下载内容来自于网络，除下载问题外，其它问题请自行百度。更多...
  • 本站已设置防盗链，请勿用迅雷、QQ旋风等下载软件下载资源，下载后用WinRAR最新版进行解压.
  • 如果您发现内容无法下载，请稍后再次尝试；或换浏览器；或者到消费记录里找到下载记录反馈给我们.
  • 下载后发现下载的内容跟说明不相乎，请到消费记录里找到下载记录反馈给我们，经确认后退回积分.
  • 如下载前有疑问，可以通过点击"提供者"的名字，查看对方的联系方式，联系对方咨询.
查看所有评论

相关评论

暂无评论内容．

发表评论

*快速评论： 推荐 一般 有密码 和说明不符 不是源码或资料 文件不全 不能解压 纯粹是垃圾
*内　　容：
*验 证 码：
搜珍网 www.dssz.com