使用rocketMQ作为消息转发 rocketmq支持分片键hash路由到同一个节点 emqx中怎么做

huo · 2025 年3 月 31 日 11:59

zhongwencool · 2025 年3 月 31 日 12:27

不了解rocketmq唉，可以去rocketmq社区问问

huo · 2025 年4 月 1 日 09:25

平台不是支持rocketmq嘛这里默认是roundrobin（轮询）

zhongwencool · 2025 年4 月 1 日 09:39

抱歉我以为这句话的意思是要把rocketmq的消息发送到emqx中的一个节点
现在是轮询，您具体想要的是什么效果

huo · 2025 年4 月 1 日 09:52

比如我现在有两个消费者同一个消费组 rocketmq为集群消费模式我现在想要通过deviceId做hash分片把同一台设备发送的消息都发送到同一个消费者

Okay · 2025 年4 月 1 日 10:14

SQL取出deviceid，然后这里填上${deviceid}应该就可以

huo · 2025 年4 月 1 日 10:33

您看我发的截图是按照device取的但是没有做到hash分片还是轮询的机制

zhongwencool · 2025 年4 月 2 日 02:40

你的消息模板( body )不对，只写了一个固定的 1，根本就没有 deviceId 这个字段。如果在消息里面没有找到对应的字段，就会随机发。

github.com

emqx/emqx/blob/master/apps/emqx_bridge_rocketmq/src/emqx_bridge_rocketmq_connector.erl#L345-L368


      
          %% returns a procedure to generate the produce context
          parse_dispatch_strategy(roundrobin) ->
              fun(_) ->
                  #{}
              end;
          parse_dispatch_strategy(Template) ->
              Tokens = emqx_placeholder:preproc_tmpl(Template),
              fun(Msg) ->
                  #{
                      key =>
                          case emqx_placeholder:proc_tmpl(Tokens, Msg) of
                              <<"undefined">> ->
                                  %% Since the key may be absent on some kinds of events (ex:
                                  %% `topic' is absent in `client.disconnected'), and this key is
                                  %% used for routing, we generate a random key when it's absent to
                                  %% better distribute the load, effectively making it `random'
                                  %% dispatch if the key is absent and we are using `key_dispatch'.
                                  %% Otherwise, it'll be deterministic.
                                  emqx_utils:rand_id(8);
                              Key ->

This file has been truncated. show original

huo · 2025 年4 月 2 日 02:57

没太懂您说的只写了一个固定1 这是我的消息模板我消费端接收的也是这个模板

zhongwencool · 2025 年4 月 2 日 07:48

那就是对的，我看错了，我把那个消息模板那的行号 1 看成了写到 body 里面的 1.如果留空，那就是对的。
如果你用的是最新版本 v5.8.6

可以用这打开这个 trace 看看。
找到日志里面的QUERY_RENDER action_template_rendered 看里面的 topic_key是不是对应的 deviceId。

huo · 2025 年4 月 2 日 09:37

貌似搜不到诶

zhongwencool · 2025 年4 月 2 日 09:54

我不知道你这个日志界面是什么来的，如果是使用的 cloud，可以直接提工单，应该有人专门处理的.

我说的方法是自己部署的企业版本，里面有一个日志 trace 功能。和您的界面不一样。

PS：如果是 cloud 版本，最好的方式是直接提工单。