Docker下kafka學習三部曲之一：極速體驗kafka

Kafka是一種高吞吐量的分佈式發佈訂閱消息系統，從本章開始咱們先極速體驗，再實戰docker下搭建kafka環境，最後開發一個java web應用來體驗kafka服務。

咱們一塊兒用最快的速度體驗kafka的消息發佈訂閱功能：

新建一個docker-compose.yml文件，內容以下：

version: '2'
services:
  zk_server: 
    image: daocloud.io/library/zookeeper:3.3.6
    restart: always
  kafka_server: 
    image: bolingcavalry/kafka:0.0.1
    links: 
      - zk_server:zkhost
    command: /bin/sh -c '/usr/local/work/start_server.sh'
    restart: always
  message_producer: 
    image: bolingcavalry/kafka:0.0.1
    links: 
      - zk_server:zkhost
      - kafka_server:kafkahost
    restart: always
  message_consumer: 
    image: bolingcavalry/kafka:0.0.1
    links: 
      - zk_server:zkhost
    restart: always複製代碼

打開終端，在docker-compose.yml所在目錄下執行docker-compose up -d，因爲須要從hub.docker.com下載鏡像，因此須要等待幾分鐘，下載結束後會自動啓動四個容器，以下圖：

爲了更好的觀察效果，咱們要打開三個終端對不一樣的容器作操做，在後面咱們用編號來表達不一樣的終端，編號對應以下：

1號 : kafka server

2號 : 消息生產者(producer)

3號 : 消息消費者(consumer)

1號終端中輸入如下命令，便可看到kafka server的實時輸出信息：

docker logs -f dockerkafka_kafka_server_1複製代碼

輸入命令後看到的信息以下圖，與zookeeper鏈接成功，啓動成功:

2號終端中輸入如下命令，進入消息生產者容器：

docker exec -it dockerkafka_message_producer_1 /bin/bash複製代碼

再執行如下命令建立一個主題：

$WORK_PATH/$KAFKA_PACKAGE_NAME/bin/kafka-topics.sh --create --zookeeper zkhost:2181 --replication-factor 1 --partitions 1 --topic test001複製代碼

3號終端中輸入如下命令，進入消息消費者容器：

docker exec -it dockerkafka_message_consumer_1 /bin/bash複製代碼

執行如下命令能夠查看當前kafka sever上的全部主題：

$WORK_PATH/$KAFKA_PACKAGE_NAME/bin/kafka-topics.sh --list --zookeeper zkhost:2181複製代碼

能夠看到剛纔在2號終端建立的主題，以下圖：

繼續在3號終端上執行如下命令，便可訂閱主題爲test001的消息：

$WORK_PATH/$KAFKA_PACKAGE_NAME/bin/kafka-console-consumer.sh --zookeeper zkhost:2181 --topic test001 --from-beginning複製代碼

此時回到1號終端，能夠看到消息訂閱者容器的鏈接信息，以下圖：

如今主題也建立了，訂閱也添加了，能夠測試消息的發送和接收了：

在2號終端，執行如下命令，就能夠進入發送消息的交互模式：

$WORK_PATH/$KAFKA_PACKAGE_NAME/bin/kafka-console-producer.sh --broker-list kafkahost:9092 --topic test001複製代碼

此時已經進入了交互模式，繼續輸入一個字符串，例如hello world!，再輸入回車鍵，便可發送內容爲"hello world!"的消息，以下圖：

如今回到3號終端，能夠看到已經接收到了最新的消息，內容被打印出來了，以下圖：

最後咱們回到1號終端，能看到消息生產者的鏈接信息，以下圖：

至此，咱們快速體驗了kafka的消息發佈訂閱功能，下一章咱們再細說docker下kafka環境的搭建過程。

歡迎關注個人公衆號：程序員欣宸