提供的方式
方式1 tag过滤消息,优点过滤简单 高效 不适合复杂过滤
方式2 filterService 过滤,定制化过滤,支持复杂过滤
实现原理
tag过滤
FilterService原理
缺点:这里把本地的类上传到rocketMq远端进行执行,这里是危险的操作,如果本地代码大量创建对象和线程就会很消耗broker机器的资源,必须严格确认自己本地的代码才确认上传到远端broker执行。也可以采取从固定远程拉取 方案。
流程比较简单,没有什么复杂理解的。就不源码了
网友评论