RocketMQ发送异步消息报错No route info of this topic

怼烎@ 2023-06-11 05:20 15阅读 0赞

public class AsyncProducer { 
        public static final int MSG_COUNT = 10;
        public static final String NAME_SERVER_ADDR = "192.168.182.200:9876";
    
        public static void main(String[] args) throws Exception { 
            //实例化消息生产者Producer
            DefaultMQProducer mqProducer = new DefaultMQProducer("async_msg_group");
            //设置NameServer的地址
            mqProducer.setNamesrvAddr(NAME_SERVER_ADDR);
            //启动Producer实力
            mqProducer.start();
            for (int i = 0; i < 5; i++) { 
                String topic = "async_msg_topic";
                String tag = "async_msg_tag";
                String key = "order_id"+i;
                byte[] body = ("Hello Async_Msg" + i).getBytes();
                Message message = new Message(topic, tag, key, body);
                // 2.2 异步发送消息
                mqProducer.send(message, new SendCallback() { 
                    //rabbitmq急速入门的实战: 可靠性消息投递
                    @Override
                    public void onSuccess(SendResult sendResult) { 
                        System.err.println("msgId: " + sendResult.getMsgId() + ", status: " + sendResult.getSendStatus());
                    }
                    @Override
                    public void onException(Throwable e) { 
                        e.printStackTrace();
                        System.err.println("------发送失败");
                    }
                });
            }
            mqProducer.shutdown();
        }
    }

在mqProducer.shutdown();前线程睡眠适当时间： TimeUnit.SECONDS.sleep(1);不然在异步发送消息之前，Producer就被关闭了，发送同步消息不会出现这种问题