问题导读： 1.zookeeper在kafka的作用是什么？ 2.kafka中几乎不允许对消息进行“随机读写”的原因是什么？ 3.kafka集群consumer和producer状态信息是如何保存的？ 4.partitions设计的目的的根本原因是什么？ 一、入门 1、简介 Kafka is a d ...
分类：
其他好文 时间：
2019-06-12 19:52:22
阅读次数：
88
游戏开发过程中事件是非常多的，可以通过 Messenger 事件系统来解藕，用法如下： 代码如下： 1 // Messenger.cs v1.0 by Magnus Wolffelt, magnus.wolffelt@gmail.com 2 // 3 // Inspired by and based ...
分类：
编程语言 时间：
2019-06-11 15:01:46
阅读次数：
161
在使用kafka时，client是最先接触的部分，消息也是从producer产生，故先从producer开始介绍 在分析 Producer 发送模型之前，先通过一个栗子看一下用户是如何使用 Producer 向 Kafka 写数据的。 使用示例 下面是一个关于 Producer 最简单的应用示例。 ...
分类：
其他好文 时间：
2019-06-09 16:56:48
阅读次数：
94
[TOC] 第一章 计算机基础 1. 计算机概览 1.1 计算机硬件 计算机的主要组成部分时主板、CPU、硬盘、内存及一些外设设备组成。 1.2 常见的操作系统 ? 操作系统（OS），是最接近物理硬件的系统软件。主要用来协调、控制、分配计算机硬件资源，使计算机各组件可以发挥最优性能。 windows ...
分类：
编程语言 时间：
2019-06-06 22:50:46
阅读次数：
132
1、简介 Kafka is a distributed,partitioned,replicated commit logservice。它提供了类似于JMS的特性，但是在设计实现上完全不同，此外它并不是JMS规范的实现。kafka对消息保存时根据Topic进行归类，发送消息者成为Producer, ...
分类：
其他好文 时间：
2019-06-06 19:30:48
阅读次数：
134
1.pip install kafka-python 2.Producer.py from kafka import KafkaProducer producer = KafkaProducer(bootstrap_servers='10.32.106.42:9092') for _ in rang... ...
分类：
其他好文 时间：
2019-06-06 16:10:43
阅读次数：
107
MQ使用过程中，有些业务场景需要我们保证顺序消费，而如果一个Producer，一个Queue，多个Consumer的情况下是无法保证顺序的 举例： 1、业务上产生三条消息，分别是对数据的增加、修改、删除，而如果没有保证顺序消费，结果可能是删除、修改、增加，本来数据最终要删除 、结果变成增加 2、或者 ...
分类：
其他好文 时间：
2019-05-27 11:51:51
阅读次数：
1316
在上一篇文章讲解MQ消息可靠性投递和幂等性中有提到confirm机制的重要性，现在更相信的说明一下 一、Confirm机制 Confirm就是消息确认，当Producer发送消息，如果Broker收到消息，会回复一个应答，我们可以以此来确认消息是否成功送达，是保证 消息可靠性投递的核心保障 Prod ...
分类：
其他好文 时间：
2019-05-24 18:59:08
阅读次数：
106
一、MQ消息发送 1、发送端MQ-client(消息生产者：Producer)将消息发送给MQ-server； 2、MQ-server将消息落地； 3、MQ-server回ACK给MQ-client（Producer）； 4、MQ-server将消息发送给消息接受端MQ-client(消息消费者：C ...
分类：
其他好文 时间：
2019-05-23 22:44:49
阅读次数：
134
1. Rocketmq消费模型(实时性) 常见的数据同步方式有这几种： push：producer发送消息后，broker马上把消息投递给consumer。这种方式好在实时性比较高，但是会增加broker的负载；而且消费端能力不同，如果push推送过快，消费端会出现很多问题。 pull：produc ...
分类：
其他好文 时间：
2019-05-19 19:23:56
阅读次数：
218
