- ACLDemo : broker开启ACL后, 客户端使用ACL生产消费消息的demo
- ConcurrentMessageDemo : 并发消息demo,也就是普通消息生产消费demo
- DelayMessageDemo : 延迟消息生产消费demo
- FliterMessageDemo : 消息过滤demo(包含tag过滤, sql92过滤)
- RequestReplyMessageDemo request-reply demo(RPC同步请求demo)
- TraceMessageDemo 消息轨迹demo
- TransactionMessageDemo 事物消息使用demo
- 命令demo
mvn clean package
mvn exec:java -Dexec.args="xxx.xxx.xxx.xxx:9876" -Dexec.mainClass="org.apache.rocketmqdemos.XXXXX" -Dexec.classpathScope=runtime