1 架构 1.1 概述 Alluxio作为大数据和机器学习生态系统中的一个新的数据访问层,配置在任何持久性存储系统(如Amazon S3、Microsoft Azure...
1 架构 1.1 概述 Alluxio作为大数据和机器学习生态系统中的一个新的数据访问层,配置在任何持久性存储系统(如Amazon S3、Microsoft Azure...
问题:当 raft group 发生脑裂的情况下,老的 raft leader 可能在一段时间内并不知道新的 leader 已经被选举出来,这时候客户端在老的 leader ...
学习大牛的成长经验,再跟自己的过去、当下做对比,看下哪些地方可以做改进,调整自己当前的状态。大牛们的成长之路虽说各有不同,但是有很多共同的地方,如果能做到这些,相信运气都不会...
RocketMQ提供了基于Tag的消息过滤机制,不少使用者都有问到如下问题: 消费组订阅关系不一致为什么会到来消息丢失?如果一个tag的消息数量很少,是否会显示很高的延迟? ...
如果你曾经使用过RocketMQ,那么一定对以下发送消息的代码不陌生 Producer启动 其实仅仅一行代码,在produer端的后台启动了多个线程来协同工作,接下来我们逐一...
前文我们梳理了消息在Commit Log文件的存储过程,讨论了消息的落盘策略,然而仅仅通过Commit Log存储消息是远远不够的,例如当我们需要消费某个topic的消息时,...
写入流程 简单可以分为三大块: 写入前准备加锁后消息写入消息落盘及集群同步 其实消息的写入准备工作也比较好理解,主要是消息状态的检查以及各类存储状态的检查,可以参看上图中的流...
Java堆栈内存与堆外内存 堆栈内存堆栈内存指的是堆内存和栈内存:堆内存是GC管理的内存,栈内存是线程内存。 堆内存结构: 还有一个更细致的结构图(包括MetaSpace还有...
今天分享的参数是 -XX:ParGCCardsPerStrideChunk 一个神奇的参数,看描述似乎还是比较迷糊,还是展开来说下。 发生young gc时,有一个特殊的GC...
目标: 了解protobuf是如何做协议兼容的。 问题: 在protobuf中,是怎么做到新旧协议传输的兼容的,比如:(问题一)在新的协议里面增加了一个字段,传输到另一方是如...
系列 rocketMq概念介绍 rocketMq-namesrv介绍 rocketMq-Topic创建过程 rocketMq-producer介绍 rocketMq-cons...
https://draveness.me/whys-the-design-tcp-time-wait/[https://draveness.me/whys-the-desig...
回顾-上期的遗留问题 疑惑1:按道理全连接队列满了,但是客户端的连接请求是已经接收到SYN+ACK了,所以对于客户端来说该连接已经建立了,为啥会报connect timeou...
问题描述 公司的支付系统,支付核心调用网关系统时候,Tomcat接口服务偶尔会出现连接超时,以下为问题现象: 出现连接超时的时间点,该机器仍有正常的请求到网关系统,只是部分请...
backlog参数的含义 TCP建立连接是要进行三次握手,但是否完成三次握手后,服务器就处理(accept)呢? backlog其实是一个连接队列,在Linux内核2.2之前...
SO_RCVTIMEO, SO_SNDTIMEO介绍 套接字选项SO_RCVTIMEO: 用来设置socket接收数据的超时时间;套接字选项SO_SNDTIMEO: 用来设置...
在看到 go 字符串的时候, 偶然看到 []rune(s), 它可以将字符串转化成 unicode 码点。那么它和 []byte(s) 有什么区别呢?来测试一下 [102 1...
[TOC] 前言 K8s是一个强大的平台,但它的网络比较复杂,涉及很多概念,例如Pod网络,Service网络,Cluster IPs,NodePort,LoadBalanc...