前言
本人使用的是windows10安装docker。安装按照下面这个连接安装即可
https://www.jb51.net/article/229157.htm
安装效果
出现的坑connect to <172.17.0.3:10909> failed
在代码生产消息时，出现了的这个问题connect to <172.17.0.3:10909> failed
解决方式:
broker.conf中
C:\Users\2019051634>docker exec -it rmqbroker /bin/bash [root@9a093d1630c0 rocketmq-4.5.1]# cd /etc/rocketmq/ [root@9a093d1630c0 rocketmq]# vi broker.conf
这个ip配置的是容器的地址
其实这是不对的!!!
应该用本机宿主机的的IP地址。
查看本机ip地址
cmd中执行ipconfig命令
①配上这个才可以！！
②重启rmqbroker
docker restart rmqbroker
③重启rmqbroker
docker restart rmqconsole
效果如下:
生产消息:
public class OnewayProducer { public static void main(String[] args) throws Exception{ //生产者实例化 DefaultMQProducer producer = new DefaultMQProducer("oneway"); //指定rocket服务器地址: producer.setNamesrvAddr("127.0.0.1:9876"); // producer.setNamesrvAddr("192.168.0.128:9876"); //启动实例 producer.start(); for (int i = 0; i < 10; i++) { //创建一个消息实例，指定topic、tag和消息体 Message msg = new Message("TopicTest" /* Topic */, "TagA" /* Tag */, ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */ ); //发送消息 producer.sendOneway(msg); System.out.printf("%s%n", new String(msg.getBody())); } //生产者实例不再使用时关闭. producer.shutdown(); } }
运行结果:
控制台显示
大功告成！！
