在分布式系统中,最常用的两个消息中间件就是RabbitMQ和Kafka了,本文将介绍如何在Win10上安装RabbitMQ和Kafka。
如果要看如何在Mac上安装,请移步另一篇文章
RabbitMQ和Kafka:Mac安装教程
1. RabbitMQ for windows安装教程
1.1 安装Erlang
RabbitMQ 是用Erlang语言编写的,所以要安装Erlang。
1.1.1 下载Erlang
点击官网连接http://www.erlang.org/downloads,根据自己的机型选择下载包,这个过程可能会很慢,需要多尝试几次下载。
点击下载 双击exe 点击next 选择安装目录 点击install按钮1.1.2 配置环境变量
右键我的电脑->属性->高级系统设置->环境变量->新建,新增
ERLANG_HOME:D:\software\Erlang\erl-23.0(安装目录)
点击确定按钮保存
新增ERLANG_HOME系统变量中找到Path,点击编辑按钮
找到path新增一行%ERLANG_HOME%\bin,然后点击所有窗口的确定按钮,保证保存成功。
新增一行1.1.3 测试
win+r 选择cmd命令窗口打开,输入命令 erl ,然后回车查看到版本说明,说明安装成功。
查看版本1.2 安装RabbitMQ
1.2.1 安装RabbitMQ软件
进入RabbitMQ下载主页https://www.rabbitmq.com/install-windows.html,然后往下滑倒下载部分
下载 双击exe 选择安装目录 安装完成1.2.2 安装RabbitMQ-Plugins
打开cmd命令窗口,切换目录到RabbitMQ的sbin目录,笔者的是D:\software\rabbitMQ\rabbitmq_server-3.8.4\sbin目录。然后输入以下命令进行安装。
rabbitmq-plugins enable rabbitmq_management
安装成功
还是在sbin目录下,输入命令rabbitmqctl status,如果出现以下结果说明启动成功。
启动成功然后浏览器地址中输入http://localhost:15672/
登录界面用户名和密码均为guest,输入后点击登录按钮,如果登录成功出现以下界面。
主界面2. Kafka for windows 安装教程
2.1 安装JDK
首先要安装JDLK,JDK安装过程本文在此略过,网上很多教程。笔者使用的是JDK8
java -version2.2 安装zookeeper
Kafka的运行依赖于Zookeeper,所以在运行Kafka之前我们需要安装并运行Zookeeper。
2.2.1 下载
去官网https://zookeeper.apache.org/releases.html#download下载最新版本
Apache ZooKeeper 3.6.1 选择HTTP下载 下载包解压到本地文件夹,如果解压过程提示是否替换文件,选择全部是即可。
解压2.2.2 配置
找到解压路径下\apache-zookeeper-3.6.1-bin\conf\zoo_sample.cfg的文件,将zoo_sample.cfg重命名为zoo.cfg
zoo_sample.cfg然后将zoo.cfg用编辑器打开,搜索找到dataDir=/tmp/zookeeper这行,然后修改为
dataDir=./apache-zookeeper-3.6.1-bin/data,修改后保存。
2.2.2 环境变量设置
右键->我的电脑->属性->高级系统设置->环境变量
高级系统设置 环境变量系统变量处新建,然后新增ZOOKEEPER_HOME: D:\software\zookeeper\apache-zookeeper-3.6.1-bin (zookeeper目录)
image.pngZOOKEEPER_HOME: D:\software\zookeeper\apache-zookeeper-3.6.1-bin
ZOOKEEPER_HOME系统变量处找到path,点击编辑,然后新建一行 %ZOOKEEPER_HOME%\bin
修改path 新增一行
2.2.3 启动zookeeper
运行cmd窗口,然后输入zkserver,出现以下效果表示启动成功。并且cmd窗口不要关闭。
image.png2.2.4 解决端口被占用的情况
如果8080端口被占用,可以找到被占用的进程,然后杀掉进程
netstat -aon|findstr "8080"
tasklist |findstr "5800"
找到被占用的进程id
2.3 安装kafka
2.3.1 下载kafka
去官网下载http://kafka.apache.org/downloads.html,笔者下载的是2.5.0版本
点击链接 选择HTTP下载 解压到本地文件夹2.3.2 配置
找到\kafka_2.13-2.5.0\config\server.properties文件,用编辑器打开,找到log.dirs=/tmp/kafka-logs这行,修改成log.dirs=./logs
server.properties 修改日志路径2.3.3 启动kafka
打开cmd命令窗口,依次输入以下命令,并不要关闭cmd窗口
>d: # 切换目录
>cd D:\software\kafka\kafka_2.13-2.5.0 # 切换到kafka安装目录
>.\bin\windows\kafka-server-start.bat .\config\server.properties # 启动kafka
启动kafka
2.4 测试TOPICS
2.4.1 创建TOPIC
- 打开cmd,进入到kafka安装目录D:\software\kafka\kafka_2.13-2.5.0\bin\windows(对应自己的安装目录)
- 输入命令 kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 创建topic
2.4.2 打开producer
- 新打开一个cmd,切换到kafka安装目录D:\software\kafka\kafka_2.13-2.5.0\bin\windows(对应自己的安装目录)
- 输入命令:kafka-console-producer.bat --broker-list localhost:9092 --topic test
2.4.3 打开consumer
- 新打开一个cmd,切换到kafka安装目录D:\software\kafka\kafka_2.13-2.5.0\bin\windows(对应自己的安装目录)
- 输入命令:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
2.4.4 测试
在producer中输入"hello kafka",然后查看consumer中是否收到消息
producer consumer 一共五个cmd窗口3. 总结
本文仅简单记录了RabbitMQ和Kafka在Windows下的安装过程,没有深入理解它们的原理。希望对有需要的读者有帮助。
网友评论