消息过滤是指消费端可以根据某些条件对一个 topic 中的消息进行过滤，即只消费一个 主题下满足过滤条件的消息。 RocketMQ 目前主要的过滤机制是基于 tag 的过滤与基于消息属性的过滤，基于消息 属性的过滤支持 SQL92 表达式，对消息进行过滤。 六、小结 本文的主要目的是介绍 RocketMQ 常见的术语，例如 nameserver、broker、主题、 消费组、消费者、队列负载算法、队列重平衡机制、并发消费、顺序消费、消费进度存储、 该目录下会有众多的日志文件，如果一开始对这些文件的含义不了解也没关系，大家可 以通过 ls -l 命令，逐一查看文件大小不为０的文件，从而寻找错误日志，便于快速解决 问题。 RocketMQ 提供了众多的运维命令来查看 RocketMQ 集群的运行状态，在这里我先 简单使用 clusterList 命令来查看集群的状态，用于验证一下集群的状态。 sh ./mqadmin clusterList 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.3 实战：RocketMQ 学习环境搭建指南篇 < 32 其运行结果如下图所示： 2. 安装 RocketMQ-Console 使用运维命令不太直观，学习成本较大，为此 RocketMQ 官方提供了一个运维管理界 面 RokcetMQ-Console，用于对 RocketMQ 集群提供常用的运维功能，故本节主要讲 解如何在 Linux

jdk版本：1.8 maven版本：3.6.3 git clone https://github.com/apache/rocketmq.git cd rocketmq # 执行mvn构建命令, 这里的命令含义是：清理之前编译、打包的文件，激活profile 名为 release-al # 然后打包，不编译单元测试，也不运行单元测试 mvn clean -P release-all package 2m-noslave 双主模式 ● lib 存放的依赖jar包 测试namesrv的启动 启动命令： nohup /Users/gitsilence/JavaTools/rocketmq/rocketmq-4.9.2-SNAPSHOT/bin/mqnamesrv & 使用 jps 查看是否启动成功 关闭命令 /Users/gitsilence/JavaTools/rocketmq/rocketmq-4 release-rocketmq-console-1.0.0 4、cd rocketmq-console 5、mvn clean package -Dmaven.test.skip=true 6、构建成功后，执行启动命令 nohup java -jar target/rocketmq-console-ng-1.0.0.jar --rocketmq.config.namesrvAddr='192.1 8.166.20:9876;192

的 SSH Tunnel 并通过 SSH Tunnel 来访问 Nameserver 的 Web Console。 1. 使用 ssh 命令建立和 Bastion Host 的 ssh 连接，下图中红⾊的部分参数需要换成 用户环境对应的参数 命令：ssh -qTfnN -D PORTNUMBER -i KEYPAIR USERNAME@HOSTNAME 样例：ssh -qTfnN -D Page 17 of 18 如何登录 Apache RocketMQ 的 Nameserver 和 Broker Node？ 1. 使用 ssh-add 命令添加 pem keypair 举例: ssh-add -k /Users/username/tmp/rocketmq.pem 2. 登录到 Bastion Host 举例：ssh -A com/amazon-linux-2/ [ec2-user@ip-10-0-6-235 ~]$ 4. 登录到 Nameserver 或者 Broker Node 之后，您就可以使用 Apache RocketMQ 自 带的命令⾏⼯具进⾏操作。

并通过 SSH Tunnel 来访问 Nameserver 的 Web Console。 1. 使用 ssh 命令建立和 Bastion Host 的 ssh 连接，下图中红色的部分参数需要 换成用户环境对应的参数 Page 17 of 21 命令：ssh -qTfnN -D PORTNUMBER -i KEYPAIR USERNAME@HOSTNAME 样例：ssh Page 20 of 21 如何登录 Apache RocketMQ 的 Nameserver 和 Broker Node？ 1. 使用 ssh-add 命令添加 pem keypair 举例: ssh-add -k /Users/username/tmp/rocketmq.pem 2. 登录到 Bastion Host 举例：ssh -A com/amazon-linux-2/ [ec2-user@ip-10-0-6-235 ~]$ 4. 登录到 Nameserver 或者 Broker Node 之后，您就可以使用 Apache RocketMQ 自带的命令行工具进行操作。

40 12.3 Broker 重启对客户端的影响 Broker 重启可能会导致正在収往返台机器的的消息収送失败，RocketMQ 提供了一种优雅关闭 Broker 的方法，通过 执行以下命令会清除 Broker 的写权限，过 40s 后，所有客户端都会更新 Broker 路由信息，此时再关闭 Broker 就丌 会収生収送消息失败的情冴，因为所有消息都収往了其他 Broker。 sh

/ Phone : +358 469 335 071 Github: ​https://github.com/hiejulia Related skills : Java, Golang, SQL, NoSQL, Rest, gPRC, Microservices, Test, DevOps, Distributed system, Cloud(AWS, Azure) , Golang, Maven Batch example : send messages in batches, split into lists - Filter example: RocketMQ offer some SQL expression to filter out message - Logappender example: - Open Message example: OMS Producer &

IaaS 基础设施支持，降低成本 轻量级SDK： • 全面支持云原生通信标准 gRPC 协议 • 无状态 Pop 消费模式，多语言友好，易集成 从业务走向数据： • 事件流场景支撑 • 面向 SQL 的轻量级实时计算引擎 可分可合的存储计算分离： • Broker 升级为真正的无状态服务节点，无 binding • Broker和Store节点分离部署、独立扩缩 • 可分可合，适应多种业务场景，降低运维负担

w th sync mode to avoid message loss Supported Supported, property filter expressi ns based on SQL92 Supported High performance and low latency file storage upported timestamp and offset two indicates

Message File Service Aliware MQ Apache RocketMQ Replication DB Connector Third party partner SQL/RPC Filter DC Router Multi- tenancy Exactly Only once 24/7 Support LOG Connector IoT Connector

Message File Service Aliware MQ Apache RocketMQ Replication DB Connector Third party partner SQL/RPC Filter DC Router Multi- tenancy Exactly Only once 24/7 Support LOG Connector IoT Connector