mqttx:MQTTX Project 完整实现 mqttv3.1.1 协议，旨在提供易于使用且性能优异的 mqtt broke...
需积分: 20 126 浏览量
2021-05-03
02:40:09
上传
评论
收藏 186KB ZIP 举报
mqttx-v1.0.zip （89个子文件） 
mqttx-1.0 
mvnw.cmd 6KB mvnw 10KB src main resources tls mqttx.keystore 2KB readme.md 59B application-dev.yml 2KB application-prod.yml 26B META-INF additional-spring-configuration-metadata.json 538B application-test.yml 1KB
banner.txt 250B application.yml 406B java com jun mqttx consumer KafkaInternalMessageSubscriber.java 3KB Watcher.java 1KB DefaultInternalMessageSubscriber.java 1KB AbstractInnerChannel.java 3KB constants InternalMessageEnum.java 1KB SerializeStrategy.java 154B ClusterTopic.java 1KB ShareStrategy.java 870B service IAuthenticationService.java 3KB IPublishMessageService.java 1KB IPubRelMessageService.java 2KB ISessionService.java 2KB impl DefaultInternalMessagePublishServiceImpl.java 954B DefaultPublishMessageServiceImpl.java 3KB DefaultRetainMessageServiceImpl.java 3KB DefaultSessionServiceImpl.java 3KB KafkaInternalMessagePublishServiceImpl.java 977B DefaultAuthenticationServiceImpl.java 899B DefaultPubRelMessageServiceImpl.java 5KB DefaultSubscriptionServiceImpl.java 21KB IInternalMessagePublishService.java 1KB ISubscriptionService.java 3KB IRetainMessageService.java 1KB utils TopicUtils.java 10KB GlobalExecutor.java 3KB RateLimiter.java 2KB MessageIdUtils.java 1KB SslUtils.java 3KB KryoSerializer.java 2KB Serializer.java 1KB JsonSerializer.java 1KB exception GlobalException.java 1KB AuthorizationException.java 906B AuthenticationException.java 1KB SslException.java 1KB config MqttxConfig.java 8KB SerializeConfig.java 861B ClusterConfig.java 6KB RedisConfig.java 1KB entity ClientAuthDTO.java 1KB TopicRateLimit.java 365B PubRelMsg.java 794B ClientSubOrUnsubMsg.java 1KB BrokerStatus.java 2KB ClientSub.java 3KB Session.java 5KB PubMsg.java 2KB Authentication.java 1KB InternalMessage.java 1KB MqttxApplication.java 4KB broker BrokerHandler.java 15KB codec MqttWebsocketCodec.java 1KB handler PublishHandler.java 20KB AbstractMqttTopicSecureHandler.java 2KB SubscribeHandler.java 18KB PubComHandler.java 2KB ConnectHandler.java 16KB PingReqHandler.java 1KB Handler.java 1KB PubRelHandler.java 2KB PubRecHandler.java 3KB DisconnectHandler.java 3KB MqttMessageHandler.java 1KB MessageDelegatingHandler.java 3KB ProbeHandler.java 3KB AbstractMqttSessionHandler.java 5KB UnsubscribeHandler.java 3KB PubAckHandler.java 2KB BrokerInitializer.java 12KB dockerfile 165B LICENSE 11KB .mvn wrapper MavenWrapperDownloader.java 5KB
maven-wrapper.jar 50KB maven-wrapper.properties 218B pom.xml 4KB docker-compose.yml 186B .gitignore 353B readme.md 30KB readme_en.md 25KB资源评论
