RocketMQ提供了基于Tag的消息过滤机制,不少使用者都有问到如下问题: 消费组订阅关系不一致为什么会到来消息丢失?如果一个tag的消息数量...
如果你曾经使用过RocketMQ,那么一定对以下发送消息的代码不陌生 Producer启动 其实仅仅一行代码,在produer端的后台启动了多个...
前文我们梳理了消息在Commit Log文件的存储过程,讨论了消息的落盘策略,然而仅仅通过Commit Log存储消息是远远不够的,例如当我们需...
写入流程 简单可以分为三大块: 写入前准备加锁后消息写入消息落盘及集群同步 其实消息的写入准备工作也比较好理解,主要是消息状态的检查以及各类存储...
Java堆栈内存与堆外内存 堆栈内存堆栈内存指的是堆内存和栈内存:堆内存是GC管理的内存,栈内存是线程内存。 堆内存结构: 还有一个更细致的结构...
https://draveness.me/whys-the-design-tcp-time-wait/[https://draveness.me...
SO_RCVTIMEO, SO_SNDTIMEO介绍 套接字选项SO_RCVTIMEO: 用来设置socket接收数据的超时时间;套接字选项SO...
在看到 go 字符串的时候, 偶然看到 []rune(s), 它可以将字符串转化成 unicode 码点。那么它和 []byte(s) 有什么区...
[TOC] 前言 K8s是一个强大的平台,但它的网络比较复杂,涉及很多概念,例如Pod网络,Service网络,Cluster IPs,Node...