mqtt 集群模式开启HTTP授权认证，后台报异常，发送的是google protobuf数据不知道什么原因

350073301 · 2023 年2 月 24 日 08:27

错误报告

2023-02-24 14:47:33,233 ERROR - reg心跳报错：Connection reset by peer
MQTTnet.Exceptions.MqttCommunicationException: Connection reset by peer
—> System.Net.Sockets.SocketException (104): Connection reset by peer
at System.Net.Sockets.Socket.AwaitableSocketAsyncEventArgs.CreateException(SocketError error, Boolean forAsyncThrow)
at System.Net.Sockets.Socket.AwaitableSocketAsyncEventArgs.ReceiveAsync(Socket socket, CancellationToken cancellationToken)
at System.Net.Sockets.Socket.ReceiveAsync(Memory1 buffer, SocketFlags socketFlags, Boolean fromNetworkStream, CancellationToken cancellationToken) at System.Net.Sockets.NetworkStream.ReadAsync(Byte[] buffer, Int32 offset, Int32 size, CancellationToken cancellationToken) at MQTTnet.Implementations.MqttTcpChannel.ReadAsync(Byte[] buffer, Int32 offset, Int32 count, CancellationToken cancellationToken) at System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[TStateMachine](TStateMachine& stateMachine) at MQTTnet.Implementations.MqttTcpChannel.ReadAsync(Byte[] buffer, Int32 offset, Int32 count, CancellationToken cancellationToken) at MQTTnet.Adapter.MqttChannelAdapter.ReadFixedHeaderAsync(CancellationToken cancellationToken) at System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[TStateMachine](TStateMachine& stateMachine) at MQTTnet.Adapter.MqttChannelAdapter.ReadFixedHeaderAsync(CancellationToken cancellationToken) at MQTTnet.Adapter.MqttChannelAdapter.ReceiveAsync(CancellationToken cancellationToken) at System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[TStateMachine](TStateMachine& stateMachine) at MQTTnet.Adapter.MqttChannelAdapter.ReceiveAsync(CancellationToken cancellationToken) at MQTTnet.Adapter.MqttChannelAdapter.ReceivePacketAsync(CancellationToken cancellationToken) at System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[TStateMachine](TStateMachine& stateMachine) at MQTTnet.Adapter.MqttChannelAdapter.ReceivePacketAsync(CancellationToken cancellationToken) at MQTTnet.Client.MqttClient.TryReceivePacketsAsync(CancellationToken cancellationToken) at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state) at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.AsyncStateMachineBox1.MoveNext(Thread threadPoolThread) at System.Threading.Tasks.AwaitTaskContinuation.RunOrScheduleAction(IAsyncStateMachineBox box, Boolean allowInlining) at System.Threading.Tasks.Task.RunContinuations(Object continuationObject) at System.Threading.Tasks.Task1.TrySetResult(TResult result)
at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.SetExistingTaskResult(Task1 task, TResult result)
at MQTTnet.Adapter.MqttChannelAdapter.ReceivePacketAsync(CancellationToken cancellationToken)
at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state)
at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.AsyncStateMachineBox1.MoveNext(Thread threadPoolThread)
at System.Threading.Tasks.AwaitTaskContinuation.RunOrScheduleAction(IAsyncStateMachineBox box, Boolean allowInlining)
at System.Threading.Tasks.Task.RunContinuations(Object continuationObject)
at System.Threading.Tasks.Task1.TrySetResult(TResult result) at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.SetExistingTaskResult(Task1 task, TResult result) at MQTTnet.Adapter.MqttChannelAdapter.ReceiveAsync(CancellationToken cancellationToken) at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state) at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.AsyncStateMachineBox1.MoveNext(Thread threadPoolThread) at System.Threading.Tasks.AwaitTaskContinuation.RunOrScheduleAction(IAsyncStateMachineBox box, Boolean allowInlining) at System.Threading.Tasks.Task.RunContinuations(Object continuationObject) at System.Threading.Tasks.Task1.TrySetResult(TResult result)
at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.SetExistingTaskResult(Task1 task, TResult result)
at MQTTnet.Adapter.MqttChannelAdapter.ReadFixedHeaderAsync(CancellationToken cancellationToken)
at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state)
at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.AsyncStateMachineBox1.MoveNext(Thread threadPoolThread)
at System.Threading.Tasks.AwaitTaskContinuation.RunOrScheduleAction(IAsyncStateMachineBox box, Boolean allowInlining)
at System.Threading.Tasks.Task.RunContinuations(Object continuationObject)
at System.Threading.Tasks.Task1.TrySetResult(TResult result) at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.SetExistingTaskResult(Task1 task, TResult result) at MQTTnet.Implementations.MqttTcpChannel.ReadAsync(Byte[] buffer, Int32 offset, Int32 count, CancellationToken cancellationToken) at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state) at System.Runtime.CompilerServices.AsyncTaskMethodBuilder1.AsyncStateMachineBox1.MoveNext(Thread threadPoolThread) at System.Threading.Tasks.AwaitTaskContinuation.RunOrScheduleAction(IAsyncStateMachineBox box, Boolean allowInlining) at System.Threading.Tasks.Task.RunContinuations(Object continuationObject) at System.Threading.Tasks.Task1.TrySetResult(TResult result)
at System.Threading.Tasks.ValueTask1.ValueTaskSourceAsTask.<>c.<.cctor>b__4_0(Object state) at System.Net.Sockets.Socket.AwaitableSocketAsyncEventArgs.InvokeContinuation(Action1 continuation, Object state, Boolean forceAsync, Boolean requiresExecutionContextFlow)
at System.Net.Sockets.SocketAsyncEngine.System.Threading.IThreadPoolWorkItem.Execute()
at System.Threading.ThreadPoolWorkQueue.Dispatch()
— End of stack trace from previous location —
at MQTTnet.Implementations.MqttTcpChannel.ReadAsync(Byte[] buffer, Int32 offset, Int32 count, CancellationToken cancellationToken)
at MQTTnet.Adapter.MqttChannelAdapter.ReadFixedHeaderAsync(CancellationToken cancellationToken)
at MQTTnet.Adapter.MqttChannelAdapter.ReceiveAsync(CancellationToken cancellationToken)
at MQTTnet.Adapter.MqttChannelAdapter.ReceivePacketAsync(CancellationToken cancellationToken)
— End of inner exception stack trace —
at MQTTnet.Adapter.MqttChannelAdapter.WrapAndThrowException(Exception exception)
at MQTTnet.Adapter.MqttChannelAdapter.ReceivePacketAsync(CancellationToken cancellationToken)
at MQTTnet.Client.MqttClient.TryReceivePacketsAsync(CancellationToken cancellationToken)
at MQTTnet.PacketDispatcher.MqttPacketAwaiter1.WaitOneAsync(TimeSpan timeout) at MQTTnet.PacketDispatcher.MqttPacketAwaiter1.WaitOneAsync(TimeSpan timeout)
at MQTTnet.PacketDispatcher.MqttPacketAwaiter1.WaitOneAsync(TimeSpan timeout) at MQTTnet.PacketDispatcher.MqttPacketAwaiter1.WaitOneAsync(TimeSpan timeout)
at MQTTnet.PacketDispatcher.MqttPacketAwaiter1.WaitOneAsync(TimeSpan timeout) at MQTTnet.PacketDispatcher.MqttPacketAwaiter1.WaitOneAsync(TimeSpan timeout)
at MQTTnet.Client.MqttClient.SendAndReceiveAsync[TResponsePacket](MqttBasePacket requestPacket, CancellationToken cancellationToken)
at MQTTnet.PacketDispatcher.MqttPacketAwaiter1.WaitOneAsync(TimeSpan timeout) at MQTTnet.Client.MqttClient.SendAndReceiveAsync[TResponsePacket](MqttBasePacket requestPacket, CancellationToken cancellationToken) at MQTTnet.PacketDispatcher.MqttPacketAwaiter1.WaitOneAsync(TimeSpan timeout)
at MQTTnet.PacketDispatcher.MqttPacketAwaiter1.WaitOneAsync(TimeSpan timeout) at MQTTnet.PacketDispatcher.MqttPacketAwaiter1.WaitOneAsync(TimeSpan timeout)
at MQTTnet.PacketDispatcher.MqttPacketAwaiter1.WaitOneAsync(TimeSpan timeout) at MQTTnet.PacketDispatcher.MqttPacketAwaiter1.WaitOneAsync(TimeSpan timeout)
at MQTTnet.Client.MqttClient.SendAndReceiveAsync[TResponsePacket](MqttBasePacket requestPacket, CancellationToken cancellationToken)
at MQTTnet.PacketDispatcher.MqttPacketAwaiter`1.WaitOneAsync(TimeSpan timeout)
at MQTTnet.Client.MqttClient.SendAndReceiveAsync[TResponsePacket](MqttBasePacket requestPacket, CancellationToken cancellationToken)

环境

EMQX 版本：
操作系统版本：

重现此问题的步骤

xxx
xxx
xxx

预期行为

实际行为

功能请求

描述你需要的功能

为什么你需要这个功能

其他

t1ger · 2023 年2 月 24 日 08:55

你好，请提供一下 EMQX 的版本以及日志，版本可以在 Dashboard 首页上直接看到，日志的位置可以看下文件输出日志。

350073301 · 2023 年2 月 24 日 09:23

版本5.0.11

错误日志：

2023-02-24T09:19:44.287824+00:00 [error] clientid: eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJjb21cGUiOiJlbnRlcnByaXNlIiwidG9rZW5UeXBlIjoxLCJleHAiOjE2NzcyMDQwMDAsInNhYXNVc2VySWQiOjQ2MDQzOCwianRpIjoiNDA5NDlmODYtMTVkZi00YjQ4LWI5NDUtZTNlMGExOWRhY2FiIiwiY2xpZW50X2lkIjoiNWVjMmYyYmI2NmYxNDIxYmJkMzJjMDc1MTNhNzI4MjQifQ.OlQE6RpmyAKUcBnEUJmDojEMopJ9bcr1FHfJ8t7fAsE, line: 111, mfa: emqx_authz_http:authorize/4, msg: http_server_query_failed, peername: 10.0.153.149:58447, reason: {ehttpc_worker_down,{shutdown,{gen_server,call,[<0.1160.1187>,{post,{“/vcs/mqtt/security/authz/%7Bpeercert%7D?clientid=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJjb21wYW55SWQiOjQxMzU0LCJjbGllbnRUeXBlIjo2LCJ1c2VyX25hbWUiOiI0NjA0MzgiLCJzY29wZSI6WyJhbGwiXSwidXNlclR5cGUiOiJlbnRlcnByaXNlIiwidG9rZW5UeXBlIjoxLCJleHAiOjE2NzcyMDQwMDAsInNVjMmYyYmI2NmYxNDIxYmJkMzJjMDc1MTNhNzI4MjQifQ.OlQE6RpmyAKUcBnEUJmDojEMopJ9bcr1FHfJ8t7fAsE”,[{<<“accept”>>,<<“application/json”>>},{<<“cache-control”>>,<<“no-cache”>>},{<<“connection”>>,<<“keep-alive”>>},{<<“content-type”>>,<<“application/json”>>},{<<“keep-alive”>>,<<“timeout=30, max=1000”>>}],<<“{"action":"publish","topic":"vcs/reg/faa60910072d42d1a0923a69018b69d5/eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJjb21wYW55SWQiOjQxMzU0LCJjbGllbnRUeXBlIjo2LCJ1c2VyX25hbWUiOiI0NjA0MzgiLCJzY29wZSI6WyJhbGwiXSwidXNlclR5cGUiOiJlbnRlcnByaXNlIiwidG9rZW5UeXBlIjoxLCJleHAiOjE2NzcyMDQwMDAsInNhYXNVc2VySWQiOjQ2MDQzOCwianRpIjoiNDA5NDlmODYtMTVkZi00YjQ4LWI5N”…>>},1677230389278},5500]}}}, resource: <<“emqx_authz_http:29847993”>>
2023-02-24T09:19:44.288034+00:00 [error] clientid: eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJjb2YxNDIxYmJkMzJjMDc1MTNhNzI4MjQifQ.NbvZmVHD_M02I0_QVQguGDpW8qSMt8L1ytaUaHWR9s4, line: 111, mfa: emqx_authz_http:authorize/4, msg: http_server_query_failed, peername: 10.0.153.149:15916, reason: {emqx_resource,#{msg => <<“resource not connected”>>,reason => not_connected}}, resource: <<“emqx_authz_http:29847993”>>
2023-02-24T09:19:44.288317+00:00 [error] clientid: eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJjb21wYW55SWQiOjQxMzU0LCJjbGllbnRUeXBlIjo2LCJ1c2VyX25hbWUiOiI0NjA0MzgiLCJzY29wZSI6WyJhbGwiXSwidXNlclR5cGUiOiJlbnRlcnByaXNlIiwidG9rZW5UeXBlIjoxLCJleHAiOjE2NzcyMDQwMDAsInNhYXNVIjoiNWVjMmYyYmI2NmYxNDIxYmJkMzJjMDc1MTNhNzI4MjQifQ.OlQE6RpmyAKUcBnEUJmDojEMopJ9bcr1FHfJ8t7fAsE, exception: error, failed_call: {emqx_authz,authorize,[#{clientid => <<“eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJjb21wYW55SWQiOjQxMzU0LCJjbGllbnRUeXBlIjo2LCJ1c2VyX25hbWUiOiI0NjA0MzgiLCJzY29wZSI6WyJhbGwiXSwidXNlclR5cGUiOiJlbnRlcnByaXNlIiwidG9rZW5UeXBlIjoxLCJleHAiOjE2NzcyMDQwMDAsInNhYXN50X2lkIjoiNWVjMmYyYmI2NmYxNDIxYmJkMzJjMDc1MTNhNzI4MjQifQ.OlQE6RpmyAKUcBnEUJmD”…>>,enable_authn => true,is_bridge => false,is_superuser => false,listener => ‘tcp:default’,mountpoint => undefined,peerhost => {10,0,153,149},protocol => mqtt,sockport => 1883,username => undefined,zone => default},publish,<<“vcs/reg/faa60910072d42d1a0923a69018b69d5/eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJjb21wYW55SWQiOjQxMzU0LCJjbGllbnRUeXBlIjo2L0YjQ4LWI5NDUtZTNlMGExOWRhY2FiIiwiY2xpZW50X2lkIjoiNWVjMmYyYmI2NmYxNDIxYm”…>>,#{from => default,result => allow},[#{annotations => #{id => <<“emqx_authz_http:29847993”>>},base_path_templete => [{str,<<“vcs/mqtt/security/authz/{peercert}”>>}],base_query_template => [{tuple,[{tmpl,[{str,<<“clientid”>>}]},{tmpl,[{var,{var,<<“clientid”>>}}]}]}],base_url => #{host => {192,168,4,188},path => “/”,port => 80,scheme => http},body => #{action => <<“${action}”>>,topic => <<“${topic}”>>,username => <<“${username}”>>},body_template => [{tuple,[{value,action},{tmpl,[{var,{var,<<“action”>>}}]}]},{tuple,[{value,topic},{tmpl,[{var,{var,<<“topic”>>}}]}]},{tuple,[{value,username},{tmpl,[{var,{var,<<“username”>>}}]}]}],connect_timeout => 5000,enable => true,enable_pipelining => 100,headers => [{<<“accept”>>,<<“application/json”>>},{<<“cache-control”>>,<<“no-cache”>>},{<<“connection”>>,<<“keep-alive”>>},{<<“content-type”>>,<<“application/json”>>},{<<“keep-alive”>>,<<“timeout=30, max=1000”>>}],method => post,pool_size => 8,pool_type => random,request_timeout => 5000,ssl => #{ciphers => [],depth => 10,enable => false,reuse_sessions => true,secure_renegotiate => true,user_lookup_fun => {fun emqx_tls_psk:lookup/3,undefined},verify => verify_peer,versions => [‘tlsv1.3’,‘tlsv1.2’,‘tlsv1.1’,tlsv1]},type => http,url => <<“http://192.168.4.188/vcs/mqtt/security/authz/{peercert}?clientid=${clientid}”>>},#{annotations => #{rules => [{allow,{username,{eq,<<“^dashboard?”>>}},subscribe,[[<<“$SYS”>>,‘#’]]},{allow,{ipaddr,{{127,0,0,1},{127,0,0,1},32}},all,[[<<“$SYS”>>,‘#’],[‘#’]]},{deny,all,subscribe,[[<<“$SYS”>>,‘#’],{eq,[‘#’]}]},{allow,all,all,[[‘#’]]}]},enable => true,path => “etc/acl.conf”,type => file}]]}, line: 210, mfa: emqx_hooks:safe_execute/2, msg: failed_to_execute, peername: 10.0.153.149:58447, reason: {case_clause,{ignore,http}}, stacktrace: [{emqx_authz,authorize_non_superuser,5,[{file,“emqx_authz.erl”},{line,338}]},{emqx_hooks,safe_execute,2,[{file,“emqx_hooks.erl”},{line,200}]},{emqx_hooks,do_run_fold,3,[{file,“emqx_hooks.erl”},{line,180}]},{emqx_access_control,do_authorize,3,[{file,“emqx_access_control.erl”},{line,128}]},{emqx_access_control,check_authorization_cache,3,[{file,“emqx_access_control.erl”},{line,89}]},{emqx_access_control,authorize,3,[{file,“emqx_access_control.erl”},{line,80}]},{emqx_channel,check_pub_authz,2,[{file,“emqx_channel.erl”},{line,1851}]},{emqx_misc,pipeline,3,[{file,“emqx_misc.erl”},{line,159}]},{emqx_channel,process_publish,2,[{file,“emqx_channel.erl”},{line,641}]},{emqx_connection,with_channel,3,[{file,“emqx_connection.erl”},{line,790}]},{emqx_connection,process_msg,2,[{file,“emqx_connection.erl”},{line,466}]},{emqx_connection,process_msg,2,[{file,“emqx_connection.erl”},{line,472}]},{emqx_connection,handle_recv,3,[{file,“emqx_connection.erl”},{line,428}]},{proc_lib,wake_up,3,[{file,“proc_lib.erl”},{line,236}]}]

350073301 · 2023 年2 月 24 日 10:49

2023-02-24T10:45:57.183104+00:00 [error] clientid: eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJjb21wYW55SWQiOjQxMzU0LCJjbGllbnRUeXBlIjo2LCJ1c2VyX25hbWUiOiI0ODUzOTIiLCJzY29wZSI6WyJh R5cGUiOiJlbnRlcnByaXNlIiwidG9rZW5UeXBlIjoxLCJleHAiOjE2NzcyMTk0NDUsInNhYXN NWVjMmYyYmI2NmYxNDIxYmJkMzJjMDc1MTNhNzI4MjQifQ.ePRYrTIQgPXOEHLOi4FtUX2yhTKwh5M0UAqaf_Bv40s, line: 1275, mfa: emqx_channel:handle_info/2, msg: unexpected_sock_close, peername: 10.0.153.149:65346, reason: einval

t1ger · 2023 年2 月 27 日 01:40

你好，我看到你的日志中出现了 case_clause，这应该是一个 Bug，并且会影响正常使用，我们会尽快修复它

350073301 · 2023 年2 月 27 日 02:45

谢谢，不知道跟什么有关系，能说明一下，我测试环境是好的，感觉是某些场景会出问题，另外修复了能同步回复一下这个问题吗，我好更新

t1ger · 2023 年2 月 27 日 02:48

他会在 HTTP 请求失败时出现问题，如果确定了修复版本，我会立即和你同步。

350073301 · 2023 年2 月 28 日 08:18

他会在 HTTP 请求失败时出现问题 ,这个是我的接口定义有问题吗，我测试环境没问题，我想先看看是不是哪里有问题，怎么查看

350073301 · 2023 年2 月 28 日 08:18

他会在 HTTP 请求失败时出现问题 ,这个是我的接口定义有问题吗，我测试环境没问题，我想先看看是不是我定义接口哪里有问题，怎么查看

t1ger · 2023 年2 月 28 日 08:20

比如请求过程中网络连接断开，那么这次请求就会失败。又或者是请求超时了，也会导致请求失败。

请求失败是一个不可避免的事情，但不应该导致这个错误，这是 EMQX 这边的一个 Bug。

350073301 · 2023 年2 月 28 日 08:50

你们大概什么时候可以改好

350073301 · 2023 年2 月 28 日 10:25

建议官方访问控制的授权把publish和subscribe分开鉴权，因为发现这个问题引起是因为服务端当作mqtt的客户端发送，需要鉴权的HTTP请求太多，卡死了

t1ger · 2023 年2 月 28 日 10:37

你好，你是指通过 HTTP API 来发布消息吗？这个是不经过鉴权的。

350073301 · 2023 年2 月 28 日 11:17

不是api来发布的，发送“{“action”:“publish”,“topic”:"vcs/reg/faa60910072d 是会鉴权的，我都看到了日志里面都是发送来请求鉴权接口了

t1ger · 2023 年2 月 28 日 13:14

了解，所以你是有一个后端服务在向EMQX发布消息对吧？所以你说消息量很大

t1ger · 2023 年2 月 28 日 15:36

你好，最新的版本中已经修复了这个错误，你可以升级一下

350073301 · 2023 年3 月 2 日 01:22

是的

350073301 · 2023 年3 月 2 日 01:22

感谢

350073301 · 2023 年3 月 2 日 03:15

我升级到5.0.19版本之后，整个mqtt消息都不行，你们稍微看一下

2023-03-02T02:42:46.999103+00:00 [warning] msg: authorization_permission_denied, mfa: emqx_authz:authorize_non_superuser/5, line: 357, peername: :38180, clientid: eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJjb21wYW55SWQiOjg4NiwiY2xpZW50VHlwZSI6NiwidXNlcl9uYW1lIjoiNTc4Iiwic2NvcGUiOlsiYWxsIl0sInVzZXJUeXBlIjoiZW50ZXJwcmlzZSIsInRva2VuVHlwZSI6MSwiZXhwIjoxNjc3ODEwOTI0LCJzYWFzVXNlcklkIjo1NzgsImp0aSI6IjJmZTYwOTFlLWU0ZTAtNDM5YS1hMzM3LWY3Y2ZjNGYyNzdmOCIsImNsaWVudF9pZCI6IjVlYzJmMmJiNjZmMTQyMWJiZDMyYzA3NTEzYTcyODI0In0.7hrRVM46PwWuHcrU3HzQfvzWiIW8F00VWUNaeB2yWXg, topic: willTopic/iPone-C9A3D45F-B85E-4260-842A-F5C448D6F2F5, ipaddr: {115,236,50,9}, source: http, username: undefined
2023-03-02T02:42:46.999327+00:00 [warning] msg: last_will_testament_publish_denied, mfa: emqx_channel:publish_will_msg/2, line: 2137, peername: :38180, clientid: eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJjb21wYW55SWQiOjg4NiwiY2xpZW50VHlwZSI6NiwidXNlcl9uYW1lIjoiNTc4Iiwic2NvcGUiOlsiYWxsIl0sInVzZXJUeXBlIjoiZW50ZXJwcmlzZSIsInRva2VuVHlwZSI6MSwiZXhwIjoxNjc3ODEwOTI0LCJzYWFzVXNlcklkIjo1NzgsImp0aSI6IjJmZTYwOTFlLWU0ZTAtNDM5YS1hMzM3LWY3Y2ZjNGYyNzdmOCIsImNsaWVudF9pZCI6IjVlYzJmMmJiNjZmMTQyMWJiZDMyYzA3NTEzYTcyODI0In0.7hrRVM46PwWuHcrU3HzQfvzWiIW8F00VWUNaeB2yWXg, topic: willTopic/iPone-C9A3D45F-B85E-4260-842A-F5C448D6F2F5
2023-03-02T02:50:19.471974+00:00 [warning] msg: authorization_permission_denied, mfa: emqx_authz:authorize_non_superuser/5, line: 357, peername: 36.28.33.123:25856, clientid: a39b7337e56c439b99d2f95b948be249, topic: willTopic/\x{7476}\x{7476}\x{7684} iPhone-EFE5BEF3-1AEF-4CEA-897D-A62B312C6304, ipaddr: {36,28,33,123}, source: http, username: undefined
2023-03-02T02:50:19.472163+00:00 [warning] msg: last_will_testament_publish_denied, mfa: emqx_channel:publish_will_msg/2, line: 2137, peername: 36.28.33.123:25856, clientid: a39b7337e56c439b99d2f95b948be249, topic: willTopic/\x{7476}\x{7476}\x{7684} iPhone-EFE5BEF3-1AEF-4CEA-897D-A62B312C6304
2023-03-02T02:50:19.472357+00:00 [error] msg: unexpected_sock_close, mfa: emqx_channel:handle_info/2, line: 1266, peername: 36.28.33.123:25856, clientid: a39b7337e56c439b99d2f95b948be249, reason: closed
2023-03-02T02:53:04.872255+00:00 [warning] msg: authorization_permission_denied, mfa: emqx_authz:authorize_non_superuser/5, line: 357, peername: 36.28.33.123:25602, clientid: a39b7337e56c439b99d2f95b948be249, topic: willTopic/\x{7476}\x{7476}\x{7684} iPhone-EFE5BEF3-1AEF-4CEA-897D-A62B312C6304, ipaddr: {36,28,33,123}, source: http, username: undefined
2023-03-02T02:53:04.872456+00:00 [warning] msg: last_will_testament_publish_denied, mfa: emqx_channel:publish_will_msg/2, line: 2137, peername: 36.28.33.123:25602, clientid: a39b7337e56c439b99d2f95b948be249, topic: willTopic/\x{7476}\x{7476}\x{7684} iPhone-EFE5BEF3-1AEF-4CEA-897D-A62B312C6304
2023-03-02T03:04:04.321686+00:00 [warning] msg: authorization_permission_denied, mfa: emqx_authz:authorize_non_superuser/5, line: 357, peername: 36.28.33.123:25606, clientid: a39b7337e56c439b99d2f95b948be249, topic: willTopic/\x{7476}\x{7476}\x{7684} iPhone-EFE5BEF3-1AEF-4CEA-897D-A62B312C6304, ipaddr: {36,28,33,123}, source: http, username: undefined
2023-03-02T03:04:04.321874+00:00 [warning] msg: last_will_testament_publish_denied, mfa: emqx_channel:publish_will_msg/2, line: 2137, peername: 36.28.33.123:25606, clientid: a39b7337e56c439b99d2f95b948be249, topic: willTopic/\x{7476}\x{7476}\x{7684} iPhone-EFE5BEF3-1AEF-4CEA-897D-A62B312C6304
2023-03-02T03:05:23.522665+00:00 [warning] msg: authorization_permission_denied, mfa: emqx_authz:authorize_non_superuser/5, line: 357, peername: :49155, clientid: f9b8f39a7ca14275a926c6bf54de84cc, topic: willTopic/test-E2ED2E69-3DF2-4393-A3D6-FEDCAC7186D3, ipaddr: {183,134,198,212}, source: http, username: undefined
2023-03-02T03:05:23.522844+00:00 [warning] msg: last_will_testament_publish_denied, mfa: emqx_channel:publish_will_msg/2, line: 2137, peername: :49155, clientid: f9b8f39a7ca14275a926c6bf54de84cc, topic: willTopic/test-E2ED2E69-3DF2-4393-A3D6-FEDCAC7186D3
2023-03-02T03:07:52.872301+00:00 [warning] msg: authorization_permission_denied, mfa: emqx_authz:authorize_non_superuser/5, line: 357, peername: 36.28.33.123:25607, clientid: a39b7337e56c439b99d2f95b948be249, topic: willTopic/\x{7476}\x{7476}\x{7684} iPhone-EFE5BEF3-1AEF-4CEA-897D-A62B312C6304, ipaddr: {36,28,33,123}, source: http, username: undefined
2023-03-02T03:07:52.872520+00:00 [warning] msg: last_will_testament_publish_denied, mfa: emqx_channel:publish_will_msg/2, line: 2137, peername: 36.28.33.123:25607, clientid: a39b7337e56c439b99d2f95b948be249, topic: willTopic/\x{7476}\x{7476}\x{7684} iPhone-EFE5BEF3-1AEF-4CEA-897D-A62B312C6304
2023-03-02T03:09:35.787074+00:00 [warning] msg: authorization_permission_denied, mfa: emqx_authz:authorize_non_superuser/5, line: 357, peername: 36.28.33.123:25874, clientid: a39b7337e56c439b99d2f95b948be249, topic: willTopic/\x{7476}\x{7476}\x{7684} iPhone-EFE5BEF3-1AEF-4CEA-897D-A62B312C6304, ipaddr: {36,28,33,123}, source: http, username: undefined
2023-03-02T03:09:35.787273+00:00 [warning] msg: last_will_testament_publish_denied, mfa: emqx_channel:publish_will_msg/2, line: 2137, peername: 36.28.33.123:25874, clientid: a39b7337e56c439b99d2f95b948be249, topic: willTopic/\x{7476}\x{7476}\x{7684} iPhone-EFE5BEF3-1AEF-4CEA-897D-A62B312C6304
2023-03-02T03:09:35.787481+00:00 [error] msg: unexpected_sock_close, mfa: emqx_channel:handle_info/2, line: 1266, peername: 36.28.33.123:25874, clientid: a39b7337e56c439b99d2f95b948be249, reason: closed

350073301 · 2023 年3 月 2 日 03:28

e => 502}
2023-03-02T02:25:32.477426+00:00 [error] msg: http connector do request, received error response, mfa: emqx_connector_http:on_query/3, line: 342, peername: 127.0.0.1:49958, clientid: mqttjs_6e6e568f, connector: <<“emqx_authn_http:10”>>, request: {“/vcs/mqtt/auth/mqttjs_6e6e568f”,[{<<“accept”>>,<<“application/json”>>},{<<“cache-control”>>,<<“no-cache”>>},{<<“connection”>>,<<“keep-alive”>>},{<<“content-type”>>,<<“application/json”>>},{<<“keep-alive”>>,<<“timeout=30, max=1000”>>}],<<“{"username":"","password":""}”>>}, status_code: 502
2023-03-02T02:25:32.477732+00:00 [error] msg: unrecoverable_error, mfa: emqx_resource_buffer_worker:handle_query_result_pure/3, line: 831, peername: 127.0.0.1:49958, clientid: mqttjs_6e6e568f, id: <<“emqx_authn_http:10”>>, reason: #{body => <<“\r\n502 Bad Gateway\r\n\r\n

502 Bad Gateway

\r\n

nginx\r\n\r\n\r\n”>>,headers => [{<<“server”>>,<<“nginx”>>},{<<“date”>>,<<“Thu, 02 Mar 2023 02:25:32 GMT”>>},{<<“content-type”>>,<<“text/html; charset=UTF-8”>>},{<<“content-length”>>,<<“150”>>},{<<“connection”>>,<<“keep-alive”>>}],status_code => 502}