node.js - 为 Redis 端点使用 Node.js 全局变量

标签 node.js redis amazon-elasticache

我们即将开始在elastic cache中使用redis。我可以用我的端点保存一个配置文件,这很好。但是如果我们决定添加另一个副本,并且我们正在使用弹性 beantalk,这意味着在所有服务器上重建应用程序只是为了添加它。我可以将它们放在 S3 上的文件中,甚至查询 API,(那里是一个方便的调用,用于获取有关包含端点的弹性缓存集群的信息。)

但我不想每次都想建立与redis的连接时都这样做。在这种情况下,我正在考虑设置一个包含端点的全局变量,带有时间戳,并每小时或半小时检索一次信息。

我知道有些人认为全局变量令人厌恶,但我想不出任何其他方法来做到这一点。我可以将结果保存在 redis 本身中,但我真的不想在每次调用 redis 之前先点击 redis。

关于此的可行性或实现相同目的的其他方法有任何想法吗?我想自动发现任何新的 redis/elastic 缓存端点。

最佳答案

因此,我使用 AWS SDK 和 setinterval 编写了一个非常简单的函数。

aws_config = require("./config/aws_config.json");
AWS = require('aws-sdk');
AWS.config.update(aws_config);

var elasticache = new AWS.ElastiCache();

var elastic_cache_endpoints = {};

redis_end_points = {};

check_redis_endpoints();

setInterval(function ()
{
    check_redis_endpoints();
}, 10000);

function check_redis_endpoints()
{
    elasticache.describeReplicationGroups(
    {
        ReplicationGroupId:'test-dev'
    },
    function(err, data)
    {
        redis_end_points.write_end_point = data["ReplicationGroups"][0]["NodeGroups"][0]["PrimaryEndpoint"]["Address"];

        var replication_groups = data["ReplicationGroups"][0]["NodeGroups"][0]["NodeGroupMembers"];

        var end_points = [];

        Object.keys(replication_groups).forEach(function(element)
        {
            var read_end_point = replication_groups[element]["ReadEndpoint"]["Address"];
            end_points.push(read_end_point);
        });

        if (end_points.length > 0)
                redis_end_points.read_end_points = end_points;
    });
}

这会产生一个每 x 秒刷新一次的漂亮结构。

{
    write_end_point: 'test-dev.ababababababa.cache.amazonaws.com',
    read_end_points: [ 'test-dev-001.ababababab.cache.amazonaws.com', 'test-dev-002.ababababb.cache.amazonaws.com' ]
}

关于node.js - 为 Redis 端点使用 Node.js 全局变量,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28619430/

相关文章:

Javascript this 和命名与不命名变量

node.js - 解析服务器和 mongodb 问题

node.js - AWS Elastic Cache 是否支持 Redis 集群上的 Pub/Sub?

PHP AWS ElastiCache 连接失败

javascript - 为什么 createServer() 被认为不是函数?

javascript - NodeJS - 循环嵌套 API 调用

django - Redis 到 Socket.IO

php - 从 php 调用外部 Web API 的最佳方式

encryption - Redis Enterprise 如何保护其节点之间的传输中内部通信?

amazon-web-services - 如何遍历redis字典