手把手教你在 Windows 上安装 Rabb...
首先我们要知道，rabbitmq是用erlang写的，所以我们第一步需要安装erlang，然后我们再安装rabbitmq，安装rabbitmq的方式有很多，但是别忘了我们这是Windows环境，一切皆可安装包。这次我们用到的版本是er...
Kafka遇到性能瓶颈不要慌，试试这 6 种提...
Kafka 以其高吞吐量、低延迟和可扩展性而备受青睐。无论是在实时数据分析、日志收集还是事件驱动架构中，Kafka 都扮演着关键角色。但是，如果 Kafka 使用不当，也可能会面临性能瓶颈，影响系统的整体效率。所以，了解如何提升 Ka...
Kafka中的key有的作用
我们在使用 Kafka 时，最简单、最常用的方式是只设置 topic（主题）和 value（消息体），如下所示： 这样的话获取消息的代码也很简单，如下所示：java代码解读复制代码@KafkaListener(topics = "...
Java的switch语句与Scala的模式匹...
背景最近在看kafka源码发现，kafka中scala语法用到了大量的模式匹配，所以就来简单研究下scala的模式匹配java switch使用 int xiaozou = 1; switch (xiaoz...
聊聊 RabbitMQ 延迟队列的实现原理
使用 RabbitMQ 和 RocketMQ 的人是幸运的，因为这两个 MQ 自身提供了延迟队列的实现，不像用 Kafka 的同学那么苦逼，还要自己实现延迟队列。当然，这都是题外话，今天咱们重点来聊聊 RabbitMQ 延迟队列的实现...
使用WebSocket和RabbitMQ实现任...
1、WebSocket简述WebSocket 是 HTML5 新增的 API，是一种基于 TCP 连接的持久化双向通信协议。WebSocket 默认连接端口是80，运行端口是443。WebSocket 连接地址示例（以 ws 或者 w...
RocketMQ 消费消息的Push模式，是推...
RocketMQ 消费消息是推还是拉？RocketMQ 是一个分布式消息中间件，广泛应用于高性能、高可靠性的消息传输场景。对于很多开发者来说，理解 RocketMQ 消费消息的机制是至关重要的。一个常见的问题是：RocketMQ 的消...
原生 RocketMq 使用方法以及 Spri...
原生版本新建一个SpringBoot项目,pom文件如下<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" ...