This lab describes how to use the Java SDK to subscribe to and consume three types of Message Queue for Apache RocketMQ (RocketMQ) messages. RocketMQ provides asynchronous decoupling and load shifting for distributed application systems and supports features for Internet applications, including massive message accumulation, high throughput, and reliable retrying. RocketMQ allows applications developed with different programming languages to quickly access the services of RocketMQ over TCP