rocketmq-all-4.7.0-source-release.zip_rocketmq使用资源-CSDN文库

共1166个文件

java：976个

md：48个

xml：35个

需积分: 13 40 浏览量 2020-04-09 08:49:44 上传评论收藏 3.29MB ZIP 举报

Apache RocketMQ 是一款开源的消息中间件，源自阿里巴巴，现在成为了Apache顶级项目。RocketMQ的核心设计目标是低延迟、高吞吐量以及高可用性，它支持分布式消息传递、事务消息、实时消息等多种应用场景，广泛应用于大数据、云计算以及互联网和传统企业领域。在"rocketmq-all-4.7.0-source-release.zip"这个压缩包中，包含了RocketMQ 4.7.0版本的完整源代码。这个版本的发布标志着RocketMQ在功能、性能和稳定性上又迈出了坚实的一步。开发者可以深入研究源代码，理解其内部工作原理，以便更好地利用RocketMQ进行系统集成和定制化开发。 RocketMQ的源码主要分为以下几个模块： 1. **Broker**：RocketMQ的核心组件，负责接收和分发消息。 Broker包含Master和Slave，Master处理发送请求，Slave用于数据备份，实现高可用。 2. **NameServer**：轻量级的注册中心，负责管理Broker集群的信息，提供Broker的发现和路由查询服务，不存储消息，降低了系统的复杂度。 3. **Producer**：生产者客户端，用于发布消息到RocketMQ集群。它支持同步和异步发送模式，以及批量发送，确保消息的可靠传输。 4. **Consumer**：消费者客户端，用于订阅和消费消息。RocketMQ提供了多种消费模式，如Push Consumer（消息推模式）和Pull Consumer（消息拉模式），以及集群消费和广播消费。 5. **Remoting**：远程调用模块，实现了网络通信的底层逻辑，包括TCP长连接、心跳检测、协议编码解码等。 6. **Store**：消息存储模块，RocketMQ将消息持久化到磁盘，包括CommitLog和ConsumerQueue等数据结构，确保消息的可靠存储和快速检索。 7. **Client API**：Java和多语言客户端API，方便开发者在不同语言环境中使用RocketMQ。 8. **Tools**：一些实用工具，如Admin工具，用于监控和管理RocketMQ集群；以及NameServer和Broker的启动脚本。 9. **Tests**：测试代码，确保代码质量并验证功能的正确性。通过研究这些源码，开发者可以学习到以下知识点： - 分布式系统的设计与实现 - 高并发、高可用的消息队列架构 - 消息的可靠传输机制，如消息确认、重试和死信处理 - 高性能的磁盘存储和检索策略 - 负载均衡和故障切换策略 - 注册中心的实现原理 - 广播和集群消费模式的工作机制 - 消息过滤和订阅规则此外，源码分析还有助于开发者深入理解RocketMQ的扩展性，如自定义过滤器、消息分片、事务消息处理等特性，为开发更复杂的业务场景提供可能。同时，这也有利于参与RocketMQ社区的贡献，为项目的发展做出自己的贡献。

资源详情

资源评论

资源推荐

收起资源包目录

rocketmq-all-4.7.0-source-release.zip （1166个子文件）

org.apache.rocketmq.broker.transaction.AbstractTransactionalMessageCheckListener 68B

org.apache.rocketmq.acl.AccessValidator 50B

BUILDING 997B

runbroker.cmd 2KB

runserver.cmd 2KB

tools.cmd 2KB

mqshutdown.cmd 1KB

play.cmd 1KB

mqnamesrv.cmd 1KB

mqbroker.cmd 1KB

mqadmin.cmd 1KB

broker-n2.conf 1KB

broker-n0.conf 1KB

broker-n1.conf 1KB

broker.conf 949B

.gitignore 180B

MQClientAPIImpl.java 107KB

CommitLog.java 84KB

AdminBrokerProcessor.java 81KB

DefaultMessageStore.java 78KB

DefaultMQProducerImpl.java 73KB

BrokerController.java 54KB

MQClientInstance.java 52KB

DefaultMQPushConsumerImpl.java 52KB

DefaultMQAdminExtImpl.java 48KB

DefaultMQProducer.java 45KB

DefaultLitePullConsumerImpl.java 45KB

SelectorParser.java 39KB

LoggingBuilder.java 39KB

SendMessageProcessor.java 34KB

RouteInfoManager.java 34KB

DefaultMQPullConsumerImpl.java 34KB

SelectorParserTokenManager.java 32KB

DefaultMQPushConsumer.java 32KB

DLedgerCommitLog.java 31KB

PullMessageProcessor.java 31KB

PlainAccessValidatorTest.java 30KB

NettyRemotingClient.java 29KB

DefaultLitePullConsumerTest.java 27KB

DefaultMessageStoreTest.java 26KB

DefaultRequestProcessor.java 26KB

ConsumeMessageOrderlyService.java 26KB

NettyRemotingAbstract.java 25KB

