logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

sentinel限流介绍

sentinel是什么随着微服务的流行,服务和服务之间的稳定性变得越来越重要,sentinel以流量为切入点,从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性sentinel具有以下特性:丰富的应用场景:Sentinel 承接了阿里巴巴近 10 年的双十一大促流量的核心场景,例如秒杀(即突发流量控制在系统容量可以承受的范围)、消息削峰填谷、集群流量控制、实时熔断下游不可用应用等完备的实

文章图片
#sentinel
spring整合redisson配置

配置方式redis的部署方式有单节点部署、哨兵方式部署、集群方式部署3种方式各种配置方式可以去看xsd文件:redisson-1.1.xsd<xsd:element name="single-server"> // 单节点<xsd:element name="sentinel-servers"> // 哨兵<xsd:element name=...

ThreadPoolTaskExecutor

配置文件spring-thread.xml<?xml version="1.0" encoding="UTF-8"?><beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://www.springframework.org/schema/beans"xsi:schemaLocation="

Vue中如何定义全局的工具类

一:简单的写法每次使用都需要importtest.js如下:具体使用如下二:定义全局的工具类全局注册不需要import例子:现需定义ValidateUtil工具类utils/validate/index.js如下:utils/index.js如下:main.js如下:代码调用如下:...

kafka如何保证消息有序

两种方案:方案一,kafka topic 只设置一个partition分区方案二,producer将消息发送到指定partition分区解析:方案一:kafka默认保证同一个partition分区内的消息是有序的,则可以设置topic只使用一个分区,这样消息就是全局有序,缺点是只能被consumer group里的一个消费者消费,降低了性能,不适用高并发的情况方案二:既然kafka默认保证同一个p

kafka分区介绍

kafka可以将一个topic(主题)从物理上分为一个或多个区partition,每个分区在物理上对应一个文件夹,以”topicName_partitionIndex”的命名方式命名,该文件夹下存储这个分区的所有消息(.log)和索引文件(.index),这使得Kafka的吞吐率可以水平扩展生产者在生产数据的时候,可以为每条消息指定Key,这样消息被发送到broker时,会根据分区规则选择被存储到

kafka的分区和消费者组

消费者组消费者组是Kafka实现单播和广播两种消息模型的手段。同一个topic,每个消费者组都可以拿到相同的全部数据(不论topic有几个分区)。单个消费者组topic单分区partition,同一个消费者组中有两个消费者这说明:同一个分区内的消息只能被同一个组中的一个消费者消费,当消费者数量多于分区数量时,多于的消费者空闲(不能消费数据)topic三分区,同一个消费者组创建2个消费者这说明:当分

kafka广播和单播

使用Consumer high level API时,同一Topic的一条消息只能被同一个Consumer Group内的一个Consumer消费,但多个Consumer Group可同时消费这一消息。这是Kafka用来实现一个Topic消息的广播(发给所有的Consumer)和单播(发给某一个Consumer)的手段。一个Topic可以对应多个Consumer Group。如果需要...

Canal常见面试题

Canal还支持多种数据输出器,如Kafka、RocketMQ、ActiveMQ等,可以将解桥出来的数据发送到不同的消息队列中,以便进行进一步的处理和分析。Canal是阿里巴巴开源的一款基于Netty实现的分布式、高性能、可靠的消息队列,在实时数据同步和数据分发场景下有着广泛的应用。如果您使用的是基于数据库的Canal存储模式,Canal还会自动更新元数据信息。Canal主要用于实时数据同步和数据

#java
mongodb中日期范围查询

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");sdf.setTimeZone(TimeZone.getTimeZone("GMT+0:00")); //转为格林尼治基准时区Date beginDate = sdf.parse(startTime);Date endDate = sdf.parse(endTime

    共 13 条
  • 1
  • 2
  • 请选择