×

rabbitmq

RabbitMQ死信队列和延时队列的使用(三)

李 发表于2024-05-02 浏览5164 评论0
1、死信队列 因为某些原因导致消息在queue里面无法被消费,并且这些消息没有后续的处理,那么这些消息就称为死信,后续处理死信的队列就是死信队列。 1.1、产生死信的来源 消息TTL过期; 队列达到最大长度,无法添加数据到队列中; 消息被拒绝并且没有设置直接丢弃; 1.2、模型图 1.2.1、TTL过期实例 import com.example.wwy.rabbit.units.ChannelUnit; import com.rabbitmq.client.AMQP;

scala

Flink学习笔记(一)简介(flink基础教程 豆瓣)

AsO AsO 发表于2024-05-02 浏览5072 评论0
学习致谢: https://www.bilibili.com/video/BV1Gt4y1z7bR?p=2 框架版本 编程语言 Flink官方提供了Java、Scala、Python语言接口用以开发Flink应用程序,但是Flink的源码是使用Java语言进行开发的,且Flink被阿里收购后,未来的主要编程语言都一直会是Java(因为阿里是Java重度使用者! ),且GitHub上关于Flink的项目,大多数是使用Java语言编写的。所以课程中以Java语言为主进行Flink的

rabbitmq

RabbitMQ发送消息不断创建新Channel, 信道缓存“失效“

wangmeda wangmeda 发表于2024-05-02 浏览5834 评论0
记录问题的解决过程。解决的结果代码在最后的总结部分,拉到底就完事。 问题: RabbitMQ发送消息时,会不断创建新的信道(Channel),直到channel数量达到rabbitmq设置的上限,之后就无法继续将消息写入队列 SpringBoot版本: 2.3.5.RELEASE 问题代码 RabbitMQ配置类 @Configuration public class RabbitConfig { String user = "guest"; St

中间件

拥抱新技术?你需要考虑的方面(拥抱新技术?你需要考虑的方面英语)

南通东东办公设备 南通东东办公设备 发表于2024-05-02 浏览20386 评论0
前言 大家好,本文是博主在负责对企业项目新技术引入时,考虑不周的点,文中以第一视角对整个过程进行复盘以及事后分析。以 Mycat 为例。希望对大家有所帮助~ 一、背景 在一次会议内容提到一个新的技术,是我没有涉及到的领域—分库分表技术预研,当时会议提到该领域其中一个技术点 Mycat 技术点,该技术是我没有涉及到,而在此次会议被安排负责该项技术的预研。 二、需求 接下来,我就花时间去了解 Mycat这个东西,网上各种找资料,说实话,资料还是非常的多的,当时的想法

分布式

zookeeper应用实战之分布式锁(zookeeper的分布式锁)

战帅 战帅 发表于2024-05-02 浏览10934 评论0
1. 什么是分布式锁? 我们先来看这样一个场景,如下图所示,两个用户同时去抢购秒杀商品,当秒杀服务同时收到秒杀请求时,都去进行库存扣减,此时在没有做任何处理的情况下,就会导致库存数量变成负数从而导致超卖现象。 这种情况下如果是单体项目,我们一般会选择加锁的方式来避免并发的问题。但是在分布式场景中,采用传统的锁并不能解决跨进程并发的问题,所以需要引入一个分布式锁,来解决多个节点之间的访问控制。 2. Zookeeper如何实现分布式锁 实现分布式的方式有很多种,本文主要讲述如何使用

spring boot

Spring Boot面试必问:启动流程

′T-oste ′T-oste 发表于2024-05-02 浏览15904 评论0
一 面试提问 1.1 Spring Boot启动流程 👨‍💻面试官:说说SpringBoot启动流程吧 🙋 我 : 首先从main找到run()方法,在执行run()方法之前new一个SpringApplication对象 进入run()方法,创建应用监听器SpringApplicationRunListeners开始监听 然后加载SpringBoot配置环境(ConfigurableEnvironment),然后把配置环境(Environment)加入监听对象中 然后加载应用上下

spring cloud

Alibaba-Sentinel简单入门

凡间教主 凡间教主 发表于2024-05-02 浏览5256 评论0
1、简介 项目地址:https://github.com/alibaba/Sentinel 随着微服务的流行,服务和服务之间的稳定性变得越来越重要。Sentinel 以流量为切入点,从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。 Sentinel 具有以下特征: 丰富的应用场景:Sentinel 承接了阿里巴巴近10 年的双十一大促流量的核心场 景,例如秒杀(即突发流量控制在系统容量可以承受的范围)、消息削峰填谷、集 群流量控制、实时熔断下游不可用应用等。 完备的实时

spring boot

SpringBoot 全局事务配置

HaoHao HaoHao 发表于2024-05-02 浏览6391 评论0
前言 传统springboot实现事务只需要在方法上添加@Transactional注解,但是需要在所有的service都加上事务,相对比较麻烦,随着项目的庞大,功能模块会随之增多,所以就需要采用AOP的方式实现全局事务处理。全局事务配置通过AOP切面指定方法前缀切入点,从而对指定的方法统一进行事务控制,根据方法名前缀来匹配到具体方法,进行事务配置 一、什么是事务? 提到事务,你肯定不陌生,和数据库打交道的时候,我们总会用到事务 案例 你要给朋友小王转 100 块钱,而此时你的银