MQClientException: No route info of this topic, PushTopic？

Question

在Linux上部署了RocketMQ后，用Java测试时一直报这个错误

百度了很多文章基本都是在说用这个命令启动broker(我也是这样启动的)。

nohup sh mqbroker -n xxx.xxx.xxx.xxx:9876 autoCreateTopicEnable=true

要么就是说环境变量，我环境变量也是按照百度说的那样配置的。可还是报这个错误。
我快疯了。。。哎接下来献上代码和配置求大佬们看一下。

还有服务器的防火墙我已经全部关闭了。然后我尝试使用控制台去创建Topic，But..看图。

已经生无可恋...
还有我的Jar包(fastjson的各种版本我都试过了。)

Answer 1

嘻嘻嘻一样的

Answer 2

send方法用

public SendResult send(Message msg, MessageQueueSelector selector, Object arg) throws MQClientException, RemotingException, MQBrokerException, InterruptedException {
        return this.defaultMQProducerImpl.send(msg, selector, arg);
    }
    
producer.send(message, new MessageQueueSelector() {
                    @Override
                    public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) {
                        Integer id = (Integer) arg;
                        int index = id % mqs.size();
                        return mqs.get(index);
                    }
                }, orderId);