转载： redis 操作

导航栏：首页评论列表

转载： redis 操作

默认分类 2014/04/20 06:01

原文地址：http://www.cnblogs.com/lori/p/3435483.html
原文地址：http://www.cnblogs.com/lori/p/3436090.html

众所周知

redis量个强大的缓存组件，可以部署在win32和linux环境之上，它有五大存储结构，其中有一种为列表list，它可以实现quene和stack的功能，即队列和堆栈的功能。

redis相关文章，可以看我的相关博文《Redis学习笔记~目录》,redis实现消息队列，可以看我的《Redis实现消息队列比MSMQ更方便》

node-redis-client相关下载地址为：https://github.com/fictorial/redis-node-client

说一下它们工作流程：

node之前

client->IIS/apache服务器->2M Thread->redis server(windows/linux)

node之后

client->Node.JS(event driven)->redis server(windows/linux)

我们可以看到，nodeJS出现之后，我们在与redis通讯时，不走原来的那种线程机制，而是走事件驱动，原来的IO瓶颈没有了，原来8G内存支持4000个并发量，现在不存在了，看到了这些信息，我想，对于高并发模块，咱们没有理由不使用nodeJS作为http服务器了吧，呵呵。

说干就干（下载地址）

首先找到\redis-node-client-master\examples目录，运行命令node publisher.js

这时打开你的redis服务redis-server,我们用的是windows版的

这时，你的redis-server将到监视到由node.js发过来的数据，如图

下面我们再来看一下通过客户端访问node.js进行redis存储的过程

如果你的电脑处于联网状态，那么安装可以把redis-node以npm模块的形式安装到node中，以后在引用时直接使用require("redis")就可以了，不需要写相对路径了，呵呵，安装它的方法如下：

npm install redis 

npm install hiredis redis

这时，如果安装成功，就可以做实例了，呵呵！注意，我们的npm install redis这种安装模块的命令，是把模块安装到当前目录的，即你的工作项目如果需要redis，需要在工作项目中进行安装，如果你的工作项目目录是c:\noderedis,那么安装模块后，你的目

录会多一个node_modules文件夹，如图：

安装的过程如图：

下面我们写一个实例，用来向redis服务器发set和hset串，然后再把redis服务器里所有的键名都读出来

var redis = require("redis");
var client = redis.createClient();

client.on("error", function (err) {
    console.log("Error " + err);
});

client.set("string key", "string val", redis.print);
client.get("string key", function(err, v){console.log(v)};

client.hset("hash key", "hashtest 1", "some value", redis.print);
client.hset(["hash key", "hashtest 2", "some other value"], redis.print);
client.hkeys("hash key", function (err, replies) {
    console.log(replies.length + " replies:");
    replies.forEach(function (reply, i) {
        console.log("    " + i + ": " + reply);
    });
    client.quit();
});

运行结果如下：

OK，这说明，我们的redis-node客户端已经和redis服务器可以正常通讯了，呵呵，下一讲中，我们将学习，通过客户端向node发post请求，将数据包通过node发到redis，敬请期待！

=============================================================================================

说在前

对于HTTP请求来说，我们通常使用的是Get和Post,除此之外还有put,delete等，而对于get来说，比较lightweight，只是对字符串的传输，它会被添加到URL地址里，属于URL的一部分，有时，我们为了安全和兼容性问题，URL地址上的参数会进行Url.Encode，有的浏览器已经带我们做了这些；而对于Post来说，就显得重了一些，它的数据以包的形式存在，除了可以有文本信息，还可以有二进制文件流信息，这讲里，我们主要说的是Post里的文本处理。

做在后

一　　使用NodeJs实现对Get请求的处理，nodejs接入的形式为url?param1=zzl&param2=male

var redis = require("redis");
var http = require('http');
var url = require("url");
var info = "通过HTTPGet方式成功加入队列";
http.createServer(function (req, res) {
    var params = url.parse(req.url, true).query;//解释url参数部分name=zzl&amp;email=zzl@sina.com
    var client = redis.createClient();
    client.lpush("topnews", params.info);
    res.writeHead(200, {
        'Content-Type': 'text/plain;charset=utf-8'
    });
    client.lpop("topnews", function (i, o) {
        console.log(o);//回调，所以info可能没法得到o的值，就被res.write输出了
    })
    client.quit();
    res.write(info);
    res.end();
}).listen(8000, "127.0.0.1");
console.log('Server running at http://127.0.0.1:8000/');

测试：http://127.0.0.1:8000?info=zzl

二　　使用NodeJs实现对Post请求的处理,nodejs接入的形式为{param1="zzl",param2="male"}

Post由于它的重量，所以不可能说接收就接收，它会存储接入中和接入完成两种状态，两种状态对应着回调方法，即，当然数据处于接入中状态时，处理一种流程；当数据接入完成后，处理另一种流程。

//接入中 
 req.addListener("data", function (postDataChunk) {});
//接收完成
 req.addListener("end", function () {});</pre>

下面看一下完成的代码：

var redis = require('redis');
var http = require('http');
var url = require("url");
var querystring = require("querystring");
http.createServer(function (req, res) {
    // 设置接收数据编码格式为 UTF-8
    req.setEncoding('utf-8');
    var postData = ""; //POST &amp; GET ： name=zzl&amp;email=zzl@sina.com
    // 数据块接收中
    req.addListener("data", function (postDataChunk) {
        postData += postDataChunk;
    });
    // 数据接收完毕，执行回调函数
    req.addListener("end", function () {
        console.log('数据接收完毕');
        var params = querystring.parse(postData);//GET &amp; POST  ////解释表单数据部分{name="zzl",email="zzl@sina.com"}
        console.log(params);
        console.log(params["name"]);
        PushToRedis(params["name"]);
        res.writeHead(500, {
            "Content-Type": "text/plain;charset=utf-8"
        });
        res.end("数据提交完毕");
    });
}).listen(8000, "127.0.0.1");
console.log('Server running at http://127.0.0.1:8000/');

//表单接收完成后，再处理redis部分
function PushToRedis(info) {
    var client = redis.createClient();
    client.lpush("topnews", info);
    console.log("PushToRedis:" + info);
    client.lpop("topnews", function (i, o) {
        console.log(o);//回调，所以info可能没法得到o的值，就被res.write输出了
    })
    client.quit();
}

下面看一下结果，我把它截了图：

实事上，对于post到nodeJS再由nodeJS到redis，这个case我们经常会看到，它实现起来比IIS，apache在性能上要高很多，它没有为每个连接建立线程，它解决了IO阻塞等等，OK，说到这里，我再强调一个nodeJS用到的最重要的场合：逻辑简单的高并发场合！

下一次，我将为大家带来NodeJS实现文件上传的功能，敬请关注！

>> 留言评论