RocketMQ（3）生产者demo以及Norouteinfoofthistopic的解决！！

目录

1、添加依赖

2、编写生产者

3、编写Controller

常见错误

常见错误一

常见错误二

常见错误三

1、添加依赖

org.apache.rocketmqrocketmq-client4.3.0

2、编写生产者

&＃64;Component
public class PayProducer {private String producerGroup &＃61; "pay_group";private String nameServerAddr &＃61; "120.76.62.13:9876";private DefaultMQProducer producer;public PayProducer(){producer &＃61; new DefaultMQProducer(producerGroup);//指定NameServer地址&＃xff0c;多个地址以 ; 隔开//如 producer.setNamesrvAddr("192.168.100.141:9876;192.168.100.142:9876;192.168.100.149:9876");producer.setNamesrvAddr(nameServerAddr);start();}public DefaultMQProducer getProducer(){return this.producer;}/*** 对象在使用之前必须要调用一次&＃xff0c;只能初始化一次*/public void start(){try {this.producer.start();} catch (MQClientException e) {e.printStackTrace();}}/*** 一般在应用上下文&＃xff0c;使用上下文监听器&＃xff0c;进行关闭*/public void shutdown(){this.producer.shutdown();}}

3、编写Controller

&＃64;RestController
public class PayController {&＃64;Autowiredprivate PayProducer payProducer;private static final String topic &＃61; "xdclass_pay_test_topic2";&＃64;RequestMapping("/api/v1/pay_cb")public Object callback(String text) throws InterruptedException, RemotingException, MQClientException, MQBrokerException {Message message &＃61; new Message(topic,"taga", ("hello xdclass rocketmq &＃61; "&＃43;text).getBytes() );SendResult sendResult &＃61; payProducer.getProducer().send(message);System.out.println(sendResult);return new HashMap<>();}}


Message对象
      topic: 主题名称
      tag: 标签&＃xff0c;用于过滤
      key: 消息唯一标示&＃xff0c;可以是业务字段组合
      body: 消息体,字节数组
注意 发送消息到Broker&＃xff0c;需要判断是否有此topic 

        启动broker的时候&＃xff0c;本地环境建议开启自动创建topic&＃xff0c;生产环境建议关闭自动化创建topic
        建议先手工创建Topic&＃xff0c;如果靠程序自动创建&＃xff0c;然后再投递消息&＃xff0c;会出现延迟情况

概念模型: 一个topic下面对应多个queue,可以在创建Topic时指定&＃xff0c;如订单类topic
通过可视化管理后台查看消息

常见错误

常见错误一


org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException:
sendDefaultImpl call timeout

原因&＃xff1a;阿里云存在多网卡&＃xff0c;rocketmq都会根据当前网卡选择一个IP使用&＃xff0c;当你的机器有多块网卡时&＃xff0c;很有可能会有问题。比如&＃xff0c;我遇到的问题是我机器上有两个IP&＃xff0c;一个公网IP&＃xff0c;一个私网IP, 因此需要配置broker.conf 指定当前的公网ip, 然后重新启动broker
新增配置&＃xff1a;conf/broker.conf (属性名称brokerIP1&＃61;broker所在的公网ip地址 )
新增这个配置&＃xff1a;brokerIP1&＃61;120.76.62.13 启动命令&＃xff1a;nohup sh bin/mqbroker -n localhost:9876 -c ./conf/broker.conf &

不加配置启动的话&＃xff0c;启动是内网ip的外网连不上的

常见错误二

MQClientException: No route info of this topic, TopicTest1
原因&＃xff1a;Broker 禁止自动创建 Topic&＃xff0c;且用户没有通过手工方式创建 此Topic, 或者broker和Nameserver网络不通
解决&＃xff1a;
通过 sh bin/mqbroker -m 查看配置
autoCreateTopicEnable&＃61;true 则自动创建topicCentos7关闭防火墙 systemctl stop firewalld

常见错误三

控制台查看不了数据&＃xff0c;提示连接 10909错误原因&＃xff1a;Rocket默认开启了VIP通道&＃xff0c;VIP通道端口为10911-2&＃61;10909解决&＃xff1a;阿里云安全组需要增加一个端口 10909

能查的都查了几乎也都试了试&＃xff0c;高版本的RocketMq上面的问题基本都解决了&＃xff0c;上面提及的3种方法本人都试了&＃xff0c;无非是broker是否能够自动创建Topic&＃xff08;高版本自动开启&＃xff09;、配置环境变量&＃xff08;高版本不必配置&＃xff09;、product是否能够连接到name server、broker是否能够连上 name server、以及防火墙的问题。。全试过了。。。。。。。。结果还是不行.........NM内心要崩溃了&＃xff0c;

最后结果是版本问题&＃xff0c;&＃xff0c;&＃xff0c;&＃xff0c;我服务器用的是4.4.0   client是4.3.0    将maven依赖换为4.4.0重新启动问题解决&＃xff01;&＃xff01;&＃xff01;

折磨我一天的问题终于解决了&＃xff0c;希望能够帮助你

broker的日志查看方法
cat /root/logs/rocketmqlogs/namesrv.log

其他错误:
https://blog.csdn.net/qq_14853889/article/details/81053145
https://blog.csdn.net/wangmx1993328/article/details/81588217#%E5%BC%82%E5%B8%B8%E8%AF%B4%E6%98%8E
https://www.jianshu.com/p/bfd6d849f156
https://blog.csdn.net/wangmx1993328/article/details/81588217

RocketMQ消费者demo&＃xff1a;https://mp.csdn.net/postedit/97272900