You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by hu...@apache.org on 2022/03/29 04:31:32 UTC
[rocketmq-mqtt] 04/43: Merge pull request #2 from pingww/main
This is an automated email from the ASF dual-hosted git repository.
huzongtang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
commit 9ca79140058f27a478e76df72025e6e1f1c15d14
Merge: a1a67f8 4dedf82
Author: rongtong <ji...@163.com>
AuthorDate: Tue Mar 8 15:09:48 2022 +0800
Merge pull request #2 from pingww/main
Repository Init
.gitignore | 3 +
README.md | 75 ++-
assembly.xml | 37 ++
bin/mqtt.sh | 93 ++++
bin/runserver.sh | 93 ++++
conf/connect.conf | 18 +
conf/logback.xml | 76 +++
conf/service.conf | 22 +
conf/spring.xml | 25 +
mqtt-common/pom.xml | 50 ++
.../rocketmq/mqtt/common/facade/AuthManager.java | 33 ++
.../mqtt/common/facade/LmqOffsetStore.java | 45 ++
.../rocketmq/mqtt/common/facade/LmqQueueStore.java | 92 ++++
.../mqtt/common/facade/MetaPersistManager.java | 44 ++
.../mqtt/common/hook/AbstractUpstreamHook.java | 70 +++
.../org/apache/rocketmq/mqtt/common/hook/Hook.java | 36 ++
.../rocketmq/mqtt/common/hook/HookResult.java | 109 +++++
.../rocketmq/mqtt/common/hook/UpstreamHook.java | 37 ++
.../mqtt/common/hook/UpstreamHookEnum.java | 25 +
.../mqtt/common/hook/UpstreamHookManager.java | 45 ++
.../rocketmq/mqtt/common/model/Constants.java | 46 ++
.../apache/rocketmq/mqtt/common/model/Message.java | 217 +++++++++
.../rocketmq/mqtt/common/model/MessageEvent.java | 79 +++
.../mqtt/common/model/MqttMessageUpContext.java | 59 +++
.../rocketmq/mqtt/common/model/MqttTopic.java | 47 ++
.../rocketmq/mqtt/common/model/PullResult.java | 65 +++
.../apache/rocketmq/mqtt/common/model/Queue.java | 116 +++++
.../rocketmq/mqtt/common/model/QueueOffset.java | 72 +++
.../apache/rocketmq/mqtt/common/model/Remark.java | 33 ++
.../apache/rocketmq/mqtt/common/model/RpcCode.java | 28 ++
.../rocketmq/mqtt/common/model/RpcHeader.java | 25 +
.../rocketmq/mqtt/common/model/StoreResult.java | 41 ++
.../rocketmq/mqtt/common/model/Subscription.java | 114 +++++
.../apache/rocketmq/mqtt/common/model/Trie.java | 240 +++++++++
.../rocketmq/mqtt/common/model/TrieException.java | 41 ++
.../rocketmq/mqtt/common/model/TrieMethod.java | 33 ++
.../rocketmq/mqtt/common/util/HmacSHA1Util.java | 45 ++
.../apache/rocketmq/mqtt/common/util/HostInfo.java | 56 +++
.../rocketmq/mqtt/common/util/MessageUtil.java | 119 +++++
.../rocketmq/mqtt/common/util/NamespaceUtil.java | 70 +++
.../apache/rocketmq/mqtt/common/util/StatUtil.java | 472 ++++++++++++++++++
.../rocketmq/mqtt/common/util/TopicUtils.java | 195 ++++++++
.../apache/rocketmq/mqtt/common/test/TestTrie.java | 37 ++
mqtt-cs/pom.xml | 71 +++
.../rocketmq/mqtt/cs/channel/ChannelCloseFrom.java | 33 ++
.../rocketmq/mqtt/cs/channel/ChannelException.java | 41 ++
.../rocketmq/mqtt/cs/channel/ChannelInfo.java | 254 ++++++++++
.../rocketmq/mqtt/cs/channel/ChannelManager.java | 64 +++
.../rocketmq/mqtt/cs/channel/ConnectHandler.java | 65 +++
.../mqtt/cs/channel/DefaultChannelManager.java | 151 ++++++
.../rocketmq/mqtt/cs/config/ConnectConf.java | 184 +++++++
.../mqtt/cs/config/ConnectConfListener.java | 73 +++
.../mqtt/cs/hook/UpstreamHookManagerImpl.java | 74 +++
.../cs/protocol/mqtt/MqttPacketDispatcher.java | 179 +++++++
.../mqtt/cs/protocol/mqtt/MqttPacketHandler.java | 37 ++
.../protocol/mqtt/handler/MqttConnectHandler.java | 111 +++++
.../mqtt/handler/MqttDisconnectHandler.java | 45 ++
.../cs/protocol/mqtt/handler/MqttPingHandler.java | 57 +++
.../protocol/mqtt/handler/MqttPubAckHandler.java | 58 +++
.../protocol/mqtt/handler/MqttPubCompHandler.java | 67 +++
.../protocol/mqtt/handler/MqttPubRecHandler.java | 60 +++
.../protocol/mqtt/handler/MqttPubRelHandler.java | 51 ++
.../protocol/mqtt/handler/MqttPublishHandler.java | 114 +++++
.../mqtt/handler/MqttSubscribeHandler.java | 130 +++++
.../mqtt/handler/MqttUnSubscribeHandler.java | 91 ++++
.../mqtt/cs/protocol/rpc/RpcPacketDispatcher.java | 86 ++++
.../cs/protocol/ws/WebSocketServerHandler.java | 109 +++++
.../mqtt/cs/protocol/ws/WebsocketEncoder.java | 38 ++
.../rocketmq/mqtt/cs/session/QueueFresh.java | 65 +++
.../apache/rocketmq/mqtt/cs/session/Session.java | 469 ++++++++++++++++++
.../rocketmq/mqtt/cs/session/infly/InFlyCache.java | 191 ++++++++
.../rocketmq/mqtt/cs/session/infly/MqttMsgId.java | 93 ++++
.../rocketmq/mqtt/cs/session/infly/PushAction.java | 187 +++++++
.../mqtt/cs/session/infly/RetryDriver.java | 327 +++++++++++++
.../mqtt/cs/session/loop/PullResultStatus.java | 26 +
.../rocketmq/mqtt/cs/session/loop/QueueCache.java | 318 ++++++++++++
.../rocketmq/mqtt/cs/session/loop/SessionLoop.java | 100 ++++
.../mqtt/cs/session/loop/SessionLoopImpl.java | 536 +++++++++++++++++++++
.../mqtt/cs/session/match/MatchAction.java | 161 +++++++
.../cs/session/notify/MessageNotifyAction.java | 88 ++++
.../rocketmq/mqtt/cs/starter/MqttServer.java | 132 +++++
.../apache/rocketmq/mqtt/cs/starter/RpcServer.java | 65 +++
.../apache/rocketmq/mqtt/cs/starter/Startup.java | 36 ++
.../mqtt/cs/test/TestDefaultChannelManager.java | 60 +++
.../rocketmq/mqtt/cs/test/TestInFlyCache.java | 49 ++
.../rocketmq/mqtt/cs/test/TestMatchAction.java | 69 +++
.../mqtt/cs/test/TestMessageNotifyAction.java | 87 ++++
.../rocketmq/mqtt/cs/test/TestMqttMsgId.java | 38 ++
.../rocketmq/mqtt/cs/test/TestPushAction.java | 96 ++++
.../rocketmq/mqtt/cs/test/TestQueueCache.java | 112 +++++
.../rocketmq/mqtt/cs/test/TestRetryDriver.java | 91 ++++
.../apache/rocketmq/mqtt/cs/test/TestSession.java | 69 +++
.../rocketmq/mqtt/cs/test/TestSessionLoopImpl.java | 157 ++++++
mqtt-ds/pom.xml | 63 +++
.../rocketmq/mqtt/ds/auth/AuthManagerSample.java | 96 ++++
.../rocketmq/mqtt/ds/config/ServiceConf.java | 139 ++++++
.../mqtt/ds/config/ServiceConfListener.java | 73 +++
.../rocketmq/mqtt/ds/meta/FirstTopicManager.java | 162 +++++++
.../mqtt/ds/meta/MetaPersistManagerSample.java | 128 +++++
.../mqtt/ds/meta/TopicNotExistException.java | 41 ++
.../rocketmq/mqtt/ds/meta/WildcardManager.java | 129 +++++
.../org/apache/rocketmq/mqtt/ds/mq/MqAdmin.java | 53 ++
.../org/apache/rocketmq/mqtt/ds/mq/MqConsumer.java | 84 ++++
.../org/apache/rocketmq/mqtt/ds/mq/MqFactory.java | 114 +++++
.../org/apache/rocketmq/mqtt/ds/mq/MqProducer.java | 62 +++
.../apache/rocketmq/mqtt/ds/mq/MqPullConsumer.java | 66 +++
.../rocketmq/mqtt/ds/notify/NotifyManager.java | 286 +++++++++++
.../mqtt/ds/notify/NotifyRetryManager.java | 97 ++++
.../mqtt/ds/store/LmqOffsetStoreManager.java | 155 ++++++
.../mqtt/ds/store/LmqQueueStoreManager.java | 427 ++++++++++++++++
.../mqtt/ds/upstream/UpstreamProcessor.java | 30 ++
.../mqtt/ds/upstream/UpstreamProcessorManager.java | 79 +++
.../mqtt/ds/upstream/processor/BaseProcessor.java | 37 ++
.../ds/upstream/processor/ConnectProcessor.java | 46 ++
.../ds/upstream/processor/DisconnectProcessor.java | 37 ++
.../ds/upstream/processor/PublishProcessor.java | 77 +++
.../ds/upstream/processor/SubscribeProcessor.java | 56 +++
.../upstream/processor/UnSubscribeProcessor.java | 53 ++
.../mqtt/ds/test/TestFirstTopicManager.java | 96 ++++
.../mqtt/ds/test/TestLmqQueueStoreManager.java | 115 +++++
.../rocketmq/mqtt/ds/test/TestNotifyManager.java | 90 ++++
.../rocketmq/mqtt/ds/test/TestWildcardManager.java | 58 +++
mqtt-example/pom.xml | 30 ++
.../apache/rocketmq/mqtt/example/MqttConsumer.java | 98 ++++
.../apache/rocketmq/mqtt/example/MqttProducer.java | 109 +++++
.../rocketmq/mqtt/example/RocketMQConsumer.java | 68 +++
.../rocketmq/mqtt/example/RocketMQProducer.java | 110 +++++
pom.xml | 189 ++++++++
128 files changed, 12695 insertions(+), 1 deletion(-)