**English** | [中文](README_CN.md)
# Jmqtt
## Features
* Full support of mqtt3.1.1 protocol
* Support data persistence and clustering based on MySQL
* Support friendly secondary development, plug-in development: cluster / storage / device connection, publish subscribe authentication
* Support tcp, websocket, SSL, WSS
* Support cluster based on redis
* Support embedded start use memory but not support cluster
* Support sprint-boot-jmqtt-starter
* Support test cases
## Official documents
[Official documents](http://www.mangdagou.com/)
## Quick start
1. Download [release](https://github.com/Cicizz/jmqtt/releases) (Version above 3. X) Or `clone` this project
2. Execute in the root directory:`mvn -Ppackage-all -DskipTests clean install -U`
3. Configuration file for configuration response:`/jmqtt-broker/resources/conf`
4. Execute the start command:`java -jar jmqtt-broker-3.0.0.jar -h ${conf文件目录}` -H is followed by the configuration file directory, which needs to contain jmqtt.properties And log4j2. XML
## Online trial
Server address: 81.69.46.38
TCP port: 1883
Websocket port: 8883
SSL port: 1884
WSS port: 8884
## QQ technology exchange group
jmqtt:由Java和Netty实现的MQTT代理，支持持久性和集群
需积分: 33 37 浏览量
2021-05-13
13:36:06
上传
评论
收藏 282KB ZIP 举报
jmqtt:由Java和Netty实现的MQTT代理，支持持久性和集群 （196个子文件） 
client.cer 875B runbroker.cmd 1KB jmqttshutdown.cmd 306B jmqttstart.cmd 256B akka.conf 382B Dockerfile 511B .dockerignore 47B spring.factories 121B .gitignore 712B AuthorizationWithDefaultACLTest.groovy 10KB RetainFlagTest.groovy 10KB RetainFlagTest.groovy 10KB MQTTV3AndV5ClientTest.groovy 8KB SessionTest.groovy 6KB SessionTest.groovy 6KB V3CoorelationAndResponseTest.groovy 5KB CoorelationAndResponseTest.groovy 5KB BasicMqttQosTest.groovy 3KB BasicMqtt5QosTest.groovy 3KB DNCTest.groovy 3KB AbstractMqtt5Specification.groovy 3KB AbstractMqtt3Specification.groovy 3KB MqttPayloadFormatAndContentTypeTest.groovy 3KB V1EndToEndTest.groovy 2KB V1EndToEndTest.groovy 2KB ClearSessionTest.groovy 2KB ClearSessionTest.groovy 2KB MessageExpiryTest.groovy 2KB MessageExpiryTest.groovy 2KB DeviceDncV1MessageTest.groovy 2KB TlsOnEmqxTest.groovy 2KB AbstractMqttV1Specification.groovy 1KB AbstractAclMqttSpecification.groovy 1017B
webSocket.html 4KB BrokerController.java 13KB NettyRemotingServer.java 11KB ConnectProcessor.java 11KB RDBSessionStore.java 10KB DefaultSubscriptionTreeMatcher.java 9KB MemSessionStore.java 8KB MqttV1Device.java 8KB ReSendMessageService.java 8KB MixAll.java 7KB MqttAclClientFactory.java 6KB BrokerConfig.java 6KB RedisSessionStore.java 6KB SubscribeProcessor.java 6KB JSONUtil.java 6KB DefaultDispatcherInnerMessage.java 6KB NettyConfig.java 5KB BrokerStartup.java 5KB MessageUtil.java 5KB MqttClientUtils.java 5KB AuthenticationUtil.java 5KB PublishProcessor.java 5KB MqttDeviceInfo.java 4KB EventConsumeHandler.java 4KB DBUtils.java 4KB RemotingHelper.java 4KB Message.java 4KB SessionStore.java 4KB HighPerformanceMessageHandler.java 4KB RDBClusterEventHandler.java 3KB RDBMessageStore.java 3KB DisconnectProcessor.java 3KB BrokerStartupService.java 3KB RedisClusterEventHandler.java 3KB NettyEventExecutor.java 3KB RedisSupportImpl.java 2KB NettySslHandler.java 2KB Runtime.java 2KB NettyConnectHandler.java 2KB MqttClientFactory.java 2KB InflowMessageHandler.java 2KB RedisMessageStore.java 2KB UnSubscribeProcessor.java 2KB AbstractMessageProcessor.java 2KB MqttV1ClientConstant.java 2KB AkkaClusterEventHandler.java 2KB OutflowMessageHandler.java 2KB ClientSession.java 2KB ClientLifeCycleHookService.java 2KB PubRelProcessor.java 2KB AbstractDBStore.java 2KB MemEventHandler.java 2KB Producer.java 2KB HttpRequest.java 2KB Consumer.java 2KB AkkaMain.java 2KB BrokerStartupConfiguration.java 2KB DefaultSubscriptionTreeMatcherTest.java 2KB MemMessageStore.java 2KB PostDatapointHttpRequest.java 1KB Subscription.java 1KB OutflowSecMessageHandler.java 1KB CommonUtils.java 1KB ClusterEventHandler.java 1KB Subscriber.java 1KB PubCompProcessor.java 1KB PubRecProcessor.java 1KB共 196 条
- 1
- 2
评论0