# 此项目暂停维护
[请使用新项目](https://github.com/quickmsg/smqtt)
# iot_push
基于netty+mqtt 3.1.1协议开发的物联网消息推送框架
## 项目目录
* [mqtt简介](#1)
* [功能](#2)
* [如何使用](#3)
## 更新日志
基于netty4.1-final+springboot实现的 Mqtt 3.1.1 物联网标准推送协议
## <a name="1">mqtt简介</a>
MQTT 协议是 IBM 开发的即时通讯协议,相对于 IM 的实际上的准标准协议 XMPP 来说,MQTT 更小,更快,更轻量。MQTT 适合于任何计算能力有限,工作在低带宽、不可靠的网络中的设备,包括手机,传感器等等。
## <a name="2">功能</a>
**## 服务端 example(iot_push_server_starter_test)**
#### 已实现:
* 发布订阅功能
* 遗言通知
* 会话session数据
* 发布保留消息
* 主题过滤(/test 会接受到 /test/yy 的主题消息)
* 实现标准的 qos0 qos1 qos2消息确认机制
* ssl加密
* 支持ws协议
* 集成spring容器
#### <a name="3">如何使用</a>
* 安装lombok插件
* 下载源码
* springboot
* jdk8
* 导入IDE
* 配置yml 或者properties 文件 [yml](https://github.com/1ssqq1lxr/iot_push/blob/master/iot_push_server_starter_test/src/main/resources/application.yml)
* 简单测试:运行包 test 下的 测试 文件,即可开启测试客户端。
* 压力测试:推荐使用jmeter 的mqtt插件 [插件](https://github.com/tuanhiep/mqtt-jmeter)
**## 客户端 example(iot_push_client_starter_test)**
* 基于springboot 配置方式[yml](https://github.com/1ssqq1lxr/iot_push/blob/master/iot_push_client_starter_test/src/main/resources/application.yml)
* 配置实现 MqttListener 类并添加MqttMessageListener指定订阅的topic跟服务质量
* @Autowired Procuder producer 即可使用;
* 编码 [java](https://github.com/1ssqq1lxr/iot_push/blob/master/iot_push_client_starter_test/src/main/java/com/lxr/iot/example/MqttMain.java)
qq群号: 789331252
### 关注公众号,输入 `物联网` 扫码加入交流群
![image](image/icon.jpg)
没有合适的资源?快使用搜索试试~ 我知道了~
基于netty+mqtt3.1.1+springboot+jdk8 实现的 mqtt 服务端跟客户端.zip
共113个文件
java:87个
xml:8个
iml:7个
1.该资源内容由用户上传,如若侵权请联系客服进行举报
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
版权申诉
5星 · 超过95%的资源 1 下载量 144 浏览量
2024-04-08
22:01:01
上传
评论 1
收藏 153KB ZIP 举报
温馨提示
可以用于毕业设计(项目源码+项目说明)目前在window10/11测试环境一切正常,用于演示的图片和部署教程说明都在压缩包里
资源推荐
资源详情
资源评论
收起资源包目录
基于netty+mqtt3.1.1+springboot+jdk8 实现的 mqtt 服务端跟客户端.zip (113个子文件)
spring.factories 103B
spring.factories 101B
iot_push_common.iml 10KB
iot_push_test.iml 9KB
iot_push_server_starter.iml 9KB
iot_push_client_starter.iml 9KB
iot_push_client.iml 9KB
iot_push_server.iml 9KB
iot_push.iml 574B
SecureSocketKeyStore.java 26KB
MqttChannelService.java 20KB
ZkUtils.java 11KB
testZk.java 10KB
AbsMqttProducer.java 10KB
MqttHandlerService.java 9KB
PublishApiSevice.java 7KB
RemotingUtil.java 7KB
MqttProducerConfigure.java 5KB
AbstractBootstrapServer.java 5KB
DefaultMqttHandler.java 5KB
MqttHandlerServiceService.java 5KB
IdWorker.java 5KB
NettyBootstrapServer.java 5KB
MqttProducer.java 4KB
MqttApi.java 4KB
StandardThreadExecutor.java 4KB
MqttClientProducerTest.java 4KB
DefaultMqttHandler.java 4KB
AbstractChannelService.java 3KB
CacheMap.java 3KB
MqttClientConsumerTest.java 3KB
SecureSocketSslContextFactory.java 3KB
MqttClientConsumerTest1.java 3KB
MqttChannel.java 3KB
SacnScheduled.java 2KB
X509CertTool.java 2KB
ServerAutoConfigure.java 2KB
MessageHandler.java 2KB
MqttMain.java 2KB
SecureSokcetTrustManagerFactory.java 2KB
ExecutorQueue.java 2KB
main.java 2KB
BaseApi.java 2KB
AbstractBootstrapClient.java 2KB
MessageTransfer.java 2KB
IpUtils.java 2KB
WillService.java 2KB
MqttHander.java 2KB
DefaultThreadFactory.java 1KB
ConnectOptions.java 1KB
DisruptorMessageStarter.java 1KB
SpringBeanUtils.java 1KB
ScanRunnable.java 1KB
ScheduledPool.java 1KB
ClientSessionService.java 1KB
ChannelService.java 1KB
InitBean.java 1021B
Producer.java 878B
ServerMqttHandlerService.java 865B
ByteBufToWebSocketFrameEncoder.java 788B
ClientMqttHandlerService.java 785B
InitServer.java 769B
WebSocketFrameToByteBufDecoder.java 700B
Cache.java 688B
SubListener.java 668B
MyListener.java 661B
MessageId.java 635B
MqttHandlerIntf.java 615B
ServerApplication.java 608B
SendMqttMessage.java 564B
ZkStateListener.java 525B
SendMqttMessage.java 516B
App.java 416B
SessionMessage.java 416B
springTest.java 408B
StreamReader.java 384B
ByteBufUtil.java 373B
RetainMessage.java 368B
MqttMessageListener.java 362B
DefaultAutoService.java 347B
WillMeaasge.java 316B
BootstrapServer.java 306B
SubMessage.java 293B
QosStatus.java 273B
BootstrapClient.java 252B
ConnectionException.java 246B
Scheduled.java 241B
NoFindHandlerException.java 236B
ConfirmStatus.java 217B
MqttListener.java 208B
SessionStatus.java 202B
BaseAuthService.java 200B
MessageEvent.java 186B
MessageStarter.java 175B
ProtocolEnum.java 174B
SubStatus.java 151B
securesocket.jks 2KB
securesocket.jks 2KB
securesocket.jks 2KB
icon.jpg 26KB
共 113 条
- 1
- 2
资源评论
- 花敗、心亦凉2024-04-17资源和描述一致,质量不错,解决了我的问题,感谢资源主。
不走小道
- 粉丝: 3174
- 资源: 3972
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功