中间件编程之RocketMq消息中间件消息堆积处理

我们一个一个来梳理吧，先假设一个场景，我们现在消费端出故障了，然后大量消息在 mq 里积压，现在出事故了，慌了。大量消息在 mq 里积压了几个小时了还没解决几千万条数据在 MQ 里积压了七八个小时，从下午 4 点多，积压到了晚上 11 点多。这个是我们真实遇到过的一个场景，确实是线上故障了，这个时候
2020年12月11日 1,039次浏览

zookeeper中间件使用之独占锁与共享锁

ZooKeeper提供分布式协调服务，应用非常广泛，虽然出现了其他服务发现组件，比如etcd、consul，但是仍然可以看到ZooKeeper在Kafka、Solr、Hbase、Stom等方面的应用。分布式锁是其中一个使用特性，分布式锁包含排他锁和共享锁两类锁。1. 排他锁1.1 简介又称为写锁或者
2020年12月11日 639次浏览

中间件编程之zookeeperApi使用

zk在常用中间件中作为通讯工具，集群管理工具，掌握zk的java操作非常有必要。Java操作zookeeper总共有三种方式：原生的Java APIzkclientcurator第一种实现代码：pom.xml<dependency> <groupId>org.apach
2020年12月09日 691次浏览