美文网首页
rockmq 过滤消息几种方式总结

rockmq 过滤消息几种方式总结

作者: 大强斌 | 来源:发表于2020-05-22 14:19 被阅读0次

提供的方式

         方式1 tag过滤消息,优点过滤简单 高效 不适合复杂过滤

          方式2 filterService 过滤,定制化过滤,支持复杂过滤

实现原理

        tag过滤 

     FilterService原理

缺点:这里把本地的类上传到rocketMq远端进行执行,这里是危险的操作,如果本地代码大量创建对象和线程就会很消耗broker机器的资源,必须严格确认自己本地的代码才确认上传到远端broker执行。也可以采取从固定远程拉取 方案。

流程比较简单,没有什么复杂理解的。就不源码了

相关文章

  • rockmq 过滤消息几种方式总结

    提供的方式 方式1 tag过滤消息,优点过滤简单 高效 不适合复杂过滤 方式2 filterSe...

  • RockMq事务消息原理

    场景: 通过mq 进行分布式事务的一致性控制,参考转账事务原理 目的: 保持本地事务和mq发送的原子性 过程: ...

  • 过滤消息

    过滤消息消息的过滤分为两种Tag过滤方式:Consumer端在订阅消息时除了指定Topic还可以指定TAG,如果一...

  • 消息通知—站内信消息推送

    上一篇《消息通知推送》中总结了消息通知推送的几种方式,这次就来聊聊产品中站内信消息推送渠道的功能建设。 同样,站内...

  • RocketMQ 与 Spring Cloud Stream整合

    RocketMQ 提供了两种方式给 Consumer 进行消息的过滤: 基于 Tag 过滤标签(Tag):为消息设...

  • RocketMQ 7.消息过滤

    RocketMQ分布式消息队列的消息过滤方式有别于其它MQ中间件,是在Consumer端订阅消息时再做消息过滤的。...

  • 详述RocketMQ消息过滤方式

    [TOC] 1 背景 业务处理过程,发现了以下问题,代码一是原代码能正常执行,代码二是经过迭代一次非正常执行代码 ...

  • 几种播放视频文件的方式

    几种播放视频文件的方式(一) —— 总结播放视频的几种方式(一)几种播放视频文件的方式(二) —— 基于Media...

  • NSPredicate谓词-数组过滤

    NSPredicate谓词-数组过滤 NSPredicate中主要的几种运算方式 1、比较运算符: > 、< 、=...

  • SpringBoot整合Redis,订阅、发布、过期事件

    Redis可以实现消息中间件的功能,在实现这个功能时,又有几种实现方式呢,看了网友们的分享,做了一个总结;消息的订...

网友评论

      本文标题:rockmq 过滤消息几种方式总结

      本文链接:https://www.haomeiwen.com/subject/cfcqahtx.html