利用Socket,ArrayBlockingQueue,IO流模拟消息队列的消息生产和消费
需要一个消息处理中心，存储消息
生产消息客户端 —> 消息处理中心 —> 消费消息客户端
模拟最简单的一种模式
生产者往消息中心推...
汪明鑫
2天前 4浏览 0评论
0喜欢
Kafka一直启不起来，查看了日志，发现报UnsupportedClassVersionError的错，看到有ClassVersion和ClassLoader，就知道可能是Kafka和jdk的版本不对头，于是我重装了Kafka的低版本，结果还不行。。。。
后来把j...
汪明鑫
1年前 (2018-09-12) 85浏览 0评论
0喜欢
Kafka集群的安装和配置步骤：
1，访问官网 Apache Kafka
2，下载
选择合适版本下载，注意不同的Kafka版本对jdk版本是有要求的
3，把下载的kafka安装包上传至服务器（这里我使用的winscp）
...
汪明鑫
1年前 (2018-09-12) 88浏览 0评论
0喜欢
Kafka为什么是高性能，高吞吐的？
1）取决于kafka的顺序写（Kafka可以每秒600M顺序读写 ），顺序写速读比随机写速度高很多
2）批量发送，在异步发送模式中。kafka允许进行批量发送，也就是先将消息缓存到内存中，然后一次请求批量发送出去。这样减少了磁盘频繁io以及网...
汪明鑫
1年前 (2018-09-11) 69浏览 0评论
0喜欢
学习Kafka之前，我们先了解一下消息队列的一些概念
描述一个场景，有一个电商系统，有两部分是订单系统和配送系统，部署在一台服务器上
后来用户量大了，系统跑不动了，于是“拆分”
订单系统这边调用远程web服务，迟迟得不到配送系统的响应，我这边就得一...
汪明鑫
1年前 (2018-09-08) 99浏览 0评论
0喜欢
