最新 最热

为什么需要消息队列,及使用消息队列的好处?

业务无关,一个具有普适性质的消息队列组件不需要考虑上层的业务模型,只做好消息的分发就可以了,上层业务的不同模块反而需要依赖消息队列所定义的规范进行通信。...

2022-08-12
1

kafka实战教程(python操作kafka),kafka配置文件详解

应用往Kafka写数据的原因有很多:用户行为分析、日志存储、异步通信等。多样化的使用场景带来了多样化的需求:消息是否能丢失?是否容忍重复?消息的吞吐量?消息的延迟?...

2022-08-12
0

消息中间件MQ与RabbitMQ面试题(2020最新版)

Java面试总结汇总,整理了包括Java基础知识,集合容器,并发编程,JVM,常用开源框架Spring,MyBatis,数据库,中间件等,包含了作为一个Java工程师在面试中需要用到或者可能用到的绝大部分知识。欢迎大家阅读,本人见识有限,写的博客难免...

2022-08-11
0

《redis in action》发布和订阅

之前我们说redis中的发布订阅有点问题,问题就是会存在消息丢失的问题。当时我们说还有几个参数。而且redis的发布订阅的时候,信道的断路的问题也是消息丢失的原因之一。那么如何诸如QQ这种发布订阅的问题如何用redis去...

2022-08-11
0

RabbitMq事务实现

我们都知道事务的四大特性,但是那是针对的数据库的事务。但是Rabbitmq的事务到底是表达何种意思?根据一般概念的规律来说,mq的事务和数据库事务是类似的。我们可以将mq看做是数据库。...

2022-08-11
0

RabbitMq备胎交换器

备胎交换器简称AE,生产者在发送消息的时候如果不设置mandatory参数,那么消息在未被路由的情况下将会丢失;如果设置了mandatory参数,那么需要添加reutrnListener的编程逻辑。生产者的代码将变得复杂,如果既不想复杂化生产者...

2022-08-11
0

RabbitMq消息确认和拒绝

今天夸平台和其他部门协作,需要给对方提供两个接口,但是最后发现两个项目用的是两套SSO,一个是正规SSO,一套是我们使用的”假SSO“,涉及的部门有4个。最后和对方系统的产品经理一起找了正规SSO领导寻求解决问题,沟通中发现...

2022-08-11
0

AMQP协议探索

1.什么是AMQP协议(Advanced Message Queuing Protocol高级消息队列协议)

2022-08-11
0

键盘钩子入门

钩子是操作系统消息处理的一种机制。通过钩子,应用程序可以安装一个钩子回调过程让系统调用,从而监视系统中的消息队列。在这些消息到达目标窗口之前对这些消息进行处理。...

2022-08-11
0

编写一个配置化的Kafka Proxy,让你分钟级别接入Kafka

消息队列作为服务解耦、异步收发消息的组件,如今已经广泛应用于各大互联网公司,具备一定规模的公司会有专门的团队负责维护消息队列。当我们需要使用消息队列时,得写专门的代码进行连接,比如若用Golang编码,当需要使用Kafk...

2022-08-10
0