作者 toobug 发布的文章

关于在线社工库关闭的问题 TOOBUG博客自2016年开始与之前守夜人平台进行合作,充分利用守夜人平台的预警中心,为双方会员提供信息安全预警、账号行为分析、个人信息检索、人际关系分析、用户网络指纹记录、精准IP定位等...

前言：【NIO】Buffer：基本原理及高级使用【NIO】Channel：基本概念及使用【NIO】Selector：从传统TRP模式到Reactor模式文件IO： BIO：读/写（人） –Stream（水流）...

热文【IO】Java 中的 BIO、NIO、AIO

在上一篇我们讲了 Linxu 下的五种 IO 模型，操作系统的 IO 模型是底层基石，Java对于IO的操作其实就是进一步的封装。适配一些系统调用方法，让我们玩地更得劲。 1.同步(Synchronization) ...

1.面向流与面向缓冲 Java NIO 和 BIO 之间第一个最大的区别是，BIO 是面向流的，NIO 是面向缓冲区的。 Java BIO 面向流意味着每次从流中读一个或多个字节，直至读取所有字节，它们没有被缓存在任...

缓冲区实际上是一个容器对象，更直接的说，其实就是一个数组，在 NIO 库中，所有数据都是用缓冲区处理的。读/写 ==> Buffer。即用户的直接操作都是面向缓冲区。在读取数据时，它是直接读到缓冲区中的；在写入数...

RocketMQ和其他消息中间件最大的一个区别是支持了事务消息，这也是分布式事务里面的基于消息的最终一致性方案。 1.事务消息是什么？事务消息：具有事务特性的消息，即Producer发送到broker后，该消息可以...

在实际使用RocketMQ的时候我们并不能保证每次发送的消息都刚好能被消费者一次性正常消费成功，可能会存在需要多次消费才能成功或者一直消费失败的情况，Broker该如何处理呢？ 1.消息消费端的确认机制 Rocke...

1.Broker集群模式（宏观） RocketMQ天生对集群的支持非常友好，天然支持高可用，它可以支持多主多从的部署架构，这也是和kafka大区别之一（PS：Kafka的分区副本可以看成一主多从）。那为什么要将这么...

1.消息发送模式 1.1 同步发送同步消息发送模式就是说消息发送出去后，producer会等到broker回应后才能继续发送下一个消息 DefaultMQProducer producer = new Defaul...

1.消息中间件的设计可以先从基本的需求开始思考基本的是要能支持消息的发送和接收，需要涉及到网络通信就一定会涉及到NIO 消息中心的消息存储（持久化/非持久化）消息的序列化和反序列化是否跨语言消息的确认机制，...

由于分布式消息队列对于可靠性的要求比较高，所以需要保证生产者将消息发送到broker之后，保证消息是不出现丢失的，因此消息队列就少不了对于可靠性存储的要求。从主流的几种MQ消息队列采用的存储方式来看，主要会有三种 ...