赞
踩
P2P点对点:使用queue作为通信载体
解析:
消息生产者生产消息发送到queue队列中,然后消息消费者从queue中消费消息
消费者消费消息后,queue中不再存储,所以消息消费者不可能消费到已经被消费过的消息,queue支持存在多个消费者,但是对一个消息而言,只会有一个消费者可以消费
Pub/Sub发布订阅(广播):使用topic作为通信载体
解析:
消息生产者将消息发布到Topic中,同时有多个消费者订阅消费该消息。和点对点方式不同,发布到Topic的消息会被所有消费者消费
queue实现了负载均衡,将生产者生产的消息发送到消息队列中,由多个消费者消费,但一个消息只能被一个消费者消费,当没有消费者可用时,这个消息会被保存到直到有一个可用的消费者。
Topic实现了发布和订阅,当你发布一个消息,所有订阅这个Topic的服务都能得到这个消息,所以从1到N个订阅者都能得到一个消息的拷贝。
kafka-topics.sh --create --zookeeper 你的zookeeper的IP:2181 --replication-factor 副本数 --partitions 分区数 --topic 消息队列名
kafka-topics.sh --zookeeper 你的zookeeper的IP:2181 --list
kafka-console-producer.sh --topic 消息队列名 --broker-list 你的kafka队列IP:9092
kafka-console-consumer.sh --bootstrap-server 你的kafka队列IP:9092 --topic 消息队列名
kafka-run-class.sh kafka.tools.GetOffsetShell --topic 消息队列名 --time -1 --broker-list 你的kafka队列IP:9092
kafka-consumer-groups.sh -bootstrap-server 你的kafka队列IP:9092 --group 你的消费者组名 --reset-offsets -all-topics --to-earliest --execute
kafka-topic.sh --delete --zookeeper 你的zookeeper的IP:2181 --topic 消息队列名
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。