/*
* 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.0-source-release.zip （1166个子文件） 
org.apache.rocketmq.broker.transaction.AbstractTransactionalMessageCheckListener 68B org.apache.rocketmq.acl.AccessValidator 50B 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 条
- 1
- 2
- 3
- 4
- 5
- 6
- 12
尚云峰
- 粉丝: 59
- 资源: 30
最新资源
- 基于PyCharm和百度AI的智能停车场车牌识别计费系统说明
- 使用 Python 绘制简单而美观的 ASCII 圣诞树示例
- 全国各城市-农村-乡村户数（1999-2020年）.xlsx
- 辅助Resx语言资源文件翻译程序
- Python实现AI智能联系人管理系统的操作指南
- 路径规划算法仿真 A星算法 传统A*(Astar)算法+改进后的A*算法 Matlab代码 可以固定栅格地图与起点终点 可以进行定量比较 改进： ①提升搜索效率（引入权重系数） ②冗余拐角优化（可显
- 基于 PyQt 的日志分析工具
- 机械设计电子烟自动装配组装机含工程图sw14可编辑非常好的设计图纸100%好用.zip
- 机械设计电子烟产品自动组装机sw16可编辑非常好的设计图纸100%好用.zip
- 使用 Python 和 Pygame 创建动态3D圣诞树效果
- 消费者行为数据集，消费者购买影响因素数据，营销行为预测数据集（该生成的数据集模拟了500名用户的营销互动数据）
- adf4150芯片加载程序
- 51商城程序使用手册：涵盖前后台功能详解与操作指南
- LSTM长短期记忆神经网络多输入多输出预测（Matlab） 所有程序经过验证，保证有效运行 1.data为数据集，10个输入特征，3个输出变量 2.MainLSTMNM.m为主程序文件 3.命
- 鸿蒙开发用户首选项demo
- 机械设计端面缺陷检测设备CCD检测机sw17可编辑非常好的设计图纸100%好用.zip
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
评论0