Mac M1：通过 docker 安装 RocketMQ，RocketMQ-Dashboard-2。

最后发送几条消息进行测试一下

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.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.exception.RemotingException;

import java.nio.charset.StandardCharsets;


/**
 * @author benjamin_5
 * @Description
 * @date 2024/2/25
 */
public class ProducerDemo {

    public static void main(String[] args) throws MQClientException, MQBrokerException, RemotingException, InterruptedException {
        DefaultMQProducer producer = new DefaultMQProducer("group_test");

        producer.setNamesrvAddr("localhost:9876");
        producer.setVipChannelEnabled(false);
        
        // 启动实例
        producer.start();

        for (int i = 0; i < 10; i++) {
            Message msg = new Message("topic_test", "tag_test", ("hello "+ i).getBytes(StandardCharsets.UTF_8));
            SendResult send = producer.send(msg, 10000);
            System.out.println(send);
        }
        producer.shutdown();

    }
}

如果出现连接超时的问题invokSync call timeout，先检查下broker.conf中配置的ip是否是本机ip

确认无误后mac执行如下指令，重新设置一下本机本地hostname

scutil --set HostName $(scutil --get LocalHostName)