Java汇总 第259页

　　我们可以把loghub当作一个消息中间件来使用。如果能知道当前的消费进度，自然好了，否则消费情况一无所知，总是有点慌！ 　　loghub消费分两种情况，一是普通消费，二是消费组消费； 　　消费组消费，loghub服务端会记录消费情况，这...

赞(0)站长2020-08-01阅读(654)

　　消息中间件是为解耦生产者和消费者的目的，三大服务点：解耦、异步、削峰。　　 　　现在的的互联网系统中，mq已经必备基础设施了，我们已明显感觉它的必要性与强大。然而，它的本质是啥？存储转发系统罢了！ 　　MQ有很多成熟产品，以Rocket...

赞(0)站长2020-08-01阅读(716)

　　为充分利用机器性能，人们发明了多线程。但同时带来了线程安全问题，于是人们又发明了同步锁。 　　这个问题自然人人知道，但你真的了解同步锁吗？还是说你会用其中的上锁与解锁功能？ 　　今天我们就一起来深入看同步锁的原理和实现吧！ 一、同步锁的...

赞(0)站长2020-08-01阅读(619)

　　因为ZK有watch机制，可以随时发现一些数据的变化，从而达到数据的及时性。 　　ZK的所有读操作都可以设置watch监视点: getData, getChildren, exists. 写操作则是不能设置监视点的。 　　监视有两种类型...

赞(0)站长2020-08-01阅读(652)

　　使用 grafana+prometheus+jmx 作为普通的监控手段，是比较有用的。我之前的文章介绍了相应的实现办法。https://tech.souyunku.com/yougewe/p/11140129.html 　　但是，按照之...

赞(0)站长2020-08-01阅读(690)

　　通过前些文章，我们已经完全从整体架构和数据接入方面理解了ZK的前情工作。接下来，我们就来看ZK的正式工作吧。 　　本文以 setData /a data 这个命令作为出发点，来观察zk是如何处理来自客户端的数据更新操作的吧！ 　　首先，...

赞(0)站长2020-08-01阅读(667)

　　通过前面几篇文章，我们可以从整体上看到zk是如何处理网络数据的宏观架构。 　　本文我们从细节着手，看一下一个tcp的包是如何转换到内部的数据流处理的。 一、监听用户请求socket 　　基于NIO的端口监听，获取tcp数据流。 // o...

赞(0)站长2020-08-01阅读(701)

　　我们知道，zk就是一个个处理链组成的。 　　但是，这些处理链是在什么创建的呢？ 　　ZooKeeper 中有三种角色的服务节点存在: Leader, Follower, Observer . 　　而每个服务节点的承担的任务是不一样的，所...

赞(0)站长2020-08-01阅读(710)

　　ZooKeeper 作为优秀的分布系统协调组件，值得一探究竟。它的启动类主要为： 　　　　1. 单机版的zk 使用 ZooKeeperServerMain 　　　　2. 集群版的zk 使用 QuorumPeerMain 　　与用户端各服...

赞(0)站长2020-08-01阅读(700)

　　我们有些场景，是需要使用 多线各一起执行某些操作的，比如进行并发测试，比如进行多线程数据汇总。 　　自然，我们可以使用 CountDownLatch, CyclicBarrier, 以及多个 Thread.join()。 虽然最终的效果...

赞(0)站长2020-08-01阅读(731)