查询到最新的7条

kafka消息队列的初步探索

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

Kafka 入门到精通

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

activemq后台管理 看topic消息_「Java」 - SpringBoot amp; ActiveMQ

一、消息队列消息队列中间件是分布式系统中重要的组件,主要解决应用耦合、异步消息、流量削锋等问题,实现高性能、高可用、可伸缩和最终一致性架构,是大型分布式系统不可缺少的中间件。目前在生产环境中使用较多的消息队列有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一个事务问题,然后被忽悠了

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

京东四面面经整理

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