# 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 实现消息代理(可选)
## 理想架构图
![](https://image-ihui.oss-cn-beijing.aliyuncs.com/img/20220403231318.png)
![](https://image-ihui.oss-cn-beijing.aliyuncs.com/img/20220403231819.png)
![](https://image-ihui.oss-cn-beijing.aliyuncs.com/img/20220403231833.png)
没有合适的资源?快使用搜索试试~ 我知道了~
基于netty实现mqtt服务器 毕业设计.zip
共150个文件
java:104个
xml:15个
yaml:5个
1.该资源内容由用户上传,如若侵权请联系客服进行举报
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
版权申诉
0 下载量 38 浏览量
2024-03-29
15:18:32
上传
评论
收藏 156KB ZIP 举报
温馨提示
可以用于毕业设计(项目源码+项目说明)目前在window10/11测试环境一切正常,用于演示的图片和部署教程说明都在压缩包里
资源推荐
资源详情
资源评论
收起资源包目录
基于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
资源评论
不走小道
- 粉丝: 3200
- 资源: 5124
下载权益
C知道特权
VIP文章
课程特权
开通VIP
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功