关于在线社工库关闭的问题 TOOBUG博客自2016年开始与之前守夜人平台进行合作,充分利用守夜人平台的预警中心,为双方会员提供信息安全预警、账号行为分析、个人信息检索、人际关系分析、用户网络指纹记录、精准IP定位等...
作者 toobug 发布的文章
使用场景 当我们在电商平台购买一件物品,但是没有付款时,平台会把对应的库存减少,并在会在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来消费的...
热文RocketMQ源码解析:消息发送流程
RocketMQ发送消息的三种方式 在RocketMQ中发送消息的方式有如下三种,同步发送,异步发送和单向发送。其中前2中发送方式是可靠的,因为会有发送是否成功的应答,而单向发送只管发不管发送是否成功 同步发送消息,...












