Kafka监控安装Kafka集群监控方案选择：Kafka只能依靠kafka-run-class.sh等命令进行管理KafkaManager（CMAK）是目前比较常用的监控工具，它有如下功能：管理多个集群轻松检查群集状态（主题，消费者，偏移，代理，副本分发，分区分发）运行首选副本选举使用选项生成分区分配以选择要使用的代理运行分区重新分配（基于生成的分配）使用可选主题配置创建主题（0.8.1.1具有与
分类：
其他好文 时间：
2020-07-10 09:39:18
阅读次数：
259
Disruptor是一款java高性能无锁并发处理框架。和JDK中的BlockingQueue有相似处，但是它的处理速度非常快！！！号称“一个线程一秒钟可以处理600W个订单”（反正渣渣电脑是没体会到）。 Disruptor功能十分强大，比如消费者阻塞等待；生产者-消费者一对一、一对多、多对一、多对 ...
分类：
其他好文 时间：
2020-07-09 19:42:22
阅读次数：
126
在利用jvisualvm.exe搞一个关于生产者消费者的一个纠结的问题，我们已经看到如何在生产者消费者模型中，由于队列的不安全导致消费者一直空转的情况，已经如何解决该问题。接下来我们继续跟踪该问题的其他几种并发情况，现在先把代码中的关键那一行休眠注释掉，还是用LinkedList作为队列跑一下，结果 ...
分类：
其他好文 时间：
2020-07-09 00:39:49
阅读次数：
86
先看代码： package com.wlf.service; import java.util.LinkedList; import java.util.Queue; import java.util.concurrent.LinkedBlockingQueue; /** * 生产者消费者模拟 * ...
分类：
其他好文 时间：
2020-07-08 22:41:29
阅读次数：
48
Kafka消费者Demo 依赖包： <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>1.0.0</version> </dependency> 源码： p ...
分类：
其他好文 时间：
2020-07-08 18:11:21
阅读次数：
45
eureka-主要由两部分组成。 eureka-server eureka-client 客户端包括消费者和生产者。消费者和生产者都是客户端。只需引入pom,启动类添加注解，配置文件配置其他信息。 生产者服务启动时会向注册中心，发送注册等相关信息。 注册中心将其信息保存在内存中。并且默认没30秒发送 ...
分类：
编程语言 时间：
2020-07-08 14:55:43
阅读次数：
67
这道题是字节的面试题，当场问我有点紧张没想出来，只答上来要交替阻塞，还是面试官提醒我用生产者消费者思路解决。 题目 有A类线程50个，任务是打印字符A。有B类线程50个，任务是打印字符B。现在异步启动这100个线程，问如何才能让他们交替打印AB字符？ 解题思路 设两个信号SemaphoreA和Sem ...
分类：
编程语言 时间：
2020-07-08 10:31:30
阅读次数：
100
zookeeper可以作为dubbo的注册中心。一般都是以奇数个zookeeper集群的形式。 几个主要知识点。 session。zookeeper是个服务器，zk客户端(服务消费者和提供者)要和zk服务端(也就是注册中心)连接就要建立一次TCP长连接，连接建立后session就建立了，sessio ...
分类：
其他好文 时间：
2020-07-07 23:27:52
阅读次数：
79
Java深入学习29：线程等待和唤醒的两个方案 模拟场景 一个门店，有一个店员，有消费者来消费商品(每次消费1件商品)，有仓库人员来添加(生产)商品(每次生产1件商品)，并假设库存上限是2. 基础代码实现 public class ThreadNotifyTest { public static v ...
分类：
编程语言 时间：
2020-07-07 17:39:59
阅读次数：
57
消息队列 基本概述 MQ,Message Queue,基于TCP协议构建的简单协议，区别于具体的通信协议。 基于通信协议定义和抽象的更高层次的通信模型,一般都是生产者和消费者模型，又或者说服务端和客户端模型。 生产者/消费者模型：一般通过定义生产者和消费者实现消息通信从而屏蔽复杂的底层通信协议。应用 ...
分类：
系统相关 时间：
2020-07-07 09:29:51
阅读次数：
94
