【Java Web】Kafka，构建TB级异步消息系统-Toy模板网

这篇具有很好参考价值的文章主要介绍了【Java Web】Kafka，构建TB级异步消息系统。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

BlockingQueue
- 解决线程通信的问题；
- 阻塞方法：put从队列中存一个， take 从队列中拿出一个
生产者消费者模式
- 生产者：产生数据的线程；
- 消费者：使用数据的线程。
实现类
- ArrayBlockingQueue
- LinkedBlockingQueue
- ProrityBlockingQueue、SynchronousQueue、DelayQueue等

【Java Web】Kafka，构建TB级异步消息系统,java,java,前端,kafka

Kafka简介
- kafka 是一个分布式的流媒体平台；
- 应用：消息系统、日志收集、用户行为追踪、流式处理。
Kafka特点
- 高吞吐量、消息持久化、高可靠性、高扩展性
Kafka术语
- Broker(一个服务器)、Zookeeper（集群）
- Topic(文件夹)、Partition(分区，提高容错率)、Offset(在分区中的位置)
- Leader Replica（主副本，如果需要从分区获取数据，主副本可以响应）、Follower Replica（随从副本，备份）

-卡夫卡能处理海量数据（高吞吐量），因为卡夫卡将数据存在硬盘此类的介质里，而硬盘比内存的价格低廉，所以它可以持久化。卡夫卡的分布式保证了高可靠性。如果想要加入新服务器，只需简单的配置，因此具有高扩展性。

【1】Mac 启动Zookeeper:

./zookeeper-server-start.sh ../config/zookeeper.properties &

【2】启动Kafka:

./kafka-server-start.sh ../config/server.properties &

【3】创建Topic

./kafka-topics.sh --bootstrap-server localhost:9092 --create --topic javaTopic --partitions 2 --replication-factor 1

replication-factor：指定副本数量
partitions：指定分区

【4】查看Topic

./kafka-topics.sh --bootstrap-server localhost:9092 --list

【5】删除Topic

./kafka-topics.sh --bootstrap-server localhost:9092 --delete -topic javaTopic

【6】生产消费数据
【6-1】生产者

./kafka-console-producer.sh --broker-list localhost:9092 --topic javaTopic

【6-2】消费者文章来源地址https://www.toymoban.com/news/detail-708819.html

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic javaTopic --from-beginning

到了这里，关于【Java Web】Kafka，构建TB级异步消息系统的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

【Java Web】Kafka，构建TB级异步消息系统