BrokerConfig.java 25KB

DefaultMQAdminExt.java 24KB

ConsumeQueue.java 23KB

HAService.java 23KB

DefaultMQAdminExtTest.java 22KB

MessageStoreConfig.java 22KB

TransactionalMessageServiceImpl.java 22KB

MQAdminImpl.java 21KB

MQClientAPIImplTest.java 21KB

MappedFileQueue.java 21KB

DefaultMQProducerTest.java 21KB

MappedFile.java 21KB

NettyRemotingServer.java 20KB

RebalanceImpl.java 20KB

StoreStatsService.java 20KB

UtilAll.java 20KB

ConsumeMessageConcurrentlyService.java 20KB

TopicConfigManager.java 20KB

MessageDecoder.java 19KB

PlainPermissionManager.java 19KB

ConsumeQueueExt.java 19KB

RemoteAddressStrategyTest.java 19KB

BrokerOuterAPI.java 19KB

ConsumerFilterManager.java 18KB

MixAll.java 18KB

RemotingCommand.java 18KB

TransactionProducer.java 18KB

DefaultMessageStoreCleanFilesTest.java 18KB

ScheduleMessageService.java 18KB

DefaultMQPullConsumer.java 17KB

AsyncTraceDispatcher.java 17KB

ComparisonExpression.java 16KB

ReplyMessageProcessor.java 16KB

ExpressionTest.java 16KB

TransactionalMessageBridge.java 16KB

HAConnection.java 16KB

InnerLoggerFactory.java 16KB

ProcessQueue.java 15KB

AbstractSendMessageProcessor.java 15KB

DefaultLitePullConsumer.java 15KB

MessageStoreWithFilterTest.java 15KB

DefaultMQConsumerWithTraceTest.java 15KB

MQAdminExt.java 15KB

ClientRemotingProcessor.java 15KB

Broker2Client.java 14KB

SendMessageProcessorTest.java 14KB

MQVersion.java 14KB

TlsTest.java 14KB

DefaultMQPushConsumerTest.java 14KB

SimpleCharStream.java 14KB

EndTransactionProcessor.java 13KB

IndexService.java 13KB

Logger.java 13KB

MonitorService.java 13KB

PlainPermissionManagerTest.java 13KB

ClusterListSubCommand.java 13KB

共 1166 条

