用Nodejs加redis实现follow，tag，feed系统

用Node.js加Redis实现Follow、Tag、Feed系统

概述

本文将介绍如何使用Node.js和Redis来实现一个简单的Follow、Tag和Feed系统。我们将从Tag系统开始，逐步扩展到其他功能。

Tag系统实现

示例代码

首先，我们来看一下如何使用Redis来管理标签（Tag）。

const redis = require('redis');
const client = redis.createClient();

// 添加标签
function addTag(username, item, tag, callback) {
    const key1 = `user:${username}:tag:${tag}`;
    const key2 = `user:${username}:item:${item}`;

    client.sadd(key1, item, (err, res) => {
        if (err) return callback(err);
        client.sadd(key2, tag, (err, res) => {
            callback(null, res);
        });
    });
}

// 获取所有标签
function getAllTags(username, item, callback) {
    client.smembers(`user:${username}:item:${item}`, callback);
}

// 获取带有特定标签的所有项目
function getItemsByTag(username, tag, callback) {
    client.smembers(`user:${username}:tag:${tag}`, callback);
}

// 获取带有多个标签的所有项目
function getItemsByMultipleTags(username, tags, callback) {
    client.sinterstore('temp', tags.map(tag => `user:${username}:tag:${tag}`), (err, res) => {
        if (err) return callback(err);
        client.smembers('temp', (err, res) => {
            client.del('temp', () => {});
            callback(null, res);
        });
    });
}

示例调用

addTag('ltebean', 'bootstrap', 'css', (err, res) => {
    console.log(res); // 输出添加结果
});

getAllTags('ltebean', 'bootstrap', (err, res) => {
    console.log(res); // 输出所有标签
});

getItemsByTag('ltebean', 'css', (err, res) => {
    console.log(res); // 输出带有该标签的所有项目
});

getItemsByMultipleTags('ltebean', ['css', 'web'], (err, res) => {
    console.log(res); // 输出同时带有这两个标签的所有项目
});

Follow系统实现

示例代码

接下来，我们来看一下如何使用Redis来实现Follow系统。

// 关注用户
function followUser(follower, following, callback) {
    const key1 = `user:${follower}:following`;
    const key2 = `user:${following}:followers`;

    client.sadd(key1, following, (err, res) => {
        if (err) return callback(err);
        client.sadd(key2, follower, (err, res) => {
            callback(null, res);
        });
    });
}

// 获取关注者列表
function getFollowers(username, callback) {
    client.smembers(`user:${username}:followers`, callback);
}

// 获取被关注者列表
function getFollowing(username, callback) {
    client.smembers(`user:${username}:following`, callback);
}

示例调用

followUser('user1', 'user2', (err, res) => {
    console.log(res); // 输出添加结果
});

getFollowers('user2', (err, res) => {
    console.log(res); // 输出关注者列表
});

getFollowing('user1', (err, res) => {
    console.log(res); // 输出被关注者列表
});

Feed系统实现

示例代码

最后，我们来看一下如何使用Redis来实现Feed系统。

// 发布动态
function postActivity(username, activity, callback) {
    const key = `user:${username}:activity`;

    client.rpush(key, activity, (err, res) => {
        callback(null, res);
    });
}

// 获取用户的动态
function getActivity(username, callback) {
    client.lrange(`user:${username}:activity`, 0, -1, callback);
}

示例调用

postActivity('ltebean', 'Learning Node.js', (err, res) => {
    console.log(res); // 输出发布结果
});

getActivity('ltebean', (err, res) => {
    console.log(res); // 输出动态列表
});

总结

以上代码展示了如何使用Node.js和Redis来实现一个简单的Follow、Tag和Feed系统。通过这些基本的功能，你可以进一步扩展和优化你的应用。更多详细的实现可以参考GitHub上的项目地址：

• Taggie
• User Graph
• Feedie

希望这些示例对你有所帮助！