问题导读： 1.zookeeper在kafka的作用是什么？ 2.kafka中几乎不允许对消息进行“随机读写”的原因是什么？ 3.kafka集群consumer和producer状态信息是如何保存的？ 4.partitions设计的目的的根本原因是什么？ 一、入门 1、简介 Kafka is a d ...
分类：
其他好文 时间：
2019-05-08 15:56:20
阅读次数：
114
一 、进程间通信（IPC机制） 队列：先进先出 堆栈：先进后出 利用队列实现进程间通信 from multiprocessing import Queue q = Queue(5) # 产生一个最多能够存放五个数据的队列 # q.put(1) # 往队列中存放数据,如果存放的数据个数大于队列最大存储 ...
分类：
编程语言 时间：
2019-05-07 19:37:46
阅读次数：
158
https://www.cnblogs.com/raoshaoquan/articles/6636067.html 1 写在前面 1.1 名词解释 consumer表示服务调用方 provider标示服务提供方，dubbo里面一般就这么讲。 下面的A调用B服务，一般是泛指调用B服务里面的一个接口。 ...
分类：
其他好文 时间：
2019-05-05 23:32:24
阅读次数：
184
首先Kafka是一个分布式消息队列中间件，Apache顶级项目，https://kafka.apache.org/ 高性能、持久化、多副本备份、横向扩展。 生产者Producer往队列里发送消息，消费者Consumer从队列里消费消息，然后进行业务逻辑。应用场景主要有：解耦、削峰（缓冲）、异步处理、 ...
分类：
其他好文 时间：
2019-05-04 16:16:53
阅读次数：
217
通过 Dubbo，使 A（消费者：Consumer） 项目代码调用 B（提供者：Provider） 项目的代码 注册中心使用 zookeeper 一、接口（Interface） 项目之间通过接口进行调用，抽出为一个单独的项目，方便复用 pom.xml 接口 项目结构 二、ROOT 由于消费者和提供者 ...
分类：
其他好文 时间：
2019-05-03 16:22:26
阅读次数：
140
使用信号量完成线程间同步，模拟生产者，消费者问题。 【sem_product_consumer.c】 思路分析： 规定： 如果□中有数据，生产者不能生产，只能阻塞。 如果□中没有数据，消费者不能消费，只能等待数据。 定义两个信号量：S满 = 0， S空 = 1 （S满代表满格的信号量，S空表示空格的 ...
分类：
其他好文 时间：
2019-05-02 21:49:05
阅读次数：
145
1、查看topic信息 kafka-topics --zookeeper 10.79.2.92:2181/chroot --describe --topic ogg_fab_u 2、创建topic kafka-topics --create --topic dwr_pnl --zookeeper 1 ...
分类：
其他好文 时间：
2019-04-28 15:26:51
阅读次数：
84
Kafka consumer中poll(0)与poll(Duration.ofMills(0))的区别 ...
分类：
其他好文 时间：
2019-04-26 13:05:50
阅读次数：
872
本例子主要使用了eureka集群作为注册中心来保证高可用，客户端来做ribbon服务提供者的负载均衡。 负载均衡有两种，第一种是nginx，F5这种集中式的LB，对所有的访问按照某种策略分发。 第二种是客户端知道所有的服务的地址，在客户端做负载均衡，客户端自己去发送。 ...
分类：
编程语言 时间：
2019-04-26 12:50:23
阅读次数：
142
16.The Effect of Advertisement 广告的影响 (1) The appeal of advertising to buying motives can have both negative and positive effects.Consumers may be conv ...
分类：
其他好文 时间：
2019-04-26 00:43:00
阅读次数：
392