/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.rocketmq.client.impl; import java.io.UnsupportedEncodingException; import java.nio.ByteBuffer; import java.util.Arrays; import java.util.Collections; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Properties; import java.util.Set; import java.util.concurrent.atomic.AtomicInteger; import org.apache.commons.lang3.StringUtils; import org.apache.rocketmq.client.ClientConfig; import org.apache.rocketmq.client.consumer.PullCallback; import org.apache.rocketmq.client.consumer.PullResult; import org.apache.rocketmq.client.consumer.PullStatus; import org.apache.rocketmq.client.exception.MQBrokerException; import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.client.hook.SendMessageContext; import org.apache.rocketmq.client.impl.consumer.PullResultExt; import org.apache.rocketmq.client.impl.factory.MQClientInstance; import org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl; import org.apache.rocketmq.client.impl.producer.TopicPublishInfo; import org.apache.rocketmq.client.log.ClientLogger; import org.apache.rocketmq.client.producer.SendCallback; import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.client.producer.SendStatus; import org.apache.rocketmq.common.AclConfig; import org.apache.rocketmq.common.DataVersion; import org.apache.rocketmq.common.MQVersion; import org.apache.rocketmq.common.MixAll; import org.apache.rocketmq.common.PlainAccessConfig; import org.apache.rocketmq.common.TopicConfig; import org.apache.rocketmq.common.UtilAll; import org.apache.rocketmq.common.admin.ConsumeStats; import org.apache.rocketmq.common.admin.TopicStatsTable; import org.apache.rocketmq.common.message.Message; import org.apache.rocketmq.common.message.MessageBatch; import org.apache.rocketmq.common.message.MessageClientIDSetter; import org.apache.rocketmq.common.message.MessageConst; import org.apache.rocketmq.common.message.MessageDecoder; import org.apache.rocketmq.common.message.MessageExt; import org.apache.rocketmq.common.message.MessageQueue; import org.apache.rocketmq.common.namesrv.TopAddressing; import org.apache.rocketmq.common.protocol.NamespaceUtil; import org.apache.rocketmq.common.protocol.RequestCode; import org.apache.rocketmq.common.protocol.ResponseCode; import org.apache.rocketmq.common.protocol.body.BrokerStatsData; import org.apache.rocketmq.common.protocol.body.CheckClientRequestBody; import org.apache.rocketmq.common.protocol.body.ClusterAclVersionInfo; import org.apache.rocketmq.common.protocol.body.ClusterInfo; import org.apache.rocketmq.common.protocol.body.ConsumeMessageDirectlyResult; import org.apache.rocketmq.common.protocol.body.ConsumeStatsList; import org.apache.rocketmq.common.protocol.body.ConsumerConnection; import org.apache.rocketmq.common.protocol.body.ConsumerRunningInfo; import org.apache.rocketmq.common.protocol.body.GetConsumerStatusBody; import org.apache.rocketmq.common.protocol.body.GroupList; import org.apache.rocketmq.common.protocol.body.KVTable; import org.apache.rocketmq.common.protocol.body.LockBatchRequestBody; import org.apache.rocketmq.common.protocol.body.LockBatchResponseBody; import org.apache.rocketmq.common.protocol.body.ProducerConnection; import org.apache.rocketmq.common.protocol.body.QueryConsumeQueueResponseBody; import org.apache.rocketmq.common.protocol.body.QueryConsumeTimeSpanBody; import org.apache.rocketmq.common.protocol.body.QueryCorrectionOffsetBody; import org.apache.rocketmq.common.protocol.body.QueueTimeSpan; import org.apache.rocketmq.common.protocol.body.ResetOffsetBody; import org.apache.rocketmq.common.protocol.body.SubscriptionGroupWrapper; import org.apache.rocketmq.common.protocol.body.TopicConfigSerializeWrapper; import org.apache.rocketmq.common.protocol.body.TopicList; import org.apache.rocketmq.common.protocol.body.UnlockBatchRequestBody; import org.apache.rocketmq.common.protocol.header.CloneGroupOffsetRequestHeader; import org.apache.rocketmq.common.protocol.header.ConsumeMessageDirectlyResultRequestHeader; import org.apache.rocketmq.common.protocol.header.ConsumerSendMsgBackRequestHeader; import org.apache.rocketmq.common.protocol.header.CreateAccessConfigRequestHeader; import org.apache.rocketmq.common.protocol.header.CreateTopicRequestHeader; import org.apache.rocketmq.common.protocol.header.DeleteAccessConfigRequestHeader; import org.apache.rocketmq.common.protocol.header.DeleteSubscriptionGroupRequestHeader; import org.apache.rocketmq.common.protocol.header.DeleteTopicRequestHeader; import org.apache.rocketmq.common.protocol.header.EndTransactionRequestHeader; import org.apache.rocketmq.common.protocol.header.GetBrokerAclConfigResponseHeader; import org.apache.rocketmq.common.protocol.header.GetBrokerClusterAclConfigResponseBody; import org.apache.rocketmq.common.protocol.header.GetConsumeStatsInBrokerHeader; import org.apache.rocketmq.common.protocol.header.GetConsumeStatsRequestHeader; import org.apache.rocketmq.common.protocol.header.GetConsumerConnectionListRequestHeader; import org.apache.rocketmq.common.protocol.header.GetConsumerListByGroupRequestHeader; import org.apache.rocketmq.common.protocol.header.GetConsumerListByGroupResponseBody; import org.apache.rocketmq.common.protocol.header.GetConsumerRunningInfoRequestHeader; import org.apache.rocketmq.common.protocol.header.GetConsumerStatusRequestHeader; import org.apache.rocketmq.common.protocol.header.GetEarliestMsgStoretimeRequestHeader; import org.apache.rocketmq.common.protocol.header.GetEarliestMsgStoretimeResponseHeader; import org.apache.rocketmq.common.protocol.header.GetMaxOffsetRequestHeader; import org.apache.rocketmq.common.protocol.header.GetMaxOffsetResponseHeader; import org.apache.rocketmq.common.protocol.header.GetMinOffsetRequestHeader; import org.apache.rocketmq.common.protocol.header.GetMinOffsetResponseHeader; import org.apache.rocketmq.common.protocol.header.GetProducerConnectionListRequestHeader; import org.apache.rocketmq.common.protocol.header.GetTopicStatsInfoRequestHeader; import org.apache.rocketmq.common.protocol.header.GetTopicsByClusterRequestHeader; import org.apache.rocketmq.common.protocol.header.PullMessageRequestHeader; import org.apache.rocketmq.common.protocol.header.PullMessageResponseHeader; import org.apache.rocketmq.common.protocol.header.QueryConsumeQueueRequestHeader; import org.apache.rocketmq.common.protocol.header.QueryConsumeTimeSpanRequestHeader; import org.apache.rocketmq.common.protocol.header.QueryConsumerOffsetRequestHeader; import org.apache.rocketmq.common.protocol.header.QueryConsumerOffsetResponseHeader; import org.apache.rocketmq.common.protocol.header.QueryCorrectionOffsetHeader; import org.apache.rocketmq.common.protocol.header.QueryMessageRequestHeader; import org.apache.rocketmq.common.protocol.header.QueryTopicConsumeByWhoRequestHeader; import org.apache.rocketmq.common.protocol.header.ResetOffsetRequestHeader; import org.apache.rocketmq.common.protocol.header.ResumeCheckHalfMessageRequestHeader; import org.apache.rocketmq.common.protocol.header.SearchOffsetRequestHeader; import org.apache.rocketmq.common.pro