You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2019/01/30 13:56:40 UTC
[rocketmq] branch snode updated (e49c616 -> b3dfa1c)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a change to branch snode
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
from e49c616 Add slow consumer resolve strategy
new 5d60a63 add mqtt protocol support
new 359e443 add mqtt support and fix NPE of shutdown method in SnodeController
new 686b5c7 implement part of logic of mqtt CONNECT request
new 4d88d5b fix checkstyle error
new 7f23433 optimize logic with dispatcher;add some test case
new b3dfa1c Merge pull request #733 from xiangwangcheng/snode
The 635 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../rocketmq/common/protocol/RequestCode.java | 2 +
.../common/protocol/header/mqtt/MqttHeader.java | 221 +++++++++++++++
.../rocketmq/remoting/RemotingServerFactory.java | 2 +-
.../org/apache/rocketmq/remoting/ServerConfig.java | 9 +
.../rocketmq/remoting/common/RemotingUtil.java | 1 +
.../transport/mqtt/DisconnectChannelEvent.java | 19 +-
.../remoting/transport/mqtt/MqttHeader.java | 215 +++++++++++++++
.../mqtt/MqttMessage2RemotingCommandHandler.java | 54 ++++
.../MqttRemotingClient.java} | 28 +-
.../MqttRemotingServer.java} | 190 +++++++------
.../mqtt/RemotingCommand2MqttMessageHandler.java | 43 +++
.../transport/mqtt/RocketMQMqttConnectPayload.java | 112 ++++++++
.../mqtt/dispatcher/EncodeDecodeDispatcher.java | 49 ++++
.../dispatcher/Message2MessageEncodeDecode.java} | 12 +-
.../mqtt/dispatcher/MqttConnectEncodeDecode.java | 70 +++++
.../dispatcher/MqttConnectackEncodeDecode.java | 15 +-
.../org.apache.rocketmq.remoting.RemotingClient | 3 +-
.../org.apache.rocketmq.remoting.RemotingServer | 1 +
.../org/apache/rocketmq/snode/SnodeController.java | 300 +++++++++++++++------
.../org/apache/rocketmq/snode/SnodeStartup.java | 6 +-
.../org/apache/rocketmq/snode/client/Client.java | 16 +-
.../snode/client/ClientHousekeepingService.java | 9 +-
.../rocketmq/snode/client/ClientManager.java | 2 +
.../snode/client/impl/ClientManagerImpl.java | 54 ++--
.../snode/client/impl/IOTClientManagerImpl.java | 12 +
.../apache/rocketmq/snode/config/SnodeConfig.java | 32 ++-
.../rocketmq/snode/constant/MqttConstant.java | 8 +-
.../processor/DefaultMqttMessageProcessor.java | 82 ++++++
.../processor/mqtthandler/MessageHandler.java | 18 +-
.../mqtthandler/MqttConnectMessageHandler.java | 89 ++++++
.../mqtthandler/MqttDisconnectMessageHandler.java | 36 ++-
.../mqtthandler/MqttMessageForwarder.java | 41 ++-
.../processor/mqtthandler/MqttMessageSender.java | 29 +-
.../mqtthandler/MqttPingreqMessageHandler.java | 45 ++--
.../mqtthandler/MqttPubackMessageHandler.java | 40 ++-
.../mqtthandler/MqttPubcompMessageHandler.java | 28 +-
.../mqtthandler/MqttPublishMessageHandler.java | 24 +-
.../mqtthandler/MqttPubrecMessageHandler.java | 28 +-
.../mqtthandler/MqttPubrelMessageHandler.java | 27 +-
.../mqtthandler/MqttSubscribeMessageHandler.java | 54 ++++
.../mqtthandler/MqttUnsubscribeMessagHandler.java | 50 ++++
.../apache/rocketmq/snode/util/MessageUtil.java | 178 ++++++++++++
.../processor/DefaultMqttMessageProcessorTest.java | 109 ++++++++
.../processor/MqttConnectMessageHandlerTest.java | 54 ++++
44 files changed, 2046 insertions(+), 371 deletions(-)
create mode 100644 common/src/main/java/org/apache/rocketmq/common/protocol/header/mqtt/MqttHeader.java
copy common/src/main/java/org/apache/rocketmq/common/filter/impl/Op.java => remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/DisconnectChannelEvent.java (73%)
create mode 100644 remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/MqttHeader.java
create mode 100644 remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/MqttMessage2RemotingCommandHandler.java
copy remoting/src/main/java/org/apache/rocketmq/remoting/transport/{rocketmq/NettyRemotingClient.java => mqtt/MqttRemotingClient.java} (93%)
copy remoting/src/main/java/org/apache/rocketmq/remoting/transport/{rocketmq/NettyRemotingServer.java => mqtt/MqttRemotingServer.java} (62%)
create mode 100644 remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/RemotingCommand2MqttMessageHandler.java
create mode 100644 remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/RocketMQMqttConnectPayload.java
create mode 100644 remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/EncodeDecodeDispatcher.java
copy remoting/src/main/java/org/apache/rocketmq/remoting/{serialize/Serializer.java => transport/mqtt/dispatcher/Message2MessageEncodeDecode.java} (76%)
create mode 100644 remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/MqttConnectEncodeDecode.java
copy filter/src/main/java/org/apache/rocketmq/filter/expression/EmptyEvaluationContext.java => remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/MqttConnectackEncodeDecode.java (69%)
copy acl/src/main/java/org/apache/rocketmq/acl/AccessResource.java => snode/src/main/java/org/apache/rocketmq/snode/constant/MqttConstant.java (72%)
create mode 100644 snode/src/main/java/org/apache/rocketmq/snode/processor/DefaultMqttMessageProcessor.java
copy remoting/src/main/java/org/apache/rocketmq/remoting/serialize/Serializer.java => snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MessageHandler.java (70%)
create mode 100644 snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MqttConnectMessageHandler.java
copy remoting/src/main/java/org/apache/rocketmq/remoting/interceptor/RequestContext.java => snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MqttDisconnectMessageHandler.java (53%)
copy remoting/src/main/java/org/apache/rocketmq/remoting/interceptor/ExceptionContext.java => snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MqttMessageForwarder.java (52%)
copy remoting/src/main/java/org/apache/rocketmq/remoting/interceptor/ResponseContext.java => snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MqttMessageSender.java (58%)
copy remoting/src/main/java/org/apache/rocketmq/remoting/interceptor/ExceptionContext.java => snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MqttPingreqMessageHandler.java (52%)
copy remoting/src/main/java/org/apache/rocketmq/remoting/interceptor/RequestContext.java => snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MqttPubackMessageHandler.java (54%)
copy remoting/src/main/java/org/apache/rocketmq/remoting/interceptor/ResponseContext.java => snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MqttPubcompMessageHandler.java (59%)
copy remoting/src/main/java/org/apache/rocketmq/remoting/interceptor/ResponseContext.java => snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MqttPublishMessageHandler.java (63%)
copy remoting/src/main/java/org/apache/rocketmq/remoting/interceptor/ResponseContext.java => snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MqttPubrecMessageHandler.java (60%)
copy remoting/src/main/java/org/apache/rocketmq/remoting/interceptor/ResponseContext.java => snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MqttPubrelMessageHandler.java (60%)
create mode 100644 snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MqttSubscribeMessageHandler.java
create mode 100644 snode/src/main/java/org/apache/rocketmq/snode/processor/mqtthandler/MqttUnsubscribeMessagHandler.java
create mode 100644 snode/src/main/java/org/apache/rocketmq/snode/util/MessageUtil.java
create mode 100644 snode/src/test/java/org/apache/rocketmq/snode/processor/DefaultMqttMessageProcessorTest.java
create mode 100644 snode/src/test/java/org/apache/rocketmq/snode/processor/MqttConnectMessageHandlerTest.java