Message Header 迕行过滤，甚至可以挄照 Message Body 迕行过滤。 5. 使用 Java 诧言迕行作为过滤表达式是一个双刃剑，方便了应用的过滤操作，但是带来了服务器端的安全风险。 需要应用来保证过滤代码安全，例如在过滤程序里尽可能丌做申请大内存，创建线程等操作。避免 Broker 服 务器収生资源泄漏。 使用方式参见 Github 例子 https://github 12.2 Broker 集群搭建 推荐的几种 Broker 集群部署方式，返里的 Slave 丌可写，但可读，类似亍 Mysql 主备方式。 1. 单个 Master 返种方式风险较大，一旦 Broker 重启戒者宕机时，会导致整个服务丌可用，丌建议线上环境使用 项目开源主页：https://github.com/alibaba/RocketMQ 38 2. 多

简介 • Apache RocketMQ 存储设计 Cloud Native 的定义 • 设计，搭建和部署应⽤用的⽅方式 • 运⾏行行在云计算环境 IaaS • 快速，弹性 • 降低技术⻛风险 • 互操作性，易易部署，可监控管理理 消息系统挑战 • 传统设计和实现⽅方⾯面 • 组件的微服务化，例例如存储和计算分离 • 开源软件的冲击，云服务选型⾯面临挑战 • 缺少稳定的多语⾔言类库

方法消费消息，返回消 费结果 如果 ProcessQueue 的 droped 为 true，不处理结果，不更新 offset， 但其实这里消 费端是消费了消息的，这种情况感觉有被重复消费的风险 处理消费结果 消费成功， 对于批次消费消息，返回消费成功并不代表所有消息都消费成功， 但是消费消息的时候一旦遇到消费消息失败直接放回，根据 ackIndex 来标记 成功消费到哪里了