发表于 更新于 分类于

生产者发送消息向kafka发送消息的主要步骤如下图： 创建ProducerRecord对象，其中包含主题(topic)和内容(value)两个必传参数，也可以添加键(key)和分区(partition)两个非必传参数； 然后在发送ProducerRecord对象，生产者要先把键值对象序列化成字节数 ...

阅读全文 »

发表于 更新于 分类于

Kafka is a distributed,partitioned,replicated commit logservice。 Kafka是一个分布式、分区、复制的提交日志服务。 kafka对消息保存时根据主题（Topic）进行归类，发送消息者成为生产者（Producer）,消息接受者成为消费者（ ...

阅读全文 »

发表于 更新于 分类于

发布与订阅消息系统的数据的发送者不会把消息直接发送给接受者； 发送者以某种方式对消息进行分类，接受者订阅他们，以便接受特定类型的消息； 发布和订阅系统一般会有一个broker,也就是发布消息的中心点。 没有使用发布订阅消息系统的结构如下图: 如果多个服务之间需要互相获取消息，需要专门写对应的接口， ...

阅读全文 »

发表于 更新于 分类于

本篇使用的zookeeper+kafka单机安装的版本见下文描述，软件版本不一致可能配置不尽相同，慎重参考。 不论是zookeeper还是kafka的安装都需要安装jdk环境，不再赘述 zookeeper的安装下载zookeeper（本篇使用3.4.14版本） # wget https://mirr ...

阅读全文 »

发表于 更新于 分类于

本系列参考书是《Redis开发与运维》，没有通篇看完，摘取自己认为比较重要的章节做成笔记，杂糅一些网友智慧结晶，为有缘人的学习和日后自己的复习提供一个材料。 Redis特性 Redis安装、配置、启动、关闭 初识Redis 单线程架构 数据类型：字符串（string） 数据类型：哈希（hash） 数 ...

阅读全文 »