rockmq 过滤消息几种方式总结

2020-05-22  本文已影响0人  大强斌

提供的方式

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

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

实现原理

        tag过滤 

     FilterService原理

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

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

上一篇 下一篇

猜你喜欢

热点阅读