mqtt桥接客户端id创建

473131830 · 2023 年10 月 19 日 02:45

在使用mqtt桥接过程中，本地新建的客户端id能不能使用远程的客户端id

这个规则能修改吗？

heeejianbo · 2023 年10 月 19 日 09:19

目前不支持自定义的修改。就只能通过改源码的方式了

473131830 · 2023 年10 月 19 日 09:31

在哪里修改

heeejianbo · 2023 年10 月 20 日 02:25

出方向的桥接：

github.com

emqx/emqx/blob/eda82caf65147f81b3eb5ba4de8aa423bd7b0df1/apps/emqx_bridge_mqtt/src/emqx_bridge_mqtt_egress.erl#L83


      
                          msg => "egress_client_start_failed",
                          config => emqx_utils:redact(ClientOpts),
                          reason => Reason
                      }),
                      Error
              end.
          
          mk_client_opts(WorkerId, ClientOpts = #{clientid := ClientId}) ->
              ClientOpts#{clientid := mk_clientid(WorkerId, ClientId)}.
          
          mk_clientid(WorkerId, ClientId) ->
              iolist_to_binary([ClientId, $: | integer_to_list(WorkerId)]).
          
          connect(Pid, Name) ->
              case emqtt:connect(Pid) of
                  {ok, _Props} ->
                      {ok, Pid};
                  {error, Reason} = Error ->
                      ?SLOG(warning, #{
                          msg => "egress_client_connect_failed",
                          reason => Reason,

入方向的：

github.com

emqx/emqx/blob/eda82caf65147f81b3eb5ba4de8aa423bd7b0df1/apps/emqx_bridge_mqtt/src/emqx_bridge_mqtt_ingress.erl#L83


      
                      }),
                      Error
              end.
          
          mk_client_opts(Name, WorkerId, Ingress, ClientOpts = #{clientid := ClientId}) ->
              ClientOpts#{
                  clientid := mk_clientid(WorkerId, ClientId),
                  msg_handler => mk_client_event_handler(Name, Ingress)
              }.
          
          mk_clientid(WorkerId, ClientId) ->
              iolist_to_binary([ClientId, $: | integer_to_list(WorkerId)]).
          
          mk_client_event_handler(Name, Ingress = #{}) ->
              IngressVars = maps:with([server], Ingress),
              OnMessage = maps:get(on_message_received, Ingress, undefined),
              LocalPublish =
                  case Ingress of
                      #{local := Local = #{topic := _}} ->
                          Local;
                      #{} ->