上一篇展示了kafka虚拟机环境单机版部署,这一节主要讲kafka集群环境部署，kafka基础概念介绍与强化1）Producer：消息生产者，就是向kafkabroker发消息的客户端；2）Consumer：消息消费者，向kafkabroker取消息的客户端；3）Topic：可以理解为一个队列；4）ConsumerGroup（CG）：这是kafka用来实现一个topic消息的广播（发给所有的con
分类：
其他好文 时间：
2019-11-27 13:48:09
阅读次数：
77
kafka 由于它自身的高性能发送与消费能力，而受到广大企业的喜欢，所以我们就先看看kafka 一些源码实现如下： 这段代码摘抄的是，kafka源码 生产者发送消息demo（kafka.examples.Producer） 里面的一个片段，主要是涉及到两个知识点，一个是异步发送消息， 回调函数的实现 ...
分类：
其他好文 时间：
2019-11-22 23:24:35
阅读次数：
79
kafka 如何保证数据不丢失 https://www.cnblogs.com/MrRightZhao/p/11498952.html 一般我们在用到这种消息中件的时候，肯定会考虑要怎样才能保证数据不丢失，在面试中也会问到相关的问题。但凡遇到这种问题，是指3个方面的数据不丢失，即：producer ...
分类：
其他好文 时间：
2019-11-21 10:26:24
阅读次数：
59
Kafka概述 是基于点对点模式和发布订阅模式的分布式消息队列系统 为什么要用kafka,为什么要用消息队列 1）解耦： 2）冗余： 3）扩展性： 4）灵活性 & 峰值处理能力： 5）可恢复性： 6）顺序保证： 7）缓冲： 8）异步通信： kafka构架 1）Producer ：消息生产者，就是向k ...
分类：
其他好文 时间：
2019-11-17 20:51:01
阅读次数：
114
问题描述 在IT技术面试过程中，我们经常会遇到生产者消费者问题(Producer consumer problem)， 这是多线程并发协作问题的经典案例。场景中包含三个对象，生产者(Producer)，消费者(Consumer)以及一个固定大小的缓冲区(Buffer)。生产者的主要作用是不断生成数据 ...
分类：
编程语言 时间：
2019-11-12 17:22:22
阅读次数：
115
一：架构简介 Spring Cloud是微服务思想的体现。每个项目单独部署，我只需要知道你服务的name就能直接调用你，而不关心你的ip和端口的变化。当接口服务不可用的时候，我能感知到你无法用了，就不再使用你。 我们做这么一个场景： producer 有一个生产者服务producer1，对外提供用户 ...
分类：
编程语言 时间：
2019-11-09 11:53:24
阅读次数：
88
First: Kafka 是什么？ Kafka 是一个发布订阅系统 最初是是LinkedIn 开发 最后交给Apache 开源组织 github地址：https://github.com/apache/kafka 是用java 和Scala 去开发的~ Kafka 现在主要用于 消息队列使用 Kaf ...
分类：
其他好文 时间：
2019-11-06 16:41:21
阅读次数：
92
一、初识RabbitMQ 百度百科有这么一句话： 他的官网中用大大的黑粗字体写着： 由此可见，RabbitMQ是一个消息中间件，生产者生成消息，消费者消费消息，它遵循AMQP（高级消息队列协议），是最广泛部署的开源消息代理。 另外，RabbitMQ是用Erlang语言实现的，它有几个概念： ...
import timeimport randomfrom multiprocessing import Queue# 生产者def producer(q, num): for i in range(1, num + 1): food = 'Spam-%d' % i # time.sleep(rand ...
分类：
编程语言 时间：
2019-11-01 14:37:21
阅读次数：
107
sem mutex1=1; sem mutex2=1; sem empty=1000; sem full=0; producer() { while(1) { 生产一个产品 p(empty); p(mutex2); 放入缓冲区 v(mutex2); v(full); } } consumer() {... ...
分类：
其他好文 时间：
2019-10-20 20:08:19
阅读次数：
80
