常见的消息队列有：abbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMQ，而其中，Kafka在单机呑吐量以及可用性上都非常优秀，本文基于docker创建kafka集群，之后测试下消息的发布与接收，通过本文，你可以快速的搭建kafka集群。 首先，我们需要安装 docker、docker-compose，这部分内容可以查阅 本博客关于docker的内容，现在，我们搭建 kafka 集群吧。 1、docker run -d --name zookeeper -p 2181 -t wurstmeister/zookeeper 2、docker run -d --name kafka --publish 9092:9092 --link zookeeper --env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 --env KAFKA_ADVERTISED_HOST_NAME=127.0.0.1 --env KAFKA_ADVERTISED_PORT=9092 --volume /etc/localtime:/etc/localtime wurstmeister/kafka:latest 现在 我们已经部署完毕了，没错，就这么简单。 测试下吧： 1、docker exec -it kafka /bin/bash 2、cd /opt/kafka/ 3、创建一个主题 kpromise：bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic kpromise 4、生产消息：bin/kafka-console-producer.sh --broker-list localhost:9092 --topic kpromise 进入后随便输入，之后按 ctrl + c 退出 5、消费消息：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic kpromise 此时你应该看到第 4 步 里面输入的内容了。 踩过的坑：直接使用 https://github.com/wurstmeister/kafka-docker 然后 docker-compose up ，结果太慢了，感觉镜像源没有为中国用户优化啊， 所以建议还是用上面的方式吧，当然，上面的方式也只是个 demo，不应该用于实际研发中，可能有性能等方面的问题。持续更新中。