Kafka 引入逻辑 Topic, 将消息分主题管理
物理存储使用的partition, partition 目的是水平扩展，增加吞吐量，让不同的消息路由到不同的partition
partition为了高可用，又引入了副本机制，使用方可以指定副本数量partit...
汪明鑫
1年前 (2022-01-19) 174浏览 0评论
6喜欢
Kafka部署
参考之前的文章，搭建单机伪分布式ZK集群和Kafka集群
10分钟搭建单机伪分布式ZK集群
10分钟搭建单机伪分布式Kafka集群
搞事情的过程中遇到过2问题，有点恶心
Java客户...
汪明鑫
1年前 (2021-12-16) 203浏览 0评论
3喜欢
创建一个kafka目录
mkdir kafka
cd kafka
wget https://archive.apache.org/dist/kafka/1.1.0/kafka_2.11-1.1.0.tgz
拷贝3份kafka配置文件
[root@xinyes...
汪明鑫
1年前 (2021-12-13) 166浏览 0评论
0喜欢
先贴上我精心制作的kafka架构图
然后开始用大白话去聊聊我眼里的Kafka
首先介绍的是kafka 外部依赖的 分布式协调服务Zookeeper，大家一般简称ZK
协调服务顾名思义做调解员的，那么kafka需要协调什么呢？
当然是协调broker成...
汪明鑫
1年前 (2021-11-10) 249浏览 0评论
0喜欢
前言
初学RocketMQ, 熟悉RocketMQ的老哥可以跳过本文
从0到1简单搭建单机RocketMQ以及简单的demo跑下消息生产和消费
安装
注意安装的rocketMQ版本和客户端版本最好一致，不然有些版本可能导致消息一直发不出去的问题
下载这个版本即可，...
汪明鑫
2年前 (2021-07-22) 317浏览 0评论
1喜欢
转载请注明：汪明鑫的个人博客 » 消息队列 全景图...
汪明鑫
3年前 (2019-10-14) 386浏览 0评论
1喜欢
Spring Boot + ActiveMQ + Mybatis + mysql
基于MQ + 事件表 实现分布式事务解决方案
什么是分布式事务就不啰嗦了，我了解的也不多
就是rpc调用导致的事务问题，区别于本地事务
比如：
用户注册后，即送皮肤
用户注册是操作在D...
汪明鑫
3年前 (2019-09-26) 451浏览 0评论
0喜欢
消息协议
AMQP
MQTT
STOMP
XMPP
JMS
接口规范，与平台无关的API
是对AMQP、MQTT、STOMP、XMPP更高一层抽象
类似JDBC
点对点模型
发布/订阅模型
ActiveMQ完全支持JMS
如...
汪明鑫
3年前 (2019-09-25) 468浏览 0评论
0喜欢
利用Socket,ArrayBlockingQueue,IO流模拟消息队列的消息生产和消费
需要一个消息处理中心，存储消息
生产消息客户端 —> 消息处理中心 —> 消费消息客户端
模拟最简单的一种模式
生产者往消息中心推...
汪明鑫
3年前 (2019-09-20) 357浏览 0评论
0喜欢
Kafka一直启不起来，查看了日志，发现报UnsupportedClassVersionError的错，看到有ClassVersion和ClassLoader，就知道可能是Kafka和jdk的版本不对头，于是我重装了Kafka的低版本，结果还不行。。。。
后来把j...
汪明鑫
4年前 (2018-09-12) 439浏览 0评论
0喜欢
