• Logtail技术分享(二):多租户隔离技术+双十一实战效果

    进入FindJob状态FindJob会从上一次处理的队列位置顺序查找当前有数据且下一级队列可以写入的队列&xff0c;若查找到则进行Process状态&xff0c;否则进行Wait状态Process对于当前job解析完后&xff0c;判断该job所属队列是否...
    文章 2017-11-16 11344浏览量
  • RMQ——支持合并和优先级的消息队列

    然后,生产者发送消息到消费队列服务,配置管理服务会定时通过心跳发送绑定的topic信息到消费者,消费者根据topic信息从消费队列服务中拉取消息进行消费。接下来将从消息队列服务、配置管理服务、生产者和消费者四个...
    文章 2020-12-21 464浏览量
  • 如何提高Linux下块设备IO的整体性能?

    为了实现这个功能,cfq在service_tree这层数据结构这实现了SYNC队列,如果请求是同步顺序请求,就入队这个service tree,如果请求是同步随机请求,则入队SYNC_NOIDLE队列,以判断下一个请求是否是顺序请求。...
    文章 2017-08-15 1391浏览量
  • RabbitMQ 高可用之镜像队列

    如何确定一个队列是不是排他性队列呢?如果队列的features包含Excl,就代表它是排他性队列。镜像队列中某个节点宕掉的后果: 当slave宕掉了,除了与slave相连的客户端连接全部断开之外,没有其他影响。当master宕掉...
    文章 2018-12-28 2291浏览量
  • 2021最新Java中间件面试真题(附答案解析)

    15.数据同步16.zookeeper 是如何保证事务的顺序一致性的?17.分布式集群中为什么会有 Master?在分布式环境中,有些业务逻辑只需要集群中的某一台机器进行执行,其他的机器可以共享这个结果,这样可以大大减少重复...
    文章 2021-11-02 56浏览量
  • Linux的IO调度

    为了实现这个功能,cfq在service_tree这层数据结构这实现了SYNC队列,如果请求是同步顺序请求,就入队这个service tree,如果请求是同步随机请求,则入队SYNC_NOIDLE队列,以判断下一个请求是否是顺序请求。...
    文章 2017-11-10 1090浏览量
  • 如何成长为一位优秀的技术人?优秀的程序员成长的技术...

    如何启动Tomcat的SpringBoot中的配置文件类型,配置文件的语法,配置文件的加载顺序?模拟SpringBoot中的自动配置SpringBoot的日志系统?SpringBoot如何设计自身的日志系统的?有什么优势?如何做到统一日志的Docker什么是...
    文章 2021-11-27 8浏览量
  • 搞懂分布式系统27:消息队列设计精要总结之高级特性篇

    一个消息队列如何尽量减少重复消息的投递。3 唯一消息id的实现:先来看看第一个话题,每一个消息应该有它的唯一身份。不管是业务方自定义的,还是根据IP/PID/时间戳生成的MessageId,如果有地方记录这个MessageId,...
    文章 2018-07-13 1258浏览量
  • IoT设备消息洪峰怎么扛?阿里云AIoT消息队列深度解读

    比如按消息特征规则来配置流转队列。阿里云AIoT的场景队列实践&xff0c;在现有mq队列、kafka队列融合之外&xff0c;加了种自有的实时优先队列实现&xff0c;同时&xff0c;加入了队列网关代理&xff0c;既能让用户选择普通消息队列...
    文章 2021-07-23 731浏览量
  • IoT设备消息洪峰怎么扛?阿里云AIoT消息队列深度解读

    比如按消息特征规则来配置流转队列。阿里云AIoT的场景队列实践&xff0c;在现有mq队列、kafka队列融合之外&xff0c;加了种自有的实时优先队列实现&xff0c;同时&xff0c;加入了队列网关代理&xff0c;既能让用户选择普通消息队列...
    文章 2021-11-22 22浏览量
  • 消息队列——延时消息应用解析及实践

    延时(定时)消息在某段时间内是对消费者不可见的,从另一个维度也属于积压的消息,阿里云消息队列RocketMQ版的不同实例规格可以支持亿级的消息积压。提供了多语言支持,包括Java、.NET、CC+、GO、Python、PHP、Node...
    文章 2020-12-16 3845浏览量
  • 基于 TensorFlow、OpenCV 和 Docker 的实时视频目标...

    简单队列的另外一个问题是,由于分析时间的不断变化,视频帧在输出队列中不是按照与输入队列相同的顺序。为了增加视频处理功能,我删掉了读取帧率的线程。作为一个替代,我使用下面的代码来读取帧率。while True: ...
    文章 2018-07-24 3939浏览量
  • HBase源码分析之HRegionServer上MemStore的flush处理...

    通过如何初始化cacheFlusher部分的介绍,我们已经知道,在MemStoreFlusher内部,存在两个存储flush请求及其HRegion封装类的队列和集合,即flushQueue和regionsInQueue,而MemStoreFlusher对外提供了一个requestFlush...
    文章 2016-02-29 1136浏览量
  • 【Azure Services Platform Step by ...日志与队列的使用

    顾名思义,Queue就是队列,按照先进先出的顺序来处理数据。在上图的“Azure兰州拉面馆”中,Queue就充当了记录点菜情况的小本子,前台服务员将顾客点的菜记录在Queue中,后台厨房的厨师则按照Queue中的顺序,一个...
    文章 2017-11-26 894浏览量
  • 打造更适合IoT场景的消息队列实践

    兼容传统队列和新队列,交给用户按场景来推荐选择,用户即可选择使用kafka、mq(ONS、MNS)也可以选用iot队列(物联网平台的服务端订阅),甚至组合模式,比如按消息特征规则来配置流转队列。IoT队列的设计思路 设计...
    文章 2020-01-18 2374浏览量
  • 阿里最全面试116题:阿里天猫、蚂蚁金服、阿里巴巴...

    8.一万个人抢100个红包,如何实现(不用队列),如何保证2个人不能抢到同一个红包,可用分布式锁 9.java内存模型,垃圾回收机制,不可达算法 10.两个Integer的引用对象传给一个swap方法在方法内部交换引用,返回后,...
    文章 2018-11-03 1851浏览量
  • [译]Swift 中关于并发的一切:第一部分—当前

    NSTimer 类也不会在这里介绍,你可以这里,来了解如何在 Swift 3 中使用它。就像已多次公布的,Swift 4.0 之后的主要版本之一(不一定是 Swift 5)会扩展语言的功能,更好地定义内存模型,并包含了新的原生...
    文章 2017-10-16 942浏览量
  • 阿里最全面试116题:阿里天猫、蚂蚁金服、阿里巴巴...

    8.一万个人抢100个红包,如何实现(不用队列),如何保证2个人不能抢到同一个红包,可用分布式锁 9.java内存模型,垃圾回收机制,不可达算法 10.两个Integer的引用对象传给一个swap方法在方法内部交换引用,返回后,...
    文章 2018-09-10 2473浏览量
  • 阿里最全面试116题:阿里天猫、蚂蚁金服、阿里巴巴...

    8.一万个人抢100个红包,如何实现(不用队列),如何保证2个人不能抢到同一个红包,可用分布式锁 9.java内存模型,垃圾回收机制,不可达算法 10.两个Integer的引用对象传给一个swap方法在方法内部交换引用,返回后,...
    文章 2018-10-09 2531浏览量
  • 我是如何处理大并发量订单处理的 KafKa部署总结

    网上已经有很多怎么用和用到哪的内容,但结果很多人都倒在了入门第一步 环境都搭不起来,可谓是从了解到放弃,所以在此特记录如何在linux环境搭建,windows中配置一样,只是启动运行bat文件。想要用它就先必须了解它...
    文章 2017-04-05 1333浏览量
  • 京东消息中间件演进之路:三次更迭,八大突破

    对于原生的客户端只能在单个Broker上收发消息,那也就不存在消息路由的问题,我们来下集群化之后消息是如何路由的,这里的路由涉及到两个方面,一方面是producer在发消息是如何选择将消息发往哪个Broker,另一方面...
    文章 2017-05-15 2423浏览量
  • 《ASD》设计模式:Command和Active Object

    1.队列的拥有者会顺序地执行队列中所有Command对象的Execute方法。(这个其实不算特殊) 2.Command对象在自己的Execute方法结束前,可以把一个新的command对象(实际上常常是这个command对象自己)再加到队列的尾部...
    文章 2017-10-09 1803浏览量
  • 18道kafka高频面试题哪些你还不会?...

    14、如何控制消费的位置15、kafka 分布式(不是单机)的情况下,如何保证消息的顺序消费?16、kafka 的高可用机制是什么?17、kafka 如何减少数据丢失18、kafka 如何不消费重复数据?比如扣款,我们不能重复的扣。1、...
    文章 2019-12-22 5342浏览量
  • 我是如何处理大并发量订单处理的 KafKa部署总结

    网上已经有很多怎么用和用到哪的内容,但结果很多人都倒在了入门第一步 环境都搭不起来,可谓是从了解到放弃,所以在此特记录如何在linux环境搭建,windows中配置一样,只是启动运行bat文件。想要用它就先必须了解它...
    文章 2017-11-22 2075浏览量
  • MySQL非主从环境下数据一致性校验及修复程序

    但为了尽可能减少此类问题(比如主从延迟也可能会),特意设计了多个redis队列,目标库多个检查线程,即比如同时指定检查8个表,源库检查会有8个线程对应,但可以根据表的写入情况,配置4个redis队列(目前是随机...
    文章 2016-11-21 3879浏览量
  • 几种java线程池的实现算法分析

    基于不同的队列实现,可以扩展出多种功能的线程池,如定制队列出队顺序实现带处理优先级的线程池、定制队列为阻塞有界队列实现可阻塞能力的线程池等。流控一方面通过控制worker数控制并发数和处理能力,一方面可基于...
    文章 2016-06-07 2126浏览量
  • 其他问题排查|《Rocket MQ 使用排查指南》第四章

    长轮询就是说针对每一个队列(queue),消费端会每15秒拉取一次消息,看看topic当中是否有可见的需要消费的消息。每一次拉取都算是一次调用api,都会收取费用。所以一个topic下面如有有3个broker,每个broker有8个...
    文章 2020-08-14 3577浏览量
  • [MySQL 5.6]MySQL 5.6 group commit 性能测试及内部...

    老规矩,先测试看看性能 sysbench,全内存操作,5个sbtest表,每个表1000000行数据 基本配置: innodb_flush_log_at_trx_commit=1 table_open_cache_instances=5 metadata_locks_hash_instances=32 metadata_locks_...
    文章 2016-05-10 1487浏览量
  • Flink on YARN(下):常见问题与排查思路

    很多应用运行 CLASSPATH 中存在相同依赖库的多个版本 JAR 包,导致实际使用的版本跟加载顺序有关,排查问题时经常需要确定某个类的来源 JAR,Flink 支持给 JM/TM 进程配置 JVM 参数,因此可以通过下面三个配置项来...
    文章 2019-09-29 11084浏览量
  • Kafka设计原理以及在达观产品中的应用

    实际吞吐表现又如何?带着这些问题,我们一起来了解一下。一,Kafka简介 首先根据官网介绍,知道kafka是一个分布式流处理平台,一个可处理企业级发布/订阅的消息系统,并且具有高容错性和消费及时性等特点,那么它是...
    文章 2017-08-01 1405浏览量
1 2 3 4 ... 24 >

云产品推荐

视频直播 大数据计算服务 MaxCompute 国内短信套餐包 ECS云服务器安全配置相关的云产品 开发者问答 阿里云建站 新零售智能客服 万网 小程序开发制作 视频内容分析 视频集锦 代理记账服务 阿里云AIoT 阿里云科技驱动中小企业数字化