置顶联合漏洞预警服务(2022-07-19 暂停开放)关于在线社工库关闭的问题 TOOBUG博客自2016年开始与之前守夜人平台进行合作,充分利用守夜人平台的预警中心,为双方会员提供信息安全预警、账号行为分析、个人信息检索、人际关系分析、用户网络指纹记录、精准IP定位等...
热文RocketMQ源码解析:长轮询是如何实现的?消费者消费很快 在文章一开始,先抛出一个问题,如果消费端的消费进度赶上生产端的消费进度,那么RocketMQ是怎么处理的? 前面的文章我们聊过RocketMQ是基于拉模式来实现消息消费的,消费端会不断的创建拉取任务(...
热文RocketMQ源码解析:延时消息是如何实现的?使用场景 当我们在电商平台购买一件物品,但是没有付款时,平台会把对应的库存减少,并在会在30分钟后关闭这个订单。如果30分钟内你没有付款,平台会自动关闭这个订单,此时对应的库存被释放出来。 我们怎么在订单创建30分钟...
热文RocketMQ源码解析:事务消息是如何实现的?用RocketMQ事务消息实现分布式事务 在分布式系统中为了保证数据的一致性,通常要使用分布式事务。分布式事务的解决方案有很多,比如TCC,SAGA,今天我们就来看一下如何用RocketMQ事务消息实现分布式事务? ...
热文RocketMQ源码解析:消息消费失败后的重试逻辑消息消费失败重新投递的流程 我们接着消息消费的逻辑分析,当消费完成后会调用ConsumeMessageConcurrentlyService#processConsumeResult的方法处理消费的结果,如果消费失败...
热文RocketMQ源码解析:消息过滤是如何实现的?三种消息过滤方式 RocketMQ的过滤方式主要分为如下2种,其中类模式过滤的方式会在RocketMQ 5.0.0版本中被移除,所以不进行详细分析 根据Tag过滤 public class TagFilterProd...
热文RocketMQ源码解析:消息拉取和消费流程消息消费总览 RocketMQ消息消费有两种模式,顺序消费和并发消费 顺序消费在工作中几乎没遇到过,所以就不分析这方面的源码了,单纯分析并发消费。并发消费实现MessageListenerConcurrently接口...
热文RocketMQ源码解析:如何快速查找消息?消息查询介绍 当我们使用MQ的时候,一个比较好的习惯就是把发送的消息和接收到的消息打印到日志中。当我们排查问题的时候就非常方便。 例如B服务需要消费A服务发送的关闭订单的消息。如果一个订单迟迟未关闭,此时可能有三种情...
热文RocketMQ源码解析:主从同步和读写分离实现启动HAService 图片来自RocketMQ的官微,对整个主从同步实现的过程概括的比较清晰,对着图说一下具体的流程 master和slave端都会启动HAService,slave端的HAClient会和brok...
热文RocketMQ源码解析:高性能存储策略Page Cache 我们经常听到别人说RocketMQ读写都很快?当别人问你RocketMQ为什么这么快时,你能回答上来多少?我们今天就来聊聊这个问题 在回答这个问题之前我们先回顾一下计算机内存管理方面的知识 物理...
热文RocketMQ源码解析:RocketMQ是如何存储消息的?Broker端使用到的文件 我们先来看一下RocketMQ的消息存储流程,当消息发送到RocketMQ上时,会被顺序写入CommitLog文件,这样能保证消息存储的高性能和高吞吐量。 但是消息是按照Topic来消费的...
专业TRON能量租赁平台-2TRX=1次转账次数直接节省80%!无视对方有没有U或者是否交易所,低于2T