RocketMQ（二）：producer客户端实践
MQ解耦了生产者和消费者，前提是有一个稳定强大的消息服务，我们只管与之通信即可。 所以，和MqServer通信是什么样的？难否？ 0. 发送端demo /** * This class demonstrates how to sen...
站长基于loghub的消息消费延迟监控
我们可以把loghub当作一个消息中间件来使用。如果能知道当前的消费进度，自然好了，否则消费情况一无所知，总是有点慌！ loghub消费分两种情况，一是普通消费，二是消费组消费； 消费组消费，loghub服务端会记录消费情况，这...
JetBrains 全家桶，激活、破解、教程
获取 IDEA 激活码、PyCharm 激活码、WebStorm 激活码和 DataGrip 激活码，提供详细破解教程与永久激活方法。支持 IDEA 永久激活与破解，免费获取注册码与激活码，解决 2024/2025 版本激活问题，轻松实现所有 JetBrains 工具的激活。
RocketMQ（一）：推拉消费模型客户端实践
消息中间件是为解耦生产者和消费者的目的，三大服务点：解耦、异步、削峰。 现在的的互联网系统中，mq已经必备基础设施了，我们已明显感觉它的必要性与强大。然而，它的本质是啥？存储转发系统罢了！ MQ有很多成熟产品，以Rocket...
同步锁基本原理与实现
为充分利用机器性能，人们发明了多线程。但同时带来了线程安全问题，于是人们又发明了同步锁。 这个问题自然人人知道，但你真的了解同步锁吗？还是说你会用其中的上锁与解锁功能？ 今天我们就一起来深入看同步锁的原理和实现吧！ 一、同步锁的...
ZooKeeper（六）：watch机制的原理与实现
因为ZK有watch机制，可以随时发现一些数据的变化，从而达到数据的及时性。 ZK的所有读操作都可以设置watch监视点: getData, getChildren, exists. 写操作则是不能设置监视点的。 监视有两种类型...
Prometheus监控有所思：多标签埋点及Mbean
使用 grafana+prometheus+jmx 作为普通的监控手段，是比较有用的。我之前的文章介绍了相应的实现办法。https://tech.souyunku.com/yougewe/p/11140129.html 但是，按照之...
ZooKeeper（五）：事务处理之更新数据逻辑解析
通过前些文章，我们已经完全从整体架构和数据接入方面理解了ZK的前情工作。接下来，我们就来看ZK的正式工作吧。 本文以 setData /a data 这个命令作为出发点，来观察zk是如何处理来自客户端的数据更新操作的吧！ 首先，...
ZooKeeper（四）：从TCP数据流到zk内部处理包的转换
通过前面几篇文章，我们可以从整体上看到zk是如何处理网络数据的宏观架构。 本文我们从细节着手，看一下一个tcp的包是如何转换到内部的数据流处理的。 一、监听用户请求socket 基于NIO的端口监听，获取tcp数据流。 // o...
ZooKeeper（三）：请求处理链路的创建过程解析
我们知道，zk就是一个个处理链组成的。 但是，这些处理链是在什么创建的呢？ ZooKeeper 中有三种角色的服务节点存在: Leader, Follower, Observer . 而每个服务节点的承担的任务是不一样的，所...
ZooKeeper（二）：多个端口监听的建立逻辑解析
ZooKeeper 作为优秀的分布系统协调组件，值得一探究竟。它的启动类主要为： 1. 单机版的zk 使用 ZooKeeperServerMain 2. 集群版的zk 使用 QuorumPeerMain 与用户端各服...