tongchenkeji
发表于：0次点击

大佬们，问个问题：rocketmqListener如何selectorexpression动态设置？[阿里云消息队列MQ]

大佬们，问个问题：rocketmqListener如何selectorexpression动态设置参数，如通过读取yml的值配置selectorexpression？谢谢 没有遇到这样的需求？

「点点赞赏，手留余香」

    还没有人赞赏，快来当第一个赞赏的人吧！
消息队列 MQ# 云消息队列 MQ1430
=====这是一个广告位，招租中，联系qq 78315851====
消息队列 MQ
Apache RocketMQ中我这边发了一条，但是这边dashboard显示两条，是不是dash？[阿里云消息队列MQ]
消息队列 MQ
Apache RocketMQ中为啥我的2m-2s-async集群，启动之后Master和Slav？[阿里云消息队列MQ]
5 条回复 A 作者 M 管理员

  1. 在Listener中使用变量：你可以在Listener的代码中定义一个变量，并将该变量作为SelectorExpression的值。然后，在代码中读取外部配置文件（如yml），将配置文件中的值赋给该变量。这样可以实现在代码中动态设置SelectorExpression。

    使用Spring Expression Language（SpEL）：如果你使用的是Spring框架来管理RocketMQ的Listener，你可以使用SpEL表达式来动态设置SelectorExpression。在SpEL表达式中，你可以使用Spring的PropertyPlaceholderConfigurer来读取外部配置文件中的值，并将其作为SelectorExpression的一部分。

    已喜欢 已反对 
  2. @RocketMQMessageListener(topic = "${topic}", consumerGroup = "${consumerGroup}", selectorExpression = "${selectorExpression}")public class MyRocketMQListener implements RocketMQListener {    // ...}
    rocketmq:  topic: my_topic  consumerGroup: my_consumer_group  selectorExpression: TagA
    @Configurationpublic class RocketMQConfig {    @Value("${rocketmq.topic}")    private String topic;    @Value("${rocketmq.consumerGroup}")    private String consumerGroup;    @Value("${rocketmq.selectorExpression}")    private String selectorExpression;    @Bean    public RocketMQListenerContainer rocketMQListenerContainer() {        DefaultRocketMQListenerContainer container = new DefaultRocketMQListenerContainer();        container.setTopic(topic);        container.setConsumerGroup(consumerGroup);        container.setSelectorExpression(selectorExpression);        container.setMessageListener(new MyRocketMQListener());        // ...        return container;    }}
    已喜欢 已反对

  3. 同学你好，这个配置还是比较简单的：

    第一步：在 YAML 配置文件中，添加一个属性来配置 selectorExpression

    rocketmq:  listener:    selector-expression: your-selector-expression

    第二步：在消息监听器类中，注入 RocketMQListenerConfig 对象，并将其作为参数传递给 @RocketMQMessageListener 注解

    @RocketMQMessageListener(    topic = "your-topic",    consumerGroup = "your-consumer-group",    selectorExpression = "#{rocketMQListenerConfig.selectorExpression}")public class YourMessageListener implements RocketMQListener {    // ...}

    已喜欢 已反对

  4. ，此回答整理自钉群“群1-Apache RocketMQ 中国开发者钉钉群”

    已喜欢 已反对

  5. 这个可以借助于使用 RocketMQ 的 MessageSelector 接口。通过这个接口可以实现自己的 MessageSelector 类，并在其中根据您的业务逻辑动态设置 selectorExpression。

    已喜欢 已反对