一、MongoDB

MongoDB是一个基于分布式文件存储概念的开源数据库系统，由C++语言编写，旨在为Web应用提供可扩展的高性能数据存储解决方案。MongoDB的数据模型是面向文档的，可以存储比较复杂的结构数据（例如json格式），支持动态查询，索引能够包含子文档（数组或内嵌文档），且查询效率高。MongoDB适用于需要大量写入的场景，但是缺乏事务（4.0版本开始支持事务），对于一些金融领域中需要强一致性的应用并不适合。

1、示例代码

//连接数据库
const mongoose = require('mongoose');
mongoose.connect('mongodb://localhost/test');
//定义Schema
const Schema = mongoose.Schema;
const userSchema = new Schema({
  name: String,
  age: Number
});
//编译Schema生成Model
const UserModel = mongoose.model('User', userSchema);
//数据的增、删、改、查操作
UserModel.create({ name: '张三', age: 20 }, function (err, user) {
  //新增
});
UserModel.updateOne({ name: '张三' }, { $set: { age: 21 } }, function (err, result) {
  //修改
});
UserModel.deleteOne({ name: '张三' }, function (err) {
  //删除
});
UserModel.find({ age: { $gte: 20 } }, function (err, users) {
  //查询
});

二、Redis

Redis是一个内存中的数据结构存储系统，支持字符串、哈希表、列表、集合、有序集合等数据类型。Redis的好处是能快速地读写存储的数据，对于缓存和短期数据存储非常适合。另外Redis支持发布订阅模式、支持事务等特性。但是，因为Redis是内存数据库，所以无法存储海量数据，且不支持持久化存储，只能将内存中的数据定期写入磁盘，如果机器宕机，会造成一定的数据丢失。

1、示例代码

//连接Redis
const redis = require('redis');
const client = redis.createClient();
//增、删、改、查操作
client.set('name', '张三', redis.print); //新增
client.get('name', function (err, result) { //查询
  console.log(result);
});
client.del('name', redis.print); //删除

三、Apache Kafka

Apache Kafka是一个分布式的流处理平台，主要用于解决高并发场景下的数据处理问题，像日志收集、实时流处理、数据分析等。与传统消息队列不同，Kafka可以支持海量消息数据的存储，同时也可以实现消息的快速传输和高度可靠的消息处理。此外，Kafka还适合于数据流的处理，可以将大量数据通过分区方式分散到多个队列中，以实现数据的并行处理和高效传输。

1、示例代码

//构建producer
const kafka = require('kafka-node');
const Producer = kafka.Producer;
const KeyedMessage = kafka.KeyedMessage;
const client = new kafka.Client('localhost:2181');
const producer = new Producer(client);
//构建consumer
const Consumer = kafka.Consumer;
const consumer = new Consumer(
  client,
  [
    { topic: 'test', partition: 0 },
  ],
  {
      autoCommit: true,
      fromBeginning: true
  }
);
//发送消息
producer.on('ready', function () {
  const message = new KeyedMessage('key', 'hello kafka');
  producer.send([{ topic: 'test', messages: [message] }]);
});
//接收消息
consumer.on('message', function (message) {
  console.log(message);
});