拉模式2，报错，请求修改调试成功后再粘贴出正确代码

Question

package com.example.rocketmq.come;

import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.exception.RemotingException;

import java.nio.charset.StandardCharsets;

//拉模式2
public class AsyncProducer2 {
    public static void main(String[] args) throws MQClientException, RemotingException, InterruptedException, MQBrokerException {
        //创建生产组
        DefaultMQProducer producer = new DefaultMQProducer("SyncProducwe");
        //连接
        producer.setNamesrvAddr("192.168.88.130:9876");
        //开始
        producer.start();
        for (int i=0;i<100;i++){
            final int index=i;
            Message message = new Message("Simple","TagA",(i+"HH").getBytes(StandardCharsets.UTF_8));
            producer.send(message, new SendCallback() {
                @Override//发送成功调用该方法
                public void onSuccess(SendResult sendResult) {
                    System.out.println(index+"消息发送成功_"+sendResult);
                }

                @Override//发送失败调用该方法
                public void onException(Throwable throwable) {
                    System.out.println(index+"消息发送失败_"+throwable.getStackTrace());
                }
            });
        }
        producer.shutdown();
    }
}
package com.example.rocketmq.come;

import org.apache.rocketmq.client.consumer.DefaultLitePullConsumer;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.common.message.MessageExt;

import java.util.List;
//拉模式2
public class LitePullConsumer {
    public static void main(String[] args) throws MQClientException {
        DefaultLitePullConsumer consumer = new DefaultLitePullConsumer("LitePullConsumer");
        consumer.setNamesrvAddr("192.168.88.130:9876");
        consumer.subscribe("Simple","*");
        consumer.start();
        while (true){
            List<MessageExt> messageExtList = consumer.poll();
            System.out.println("信息拉取成功");
            messageExtList.forEach(n->{
                System.out.println("信息消费成功_"+n);
            });
        }
    }
}

Answer 1

【RocketMQ的安装和配置 - CSDN App】http://t.csdnimg.cn/Q8Wnl
参考看下安装配置是否正常