RabbitMQ和Kafka:Win10安装教程

在分布式系统中，最常用的两个消息中间件就是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 -version

2.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，修改后保存。

zoo.cfg

2.2.2 环境变量设置

右键->我的电脑->属性->高级系统设置->环境变量

高级系统设置

环境变量

系统变量处新建，然后新增ZOOKEEPER_HOME: D:\software\zookeeper\apache-zookeeper-3.6.1-bin (zookeeper目录)

image.png

ZOOKEEPER_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.png

2.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

创建TOPICS

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

打开producer

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

打开consumer

2.4.4 测试

在producer中输入"hello kafka"，然后查看consumer中是否收到消息

producer

consumer

一共五个cmd窗口

3. 总结

本文仅简单记录了RabbitMQ和Kafka在Windows下的安装过程，没有深入理解它们的原理。希望对有需要的读者有帮助。