docker安装RocketMQ的实现步骤

docker search rocketmq

curl https://registry.hub.docker.com/v1/repositories/foxiswho/rocketmq/tags | tr -d '[/[/]" ]' | tr '}' '/n' | awk -F: -v image='foxiswho/rocketmq' '{if(NR!=NF && $3 != ""){printf("%s:%s/n",image,$3)}}'

curl https://registry.hub.docker.com/v1/repositories/foxiswho/rocketmq/tags/| tr -d '[/[/]" ]' | tr '}' '/n'/| awk -F: -v image='foxiswho/rocketmq' '{if(NR!=NF && $3 != ""){printf("%s:%s/n",image,$3)}}'

docker run -d -p 9876:9876 --name rmqserver  foxiswho/rocketmq:server-4.5.1

docker run -d -p 10911:10911 -p 10909:10909/ --name rmqbroker --link rmqserver:namesrv/ -e "NAMESRV_ADDR=namesrv:9876" -e "JAVA_OPTS=-Duser.home=/opt"/ -e "JAVA_OPT_EXT=-server -Xms128m -Xmx128m"/ foxiswho/rocketmq:broker-4.5.1

docker exec -it rmqbroker /bin/bashcd /etc/rocketmq/vi broker.conf

docker run -d --name rmqconsole -p 8180:8080 --link rmqserver:namesrv/ -e "JAVA_OPTS=-Drocketmq.namesrv.addr=namesrv:9876/ -Dcom.rocketmq.sendMessageWithVIPChannel=false"/ -t styletang/rocketmq-console-ng

docker ps|grep rocketmq

#测试消息发送命令sh tools.sh org.apache.rocketmq.example.quickstart.Producer

#测试消息接收命令sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

<dependency>	    <groupId>org.apache.rocketmq</groupId>	    <artifactId>rocketmq-client</artifactId>	    <version>4.9.2</version>	</dependency>

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.common.RemotingHelper;  public class SyncProducer {	public static void main(String[] args) throws Exception {    	// 实例化消息生产者Producer        DefaultMQProducer producer = new DefaultMQProducer("zhuzeqing-1");    	// 设置NameServer的地址    	producer.setNamesrvAddr("192.168.23.131:9876");    	// 启动Producer实例        producer.start();    	for (int i = 0; i < 1; i++) {    	    // 创建消息，并指定Topic，Tag和消息体    	    Message msg = new Message("zhuzeqing-1-Topic" /* Topic */,        	"TagA" /* Tag */,        	("hello，rocketmq --" + i).getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */        	);        	// 发送消息到一个Broker            SendResult sendResult = producer.send(msg);            // 通过sendResult返回消息是否成功送达            System.out.printf("%s%n", sendResult);    	}    	// 如果不再发送消息，关闭Producer实例。    	producer.shutdown();    }}

import java.util.List; import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;import org.apache.rocketmq.client.exception.MQClientException;import org.apache.rocketmq.common.message.MessageExt; public class Consumer { 	public static void main(String[] args) throws InterruptedException, MQClientException {     	// 实例化消费者        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("zhuzeqing-1");     	// 设置NameServer的地址        consumer.setNamesrvAddr("192.168.23.131:9876");     	// 订阅一个或者多个Topic，以及Tag来过滤需要消费的消息        consumer.subscribe("zhuzeqing-1-Topic", "*");    	// 注册回调实现类来处理从broker拉取回来的消息        consumer.registerMessageListener(new MessageListenerConcurrently() {            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {                System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);                // 标记该消息已经被成功消费                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;            }        });        // 启动消费者实例        consumer.start();        System.out.printf("Consumer Started.%n");	}}

docker inspect rmqbroker

/etc/rocketmq/broker.conf