一、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);
});
原创文章,作者:XEKIX,如若转载,请注明出处:https://www.506064.com/n/370908.html