Rabbitmq消息ack机制
一、初始化项目 1、引入依赖 <!--RabbitMq自动配置-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring
KafkaStream流式计算
一、背景 1、流式计算的概念 一般流式计算会与批量计算相比较。在流式计算模型中,输入是持续的,可以认为在时间上是无界的,也就意味着,永远拿不到全量数据去做计算。同时,计算结果是持续输出的,也即计算结果在时间上也是无界的。流式计算一般对实时性要求较高,同时一般是先定义目标计算,然后数据到来之后将计算逻
Kafka分区和消费
一、分区机制 同一个Topic包含不同的Partition(分区)存储在不同机器 一个分区就是一个提交日志。消息以追加的方式写入分区,然后以先进先出的顺序读取 Partition分区的好处是可以并行读和写,保证kafka高吞吐、高性能、高可用 每个Partition针对每一个消费组设计了独立的偏移量
中间件
未读
Nginx目录结构和配置文件详解
1、目录结构 Nginx 文件结构比较简洁,主要包括配置文件和二进制可执行程序,通过安装包形式安装的 nginx 文件结构跟各 Linux 发行版目录规则存放配置文件和二进制文件的位置 目录结构及文件功能如下: [root@localhost ~]# tree /usr/local/nginx
/u
中间件
未读
SpringBoot整合RabbitMQ实现两种延时队列(订单延迟取消)
一、延时队列概念篇 1、什么是延时队列,延时队列应用于什么场景 延时队列顾名思义,即放置在该队列里面的消息是不需要立即消费的,而是等待一段时间之后取出消费。 那么,为什么需要延迟消费呢?我们来看以下的场景: 网上商城下订单后30分钟后没有完成支付,取消订单(如:淘宝、去哪儿网) 系统创建了预约之后,
中间件
未读
在WIndows下安装Redis
1、首先在Windows下下载安装Redis 下载地址:https://github.com/MicrosoftArchive/redis/releases 根据你电脑系统的实际情况选择32位还是64位,在这里我下载了的是Redis-x64-3.0.500.zip压缩包,压缩后得到解压文件 2、测试