消息队列的作用就是提高运行速度，防止线程堵塞。 kafka的作用     异步  通过在消息队列发送消息的方式，将对应的业务作为监听者，此时我们只需要考虑发送消息的时间即可，大大提高了运行的速度。     解耦   如果使用原来的直接调用对应业务的方式，在被调用业务发生修改是，调用业务也需要修改代码，存在很大的耦合，所以使用消息队列的方式，后续我们只需要关注消 继续阅读

消息队列的流派 什么是 MQ 有 Broker 的 MQ 重 Topic 轻 Topic AMQP 中有四种 exchange Direct exchange：key 就等于 queueFanout exchange：无视 key，给所有的 queue 都来一份Topic exchange：key 可以用“宽字符”模糊匹配 queueHeaders exchange：无视 key&#xf 继续阅读

一、消息队列消息队列中间件是分布式系统中重要的组件，主要解决应用耦合、异步消息、流量削锋等问题，实现高性能、高可用、可伸缩和最终一致性架构，是大型分布式系统不可缺少的中间件。目前在生产环境中使用较多的消息队列有ActiveMQ、RabbitMQ、Kafka、RocketMQ等。A、特性异步性：将耗时的同步操作以消息的方式进行异步化处理，减少了同步等待的时间；松耦合：消息队列减少了服务之间的耦合性&# 继续阅读

消息发送流程 1.生产者main线程调用send发送消息，先走拦截器，然后会将消息进行序列化，然后选择对应的分区器，将消息发送到RecordAccumulator中，默认是32m 2.Sender线程会异步读取，要不数据达到batch的大小 进行数据拉取，要么数据达到linger的时间，读取数据之后通过网络进行将数据发送到Kafka集群。如果出现失败在进行重试，直到B 继续阅读

一、消息中间件相关知识     1、概述 消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自主开发RocketMQ等。       2、消息中间件的组成       2.1 Broker   消息服务器&#xff0c 继续阅读

给大家说一个笑话：我被ChatGPT忽悠了。 引言 前两天在编码的时候遇到一个事务未生效的问题，当时感觉比较诡异。因为我一个方法注解了@Transactional注解，但是事务未生效，而且这个方法是kafka监听之后调用的。 我出于对kafka的不熟悉，第一反应就是问下ChatGPT，结果竟然被它忽悠了！！！ 实例代码如下： 这里的 继续阅读

一面 kafka在应用场景以及 项目 里的实现bitmap底层object里有哪些方法hashmap相关sychronized和reentrantlock相关问题以及锁升级cas和volatile线程几种状态以及转化jvm内存模型mybatis相关问题Redis数据结构，问了下跳表的底层RDB和AOFMySQL索引有哪些b+树底层实现最左前缀原理 二面 线程的状态cms增量更新法GcRoots是哪些java基础mysql索引项目具体实现 三面 索引谈谈多线程j 继续阅读