From b129a354bd7a0b2f892c537e30b8c46c3d1691ff Mon Sep 17 00:00:00 2001
From: PandaX <18610165312@163.com>
Date: Wed, 25 Oct 2023 10:31:16 +0800
Subject: [PATCH] =?UTF-8?q?[fix]=E5=B9=B3=E5=8F=B0=E5=8F=91=E9=80=81?=
 =?UTF-8?q?=E7=9A=84mqtt=20push=E6=94=BE=E8=A1=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 iothub/server/emqxserver/hook.go      | 6 +++++-
 iothub/server/udpserver/udp_server.go | 2 --
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/iothub/server/emqxserver/hook.go b/iothub/server/emqxserver/hook.go
index ff8c145..e6db93e 100644
--- a/iothub/server/emqxserver/hook.go
+++ b/iothub/server/emqxserver/hook.go
@@ -175,7 +175,11 @@ func (s *HookGrpcService) OnMessagePublish(ctx context.Context, in *exhook2.Mess
 	res := &exhook2.ValuedResponse{}
 	res.Type = exhook2.ValuedResponse_STOP_AND_RETURN
 	res.Value = &exhook2.ValuedResponse_BoolResult{BoolResult: false}
-
+	//服务端的HTTP请求放行
+	if in.GetMessage().From == "http_api" {
+		res.Value = &exhook2.ValuedResponse_BoolResult{BoolResult: true}
+		return res, nil
+	}
 	etoken := &global_model.DeviceAuth{}
 	etoken.GetDeviceToken(in.Message.Headers["username"])
 	// 获取topic类型
diff --git a/iothub/server/udpserver/udp_server.go b/iothub/server/udpserver/udp_server.go
index de4ae75..e7da2d6 100644
--- a/iothub/server/udpserver/udp_server.go
+++ b/iothub/server/udpserver/udp_server.go
@@ -2,7 +2,6 @@ package updserver
 
 import (
 	"context"
-	"fmt"
 	"net"
 	"pandax/pkg/global"
 )
@@ -38,7 +37,6 @@ func (s *UdpServer) Start(ctx context.Context) error {
 		global.Log.Errorf("error http serve: %s", err)
 		return err
 	}
-	fmt.Println("UDP server started, listening on", listener.LocalAddr().String())
 	s.listener = listener
 	return nil
 }