文章
文章用户商铺快讯网址导航

小知识：docker安装RocketMQ的实现步骤

一、检索镜像

?
1
docker search rocketmq

%小知识：docker安装RocketMQ的实现步骤-猿站网-插图

检索具体版本

?
1
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安装RocketMQ的实现步骤-1猿站网-插图

查看当前镜像所有的版本shell命令

?
1
2
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安装RocketMQ的实现步骤-2猿站网-插图

二、创建broker server

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

%小知识：docker安装RocketMQ的实现步骤-3猿站网-插图

三、创建broker

?
1
2
3
4
5
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安装RocketMQ的实现步骤-4猿站网-插图

配置broker.conf

进入rmqbroker容器

?
1
2
3
4
5
docker exec -it rmqbroker /bin/bash
cd /etc/rocketmq/
vi broker.conf

%小知识：docker安装RocketMQ的实现步骤-5猿站网-插图

四、创建rocketmq console

?
1
2
3
4
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安装RocketMQ的实现步骤-6猿站网-插图

然后通过如下命令检查一下启动情况

?
1
docker ps|grep rocketmq

%小知识：docker安装RocketMQ的实现步骤-7猿站网-插图

http://192.168.23.131:8180/

%小知识：docker安装RocketMQ的实现步骤-8猿站网-插图

五、测试

由于我在宿主机安装rocketmq,测试如下：

?
1
2
#测试消息发送命令
sh tools.sh org.apache.rocketmq.example.quickstart.producer

%小知识：docker安装RocketMQ的实现步骤-9猿站网-插图

%小知识：docker安装RocketMQ的实现步骤-10猿站网-插图

?
1
2
#测试消息接收命令
sh tools.sh org.apache.rocketmq.example.quickstart.consumer

%小知识：docker安装RocketMQ的实现步骤-11猿站网-插图

六、java样例

?
1
2
3
4
5
<dependency>
<groupid>org.apache.rocketmq</groupid>
<artifactid>rocketmq-client</artifactid>
<version>4.9.2</version>
</dependency>

消息发送（producer端发送同步消息）

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
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();
}
}

消费消息

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
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”);
}
}

七、其他

查看rmqbroker ip

?
1
docker inspect rmqbroker

%小知识：docker安装RocketMQ的实现步骤-12猿站网-插图

broker容器中默认的配置文件的路径为

?
1
/etc/rocketmq/broker.conf

官网：apache rocketmq

参考：

docker中rocketmq的安装与使用_冯立彬的博客-csdn博客_docker rocketmq

到此这篇关于docker安装rocketmq的实现步骤的文章就介绍到这了,更多相关docker安装rocketmq内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！

原文链接：https://blog.csdn.net/u012965203/article/details/121236406

声明： 猿站网有关资源均来自网络搜集与网友提供，任何涉及商业盈利目的的均不得使用，否则产生的一切后果将由您自己承担！ 本平台资源仅供个人学习交流、测试使用 所有内容请在下载后24小时内删除，制止非法恶意传播，不对任何下载或转载者造成的危害负任何法律责任！也请大家支持、购置正版！ 。本站一律禁止以任何方式发布或转载任何违法的相关信息访客发现请向站长举报，会员发帖仅代表会员个人观点，并不代表本站赞同其观点和对其真实性负责。本网站的资源部分来源于网络，如有侵权烦请发送邮件至：2697268773@qq.com进行处理。
dockerrocketmq检索
建站知识

小知识：Docker实现从零开始搭建SOLO个人博客的方法步骤

2023-3-14 19:30:36

建站知识

小知识：docker-compose搭建mongodb、mysql的详细过程

2023-3-14 19:45:36

猜你喜欢
0 条回复 A文章作者 M管理员
    暂无讨论，说说你的看法吧
❯
个人中心
购物车
优惠劵
今日签到
有新私信 私信列表
搜索

  • 扫码打开当前页

返回顶部