szz
/
ShiShiYiBan
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

reactor：【IoT 物联网】实现 alink 的 IotAlinkDeviceMessageCodec，并尝试接入 http 协议

This commit is contained in:
YunaiV 2025-06-09 21:45:19 +08:00
parent 120029bb17
commit 479e0356ad
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
yudao-module-iot/yudao-module-iot-gateway/src/main/java/cn/iocoder/yudao/module/iot/gateway/protocol/http/IotHttpUpstreamProtocol.java
View File

@ -36,11 +36,10 @@ public class IotHttpUpstreamProtocol extends AbstractVerticle {
router.route().handler(BodyHandler.create()); router.route().handler(BodyHandler.create());
// 创建处理器，添加路由处理器 // 创建处理器，添加路由处理器
IotHttpUpstreamHandler upstreamHandler = new IotHttpUpstreamHandler(this);
router.post(IotHttpUpstreamHandler.PROPERTY_PATH).handler(upstreamHandler);
router.post(IotHttpUpstreamHandler.EVENT_PATH).handler(upstreamHandler);
IotHttpAuthHandler authHandler = new IotHttpAuthHandler(this); IotHttpAuthHandler authHandler = new IotHttpAuthHandler(this);
router.post(IotHttpAuthHandler.PATH).handler(authHandler); router.post(IotHttpAuthHandler.PATH).handler(authHandler);
IotHttpUpstreamHandler upstreamHandler = new IotHttpUpstreamHandler(this);
router.post(IotHttpUpstreamHandler.PATH).handler(upstreamHandler);
// 启动 HTTP 服务器 // 启动 HTTP 服务器
try { try {