rokectMQ多tag处理

2026-7-2 17:02| 发布者: zhaojun917| 查看: 8| 评论: 0

摘要: publicstaticvoidmain(Stringargs){//1.创建【Tag-处理方法】的映射（支持任意多个）java.util.MapString,RocketUtil.MessageHandlerhandlerMap=newjava.util.HashMap();//==========不同Tag绑定不同业务方法======= ...

public static void main(String[] args) {
    // 1. 创建【Tag -> 处理方法】的映射（支持任意多个）
    java.util.Map<String, RocketUtil.MessageHandler> handlerMap = new java.util.HashMap<>();

    // ========== 不同Tag 绑定不同业务方法 ==========
    // Tag1：车辆信息导入
    handlerMap.put("CarInfo_import", data -> {
        DealMsgService dealMsgService = (DealMsgService) SpringUtil.getBean("dealMsgService");
        return dealMsgService.dealMsg(data);
    });

    // Tag2：订单同步
    handlerMap.put("orderSyn", data -> {
        OrderRecycleService service = (OrderRecycleService) SpringUtil.getBean("OrderRecycleService");
        return service.deal(data) == 0;
    });

    // Tag3：订单状态同步
    handlerMap.put("orderStatusSyn", data -> {
        OrderRecycleService service = (OrderRecycleService) SpringUtil.getBean("OrderRecycleService");
        if (service.getMailNo(data) < 0) return false;
        return service.dealStatus(data) == 0;
    });

    // 2. 启动多Tag消费者
    RocketUtil.startConsumer("mq.rocket.", handlerMap);
}

# 多Tag写法：用 || 分隔
mq.rocket.tagName=CarInfo_import||orderSyn||orderStatusSyn

收藏分享邀请

上一篇：消费者Consumer启动后为啥程序一直挂着不退出？

账号		自动登录	找回密码
密码			立即注册

rokectMQ多tag处理

相关分类