消息中心选择kafka作为消息中间件,docker部署kafka已经比较成熟,所以选择docker快速部署
步骤拉取镜像
docker pull wurstmeister/kafka docker pull wurstmeister/zookeeper
启动zookeeper
docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper
启动kafka 记得修改自己的zookeper ip
docker run --name kafka01 -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_ConNECT=192.168.0.223:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.136.60.72:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -d wurstmeister/kafka
进入容器
docker exec -it kafka01 bash
进入kafka安装目录
cd /opt/kafka_2.13-2.8.1/bin/
启动生产者
./kafka-console-producer.sh --broker-list localhost:9092 --topic sun
发送消息
{"datas":[{"channel":"","metric":"temp


