转载请注明:汪明鑫的个人博客 » 消息队列 全景图...
汪明鑫
1年前 (2019-10-14) 130浏览 0评论
0喜欢
Spring Boot + ActiveMQ + Mybatis + mysql
基于MQ + 事件表 实现分布式事务解决方案
什么是分布式事务就不啰嗦了,我了解的也不多
就是rpc调用导致的事务问题,区别于本地事务
比如:
用户注册后,即送皮肤
用户注册是操作在D...
汪明鑫
1年前 (2019-09-26) 165浏览 0评论
0喜欢
消息协议
AMQP
MQTT
STOMP
XMPP
JMS
接口规范,与平台无关的API
是对AMQP、MQTT、STOMP、XMPP更高一层抽象
类似JDBC
点对点模型
发布/订阅模型
ActiveMQ完全支持JMS
如...
汪明鑫
1年前 (2019-09-25) 169浏览 0评论
0喜欢
利用Socket,ArrayBlockingQueue,IO流模拟消息队列的消息生产和消费
需要一个消息处理中心,存储消息
生产消息客户端 —> 消息处理中心 —> 消费消息客户端
模拟最简单的一种模式
生产者往消息中心推...
汪明鑫
1年前 (2019-09-20) 128浏览 0评论
0喜欢
Kafka一直启不起来,查看了日志,发现报UnsupportedClassVersionError的错,看到有ClassVersion和ClassLoader,就知道可能是Kafka和jdk的版本不对头,于是我重装了Kafka的低版本,结果还不行。。。。
后来把j...
汪明鑫
2年前 (2018-09-12) 228浏览 0评论
0喜欢
Kafka集群的安装和配置步骤:
1,访问官网 Apache Kafka
2,下载
选择合适版本下载,注意不同的Kafka版本对jdk版本是有要求的
3,把下载的kafka安装包上传至服务器(这里我使用的winscp)
...
汪明鑫
2年前 (2018-09-12) 228浏览 0评论
0喜欢
Kafka为什么是高性能,高吞吐的?
1)取决于kafka的顺序写(Kafka可以每秒600M顺序读写 ),顺序写速读比随机写速度高很多
2)批量发送,在异步发送模式中。kafka允许进行批量发送,也就是先将消息缓存到内存中,然后一次请求批量发送出去。这样减少了磁盘频繁io以及网...
汪明鑫
2年前 (2018-09-11) 226浏览 0评论
0喜欢
学习Kafka之前,我们先了解一下消息队列的一些概念
描述一个场景,有一个电商系统,有两部分是订单系统和配送系统,部署在一台服务器上
后来用户量大了,系统跑不动了,于是“拆分”
订单系统这边调用远程web服务,迟迟得不到配送系统的响应,我这边就得一...
汪明鑫
2年前 (2018-09-08) 262浏览 0评论
0喜欢