Docker安装RabbitMQ与Kafka
2024-08-23 19:26:31
RabbitMq安装(dokcer)
下载镜像
docker pull rabbitmq
创建并启动容器
docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 -v `pwd`/data:/var/lib/rabbitmq --hostname myRabbit -e RABBITMQ_DEFAULT_VHOST=my_vhost -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin rabbitmq
- -d 后台运行容器;
- --name 指定容器名;
- -p 指定服务运行的端口(5672:应用访问端口;15672:控制台Web端口号);
- -v 映射目录或文件;
- --hostname 主机名(RabbitMQ的一个重要注意事项是它根据所谓的 “节点名称” 存储数据,默认为主机名);
- -e 指定环境变量;(RABBITMQ_DEFAULT_VHOST:默认虚拟机名;RABBITMQ_DEFAULT_USER:默认的用户名;RABBITMQ_DEFAULT_PASS:默认用户名的密码)
启动rabbitmq后台管理服务
docker exec -it rabbitmq rabbitmq-plugins enable rabbitmq_management
访问后台页面:
http://127.0.0.1:15672 初始密码: admin admin
Docker安装Kafka
拉取镜像:
docker pull wurstmeister/zookeeper
docker pull wurstmeister/kafka
2、创建容器
docker run -di --name=zk_01 -p 2181:2181 --privileged=true wurstmeister/zookeeper
docker run -di --network=host --name=kafka_01 -v /etc/localtime:/etc/localtime --privileged=true wurstmeister/kafka:latest /bin/bash
3、修改kafka的配置文件server.propertiescd /opt/kafka_2.12-2.5.0/config/vi server.propertiesserver.properties配置文件的内容如下所示broker.id=0
# 表示broker的编号,如果集群中有多个broker,则每个broker的编号需要设置的不同listeners=PLAINTEXT://127.0.0.1:9092
# brokder对外提供的服务入口地址log.dirs=/tmp/kafka-logs
# 设置存放消息日志文件的地址zookeeper.connect=127.0.0.1:2181
# Kafka所需Zookeeper集群地址,教学中Zookeeper和Kafka都安装本机
4、启动kafkabin/kafka-server-start.sh config/server.properties
5、创建主题bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --create --topic demo--partitions 2 --replication-factor 1
# 创建主题,表示副本因子,表示每一个分区具有的副本数(包含分区本身),副本因子数不能超过broker的数量bin/kafka-topics.sh --zookeeper 172.19.0.60:2181 --list
# 查看所有的主题bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --describe --topic demo
# 查看主题的详细信息bin/kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic demo
# 删除主题bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic demo
# 开启一个消费者bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic demo
# 开启一个生产者修改分区数增加分区数bin/kafka-topics.sh --alter --zookeeper 127.0.0.1:2181 --topic demo--partitions 3修改分区数时,仅能增加分区个数。若是用其减少 partition 个数,则会报如下错误信息:bin/kafka-topics.sh --alter --zookeeper 127.0.0.1:2181 --topic demo--partitions 2
最新文章
- asp.net identity 2.2.0 在WebForm下的角色启用和基本使用(二)
- JMeter工具的使用-ForEach
- c# ICSharpCode.SharpZipLib.Zip实现文件的压缩
- SQL Server查询优化方法(查询速度慢的原因很多,常见如下几种) .
- JS身份证真实性校验(一)
- leetcode第一刷_Triangle
- js,this,constrct ,prototype
- (转)Maven依赖的jar包下载不了、jar更新不了的解决办法
- 搭建SpringCloud-Eureka 注册中心以及服务提供与调用
- .NET Framework和 .Net Core实现不一致的API之 `EmailAddressAttribute`
- 【苹果通知APNs】不知道大家用过PushSharp没?
- WLST
- HDU - 6314 Matrix(广义容斥原理)
- 初学JSON和AJAX心得透过解惑去学习
- flex布局 响应式布局
- java学习笔记21(迭代器)
- Mac如何搭建 配置 virtualenv python虚拟环境(超级详细,适合小白)
- 马士兵hadoop第二课:hdfs集群集中管理和hadoop文件操作
- SpringMVC 使用 RESTful 架构实现 CRUD 操作
- mfc 创建一个C++ 类
热门文章
- 这行代码告诉你!为什么你地下城与勇士(DNF)的装备强化老是失败?
- ABBYY FineReader 14新增了什么
- guitar pro系列教程(二十):Guitar Pro使用技巧之使用向导
- leetcode 33和 leetcode81
- C++实现任意进制的相互转换
- Verilog 分频器
- Map<;String,Object>;接收参数,Long类型降级为Integer,报类型转换异常
- 老猿学5G扫盲贴:3GPP规范文档命名规则及同系列文档阅读指南
- PyQt(Python+Qt)学习随笔:树型部件QTreeWidget中使用sortItems进行项排序
- PyQt(Python+Qt)学习随笔:QTreeWidgetItem项的子项索引、删除子项的方法