# Netty-MQTT
基于netty实现mqtt服务器，开发中:)
## TODO
- [x] 参考MQTT3.1.1规范实现
- [x] 完整的QoS服务质量等级实现 ✅
- [x] 遗嘱消息 ✅（仅支持主动关闭、发送失败、失去心跳等场景QoS0~2）
- [x] 保留消息及消息分发重试 ✅
- [x] 心跳机制 PingReq PingRec 长连接保活 ✅
- [x] MQTT连接认证，用户名密码验证 ✅ (可选择是否开启)
- [x] SSL方式连接 ✅ (可选择是否开启)
- [x] 主题过滤 ✅ (支持单主题订阅如 test_topic /mqtt/test --不能以/结尾, 通配符订阅 # /mqtt/# --以#结尾)
- [x] Websocket支持 ✅ (可选择是否开启)
- [ ] Redis-Cluster集群功能(可选择是否开启)
- [x] IP黑名单接口 ✅
- [x] Kafka消息转发功能(可选择是否开启)
- [x] 控制面的监控功能，链路追踪功能
- [ ] 全链路的压力测试
## 目标
1. 心跳维护 ✅
2. 链路监控 ✅
3. 报文监控 ✅
4. 物联网卡流量监控
5. 在线维护 ✅
6. ip黑名单 ✅
7. 多规约支持（代码里就配置了645/698/376/104/二进制/MQTT/充电桩这几种规约，其实支持更多，个人感觉能支持所有规约，至少目前我见到的都能支持)
8. 服务端序列化传输优化（protobuf）
## 技术体系
* 使用 netty 实现通信及协议解析
* 使用 redis 实现消息缓存，集群
* 使用 kafka 实现消息代理(可选)
## 理想架构图
毕业设计&课设--基于netty实现mqtt服务器 <毕业设计>.zip
需积分: 5 153 浏览量
2024-02-20
00:07:22
上传
评论
收藏 133KB ZIP 举报
毕业设计&课设--基于netty实现mqtt服务器 <毕业设计>.zip （150个子文件） 
server-openssl.conf 3KB ca-openssl.conf 540B Dockerfile 166B Dockerfile 158B .gitignore 350B BrokerServer.java 12KB Connect.java 10KB BrokerHandler.java 8KB Subscribe.java 6KB MessageSender.java 6KB SessionStore.java 6KB RedisService.java 6KB InternalSendServer.java 5KB MqttMessageHelper.java 5KB Publish.java 5KB SubscribeNotWildcardCache.java 5KB SubscribeWildcardCache.java 5KB ProtocolProcess.java 4KB RemotingHelper.java 4KB SubscribeStoreService.java 3KB WebMvcConfig.java 3KB TokenInterceptor.java 3KB KafkaService.java 3KB SessionStoreService.java 3KB KafkaConsumerConfiguration.java 3KB JwtUtil.java 3KB ClientController.java 3KB DisConnect.java 3KB CountInfo.java 2KB QpsCounter.java 2KB BrokerConfig.java 2KB RetainMessageCache.java 2KB InternalMessage.java 2KB PacketController.java 2KB PingReq.java 2KB PacketService.java 2KB DupPublishMessageCache.java 2KB StatService.java 2KB RetainMessageStoreService.java 2KB TopicMatcher.java 2KB PubRec.java 2KB BlackIPController.java 2KB DupPubRelMessageCache.java 2KB MonitorController.java 2KB DateUtil.java 2KB ClientService.java 2KB DupPubRelMessageStoreService.java 2KB DupPublishMessageStoreService.java 2KB App.java 2KB DeviceMessage.java 2KB AuthService.java 2KB DeviceMessageBuilder.java 1KB SubscribeService.java 1KB BlackListService.java 1KB SubscribeStore.java 1KB UnSubscribe.java 1KB DupPublishMessageStore.java 1KB ISessionStoreService.java 1KB MessageIdService.java 1KB InternalCommunication.java 1KB CPUMonitorCalc.java 1KB CORSFilter.java 1KB Result.java 1KB AuthController.java 1KB PubComp.java 1KB BlackIP.java 1KB PubAck.java 1KB PwdUtil.java 1KB User.java 1KB LettuceRedisConfig.java 1009B LettuceRedisConfig.java 984B PubRel.java 971B Constant.java 971B PacketMapper.java 951B SessionController.java 948B RsaKeyUtil.java 918B ClientMapper.java 910B RetainMessageStore.java 886B DupPubRelMessageStore.java 871B QpsCounter.java 814B BlackListService.java 785B UserService.java 765B MqttWebSocketCodec.java 763B SubscribeController.java 756B CountHandler.java 752B ServerStateReportJob.java 743B Topic.java 681B ISessionStoreService.java 678B IRetainMessageStoreService.java 644B IDupPublishMessageStoreService.java 586B IDupPubRelMessageStoreService.java 573B Packet.java 525B Packet.java 523B ISubscribeStoreService.java 523B UserMapper.java 512B App.java 510B Metrics.java 510B StoreStarter.java 506B ClusterInfo.java 499B BlackListMapper.java 453B共 150 条
- 1
- 2
资源评论
