push consumer是RocketMQ中一种消费者模式，它可以主动向Broker拉取消息进行消费。在传统的消息中间件中，通常是由Broker推送消息给消费者，消费者被动接受消息。但是在某些场景下，消费者需要对消息的消费速度进行控制，不能被动接受消息推送的方式。因此，RocketMQ提供了push consumer模式，使消费者能够根据自身的消费速度主动拉取消息。

1. 创建PushConsumer实例

在使用push consumer模式前，首先需要创建一个PushConsumer实例。可以通过`DefaultMQPushConsumer`类来创建一个默认的PushConsumer实例，并设置消费者组名和命名服务器地址。

```java
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroup");
consumer.setNamesrvAddr("127.0.0.1:9876");
```

2. 注册消息监听器

接下来，需要注册一个消息监听器，用于处理接收到的消息。消息监听器需要实现`MessageListenerConcurrently`或`MessageListenerOrderly`接口，这两个接口分别用于并发模式和顺序模式的消息消费。

```java
consumer.registerMessageListener(new MessageListenerConcurrently() {
@Override
public ConsumeConcurrentlyStatus consumeMessage(List msgs, ConsumeConcurrentlyContext context) {
// 处理消息
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
});
```

3. 启动消费者

在完成消息监听器的注册后，通过调用`start()`方法来启动消费者，使其开始从Broker拉取消息。

```java
consumer.start();
System.out.println("Consumer Started.");
```

4. 消息拉取方式

在push consumer模式中，消费者可以使用不同的方式进行消息拉取，以控制自身的消费速度。

- 单条消息拉取：调用`pull(MessageExtBrokerInner)`方法来拉取一条消息进行消费。
- 批量消息拉取：调用`pull(List, MessageQueue)`方法来拉取一批消息进行消费。
- 定时消息拉取：使用定时任务来定期拉取消息。
- 长轮询拉取：调用`pull(MessageQueue, String, long, int)`方法，设置拉取消息的最大超时时间和消息数量，如果在超时时间内有新消息可消费，则立即返回。

消费者可以根据自身的需求选择合适的拉取方式，来控制消息消费的速度和效率。

总结起来，RocketMQ中实现push consumer消息拉取，首先需要创建一个PushConsumer实例，并设置消费者组名和命名服务器地址。然后，注册消息监听器，在监听器中处理接收到的消息。最后，启动消费者并选择合适的消息拉取方式，控制消费速度和效率。通过这样的方式，消费者可以主动拉取消息进行消费，实现灵活控制和处理。