1. 概念 1.1 AMQP协议 AMQP，即Advanced Message Queuing Protocol，一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语 ...
分类：
其他好文 时间：
2020-04-14 16:52:39
阅读次数：
69
python中使用redis发布订阅者模型 redis发布订阅者模型： Redis提供了发布订阅功能，可以用于消息的传输，Redis的发布订阅机制包括三个部分，发布者，订阅者和Channel。发布者和订阅者都是Redis客户端，Channel则为Redis服务器端，发布者将消息发送到某个的频道，订阅 ...
分类：
编程语言 时间：
2020-04-13 14:12:27
阅读次数：
85
1. 什么是reentrantlock? Reentrantlock 顾名思义重入锁，表示这个锁是可以重复进入的，你可能要问了，什么情况下才可以重复进入呢？ Good question, 重入的意思是：当一个线程持有某个锁的时候，在它没有释放锁之前去干的其他的事情，那么当他干完其他的事情之后，它不需 ...
分类：
其他好文 时间：
2020-04-12 16:07:01
阅读次数：
53
假定某消费组下有 3 个消费者，c0，c1，c2，订阅了 topic_zhang，该 topic 有 2 个 queue，分别是 q0，q1 现在我们有一个数组，按 consumer 名的哈希值大小排列：[c1，c0，c2] 先不考虑虚拟节点 q1 分配给 C0，q0 分配给 C2 当 C0 下线之 ...
分类：
其他好文 时间：
2020-04-11 13:02:57
阅读次数：
78
1.通过自建kafka的生产者来产生数据 /bin/kafka-console-producter.sh --broker-list 192.168.58.177:9092 --topic my_topic 数据 {"user_id": "543462", "item_id":"1715", "ca ...
分类：
数据库 时间：
2020-04-09 19:09:25
阅读次数：
458
1.queue是点对点模式，一条消息对应一个消费者，topic是一对多模式，一条消息可能有一个或多个消费者 2.queue模式消息再发送后消费者可以在之后的任意时间消费，topic模式如果没有订阅者消息就是废消息，会被丢弃。 3.queue模式生产者与消费者之间没有时间相关性，topic模式下生产者 ...
分类：
其他好文 时间：
2020-04-08 22:28:23
阅读次数：
69
ORACLE的DDL日志 推送到Kafka，并接入Flink，进行统计 本次测试的环境： 环境：docker oracle12c 日志模式：归档日志模式 archivelog 用户：scott/tiger 具有dba权限 大数据组件：kafka(默认创建好topic：flink_topic)，zoo ...
分类：
数据库 时间：
2020-04-08 16:07:45
阅读次数：
508
1:topic下面的queue 奇偶数会影响消费端的消费数量, 假设 4个队列,8个消息,每个节点各自消费两条,如果不对等的话,就没办法做一个负载均衡 队列的数量要大于consumer数量,不然多出来的consumer无法分配到queue,消息没办法消费,需要控制队列大于消费端 2:集群模式和广播模 ...
分类：
其他好文 时间：
2020-04-06 16:01:42
阅读次数：
135
https://zhuanlan.zhihu.com/p/103594741?utm_source=wechat_session 我建议选择考试名称为ESL（English as second language） https://certcollection.org/forums/topic/811 ...
分类：
其他好文 时间：
2020-04-06 11:52:20
阅读次数：
87
TF中包含很多不同的组件，其中最重要的七种“武器”用法各不相同。
分类：
其他好文 时间：
2020-04-03 18:37:05
阅读次数：
108
