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 }