/*
* 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
没有合适的资源?快使用搜索试试~ 我知道了~
rocketmq-all-4.7.1-source-release.zip
共2795个文件
class:1353个
java:980个
xml:88个
需积分: 1 0 下载量 35 浏览量
2023-04-25
22:49:14
上传
评论
收藏 9.37MB ZIP 举报
温馨提示
rocketmq-all-4.7.1-source-release.zip 源码rocketmq-all-4.7.1-source-release.zip 源码rocketmq-all-4.7.1-source-release.zip 源码rocketmq-all-4.7.1-source-release.zip 源码rocketmq-all-4.7.1-source-release.zip 源码rocketmq-all-4.7.1-source-release.zip 源码rocketmq-all-4.7.1-source-release.zip 源码rocketmq-all-4.7.1-source-release.zip 源码rocketmq-all-4.7.1-source-release.zip 源码rocketmq-all-4.7.1-source-release.zip 源码rocketmq-all-4.7.1-source-release.zip 源码rocketmq-all-4.7.1-source-release.zip 源码rocketmq-all-4.7.1-s
资源推荐
资源详情
资源评论
收起资源包目录
rocketmq-all-4.7.1-source-release.zip (2795个子文件)
$CACHE_FILE$ 2KB
$PRODUCT_WORKSPACE_FILE$ 1KB
org.apache.rocketmq.broker.transaction.AbstractTransactionalMessageCheckListener 68B
org.apache.rocketmq.broker.transaction.AbstractTransactionalMessageCheckListener 68B
org.apache.rocketmq.acl.AccessValidator 50B
org.apache.rocketmq.acl.AccessValidator 50B
org.apache.rocketmq.acl.AccessValidator 50B
org.apache.rocketmq.acl.AccessValidator 50B
BUILDING 997B
MQClientAPIImpl.class 69KB
AdminBrokerProcessor.class 60KB
DefaultMQProducerImpl.class 52KB
DefaultMessageStore.class 48KB
MQClientInstance.class 45KB
BrokerController.class 43KB
DefaultMQPushConsumerImpl.class 42KB
DefaultMQAdminExtImpl.class 40KB
DefaultLitePullConsumerImpl.class 38KB
MQVersion$Version.class 38KB
CommitLog.class 35KB
DefaultMQPullConsumerImpl.class 32KB
SendMessageProcessor.class 30KB
SelectorParser.class 25KB
PullMessageProcessor.class 25KB
DLedgerCommitLog.class 24KB
DefaultLitePullConsumerTest.class 24KB
RouteInfoManager.class 23KB
DefaultMQAdminExtTest.class 23KB
DefaultMQProducer.class 21KB
DefaultMessageStoreTest.class 21KB
NettyRemotingClient.class 21KB
DefaultMQProducerTest.class 21KB
BrokerConfig.class 21KB
DefaultMQPushConsumer.class 19KB
TransactionalMessageServiceImpl.class 19KB
ConsumeMessageOrderlyService.class 19KB
MappedFile.class 18KB
PlainAccessValidatorTest.class 18KB
MessageStoreConfig.class 18KB
DefaultMQAdminExt.class 18KB
DefaultRequestProcessor.class 18KB
RebalanceImpl.class 18KB
RemotingCommand.class 18KB
NettyRemotingAbstract.class 17KB
MQClientAPIImplTest.class 17KB
UtilAll.class 17KB
TransactionalMessageBridge.class 17KB
MixAll.class 16KB
ReplyMessageProcessor.class 16KB
ConsumeMessageConcurrentlyService.class 16KB
DefaultMQConsumerWithTraceTest.class 16KB
DefaultMQPushConsumerTest.class 16KB
ConsumeQueue.class 16KB
MQAdminImpl.class 16KB
PlainPermissionManager.class 15KB
MappedFileQueue.class 15KB
DefaultMessageStoreCleanFilesTest.class 15KB
StoreStatsService.class 15KB
AbstractSendMessageProcessor.class 15KB
Broker2Client.class 15KB
BrokerOuterAPI.class 15KB
NettyRemotingServer.class 14KB
MessageStoreWithFilterTest.class 14KB
SelectorParserTokenManager.class 14KB
MessageDecoder.class 14KB
DefaultMQPullConsumer.class 13KB
TopicConfigManager.class 13KB
ClientRemotingProcessor.class 13KB
ProcessQueue.class 13KB
TransactionalMessageServiceImplTest.class 13KB
ConsumeMessageConcurrentlyServiceTest.class 13KB
MonitorService.class 13KB
QueryMsgByUniqueKeySubCommandTest.class 13KB
SendMessageProcessorTest.class 13KB
ConsumerFilterManager.class 13KB
PullMessageProcessorTest.class 12KB
DefaultLitePullConsumer.class 12KB
PullAPIWrapper.class 12KB
ExpressionTest.class 12KB
IndexService.class 12KB
TransactionalMessageBridgeTest.class 11KB
ConsumeQueueTest.class 11KB
LocalMessageCache.class 11KB
AclUtils.class 11KB
ConsumerProgressSubCommand.class 11KB
HATest.class 11KB
DefaultRequestProcessorTest.class 11KB
ConsumerRunningInfo.class 11KB
RebalancePushImpl.class 11KB
EndTransactionProcessor.class 11KB
ComparisonExpression.class 10KB
BrokerStartup.class 10KB
DefaultMQProducerWithTraceTest.class 10KB
ConsumerOffsetManager.class 10KB
PrintMessageByQueueCommand.class 10KB
MonitorServiceTest.class 10KB
QueryMsgByIdSubCommand.class 10KB
MQAdminStartup.class 10KB
ClientConfig.class 10KB
ScheduleMessageServiceTest.class 10KB
共 2795 条
- 1
- 2
- 3
- 4
- 5
- 6
- 28
资源评论
Java码库
- 粉丝: 1406
- 资源: 3918
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功