Redis使用的例子

pyaauto

[redis.aardio]

1. 
   
2. class redis{
   
3.         ctor(host,port){
   
4.                 this._context=wsock.tcp.client();
   
5.                 if(null===this._context.connect(host,port))
   
6.                                 return null,"Connection server failed";
   
7.                 this.is_read = true;       
   
8.                 ..table.add_gc( this,"close");
   
9.         };
   
10.         type=me;
    
11.         @_meta;
    
12.         close = function(){
    
13.                 this._context.close();
    
14.         }   
    
15.         _read_str=function(redis_str){
    
16.                 return string.slice(redis_str,2,#redis_str);
    
17.         }
    
18.         _read_int=function(redis_str){
    
19.                 return tonumber(string.slice(redis_str,2,#redis_str));
    
20.         }
    
21.         _read_bulk=function(redis_str){
    
22.                 var pos= string.indexOf(redis_str,'\r\n');
    
23.                 if(!pos) return ;
    
24.                 var data_num = tonumber(string.slice(redis_str,2,pos));
    
25.                 if( !data_num or data_num === -1) return ;
    
26.                 return string.slice(redis_str,pos+2,pos+2+data_num);
    
27.         }
    
28.         _read_err=function(redis_str){
    
29.                 return string.slice(redis_str,2,#redis_str);
    
30.         }
    
31.         _redis_read=function(socket_data){
    
32.                 socket_data =string.trimleft(socket_data);
    
33.                 var first_char= string.left(socket_data,1)
    
34.                 select(first_char) {
    
35.                         case "+" {
    
36.                                 return this._read_str(socket_data);
    
37.                         }
    
38.                         case "-" {
    
39.                                 return this._read_err(socket_data);
    
40.                         }
    
41.                         case ":" {
    
42.                                 return this._read_int(socket_data);
    
43.                         }
    
44.                         case "$" {
    
45.                                 return this._read_bulk(socket_data);
    
46.                         }
    
47.                         case "*" {
    
48.                                 var pos= string.indexOf(socket_data,'\r\n');
    
49.                                 if(!pos) return ;
    
50.                                 var tab={}
    
51.                                
    
52.                                 var remove = pos + 2;
    
53.                                 while(1){
    
54.                                                 socket_data = string.slice(socket_data,remove,#socket_data);
    
55.                                                 if(type(socket_data) !== type.string) break ;
    
56.                                                 pos= string.indexOf(socket_data,'\r\n');
    
57.                                                 if(!pos) break ;
    
58.                                                
    
59.                                                 var ret;
    
60.                                                 var line_data=string.slice(socket_data,1,pos);
    
61.                                                 var line_type = string.left(line_data,1)
    
62.                                                
    
63.                                                 ret = this._redis_read( line_data );
    
64.                                                 if(line_type==="$"){
    
65.                                                
    
66.                                                         var line_num = tonumber(string.slice(line_data,2,#line_data));
    
67.                                                        
    
68.                                                         if(line_num === -1){
    
69.                                                                 ret = this._redis_read(line_data );
    
70.                                                         }else {
    
71.                                                                 //多行
    
72.                                                                 line_data = string.left(socket_data,#line_data+2+line_num)
    
73.                                                                 ret = this._redis_read( line_data );
    
74.                                                         }
    
75.                                                 }else {
    
76.                                                         ret = this._redis_read( line_data );
    
77.                                                 }
    
78.                                                 remove = #line_data+2;
    
79.                                                 if(ret) table.push(tab,ret);
    
80.                                 }
    
81.                                 return tab:{};
    
82.                         }
    
83.                         else {
    
84.                                 return null;
    
85.                         }
    
86.                 }
    
87.         }
    
88.        
    
89.         commands=function(...){
    
90.                 var t={...};
    
91.                 var r = '\r\n';
    
92.                 var num = #t
    
93.                
    
94.                 var cmdtxt = "*"++num++r;
    
95.                 for(i=1;num;1){
    
96.                         t[i] = tostring(t[i])
    
97.                         cmdtxt += "$"++#t[i]++r;
    
98.                         cmdtxt += t[i]++r
    
99.                 }
    
100.                
     
101.                 this._context.send(cmdtxt,#cmdtxt)
     
102.                 if( this.is_read ) return this._redis_read(this._context.recv());
     
103.         }
     
104.        
     
105.         get_array =function(redis_array,sn=0,dn=-1) {
     
106.                 return this.commands("LRANGE",redis_array,sn,dn);
     
107.         }
     
108.        
     
109.         set_array=function (redis_array,redis_array_val) {
     
110.                 this.is_read =false;
     
111.                 this.commands("DEL",redis_array);
     
112.                 for(i=1;#redis_array_val;1){
     
113.                         this.commands("RPUSH",redis_array,redis_array_val[i]);
     
114.                 }
     
115.                 this.is_read = true;
     
116.                 return this._context.recv();
     
117.         }
     
118. }
     
119. 
     
120. namespace redis {
     
121.         import wsock.tcp.client;
     
122.         string = ..string;
     
123.         table = ..table;
     
124.         _meta = {
     
125.                 _get = function( k ){
     
126.                                 if( type(k) == "string" && k[1]=='_'# ) return;
     
127.                                 if(!k) return;
     
128.                                 if(!owner[['commands']]) return ;
     
129.                                  
     
130.                             var api = {
     
131.                                     _cmd = k;
     
132.                                     _cmdfunc=owner[['commands']];
     
133.                                         @_meta;
     
134.                                 }
     
135.                                 owner[[k]] = api;
     
136.                                 return api;
     
137.                 }
     
138.                 _call = function( ... ){
     
139.                                 return owner._cmdfunc(owner._cmd,...)
     
140.                 }
     
141.         }
     
142. }
     

复制代码

import console
import redis
console.open()

db=redis('127.0.0.1',6379)

//返回服务器时间
console.varDump(db.time())

//将字符串值 value 关联到 key
db.set('key',12345)
//返回 key 所关联的字符串值
console.log(db.get('key'))

//追加字符串
db.append("key","56789")
console.log("test",db.get("key"))

//保存数组
db.set_array("isarray",{"hello";"test";"test1"})
//读取数组
console.varDump(db.get_array("isarray"))


//删除
console.log(db.del('isarray'))
console.log(db.del('key'))

//模糊读取
db.set("key_1","value_1")
db.set("key_2","value_2")
db.set("key_3","value_3")
db.set("key_11","value_4")
db.set("key_12","value_5")
console.varDump(db.keys("key_*"))
console.varDump(db.keys("key_?"))

//计数
console.log("crkey",1)
db.set("crkey",1)
console.log("将 key 中储存的数字值加一");
db.incr("crkey");
console.log(db.get("crkey"))
console.log("将 key 中储存的数字值减一");
db.decr("crkey");
console.log(db.get("crkey"))

//以秒为单位设置过期时间
console.log(db.setex("exkey",2,"exvalue"))
console.log(db.get("exkey"),type( db.get("exkey")))
console.log("返回剩余生存时间:",db.pttl("exkey"))
sleep(2000)
console.log(db.get("exkey"),type( db.get("exkey")))

console.pause()

常年最低调

学习，感谢楼主

bob

感谢楼主的精彩例子

xiaoqiang

模糊查询语句不正常db.keys("*")，结束ahtmlcgi进程才能成功成功查询一次。

pyaauto

xiaoqiang 发表于 2016-10-30 22:55
模糊查询语句不正常db.keys("*")，结束ahtmlcgi进程才能成功成功查询一次。

自己简单使用没有问题，能提供一下测试代码吗？你也可以加个断点对比下协议看看

pyaauto

xiaoqiang 发表于 2016-10-30 22:55
模糊查询语句不正常db.keys("*")，结束ahtmlcgi进程才能成功成功查询一次。

自己简单使用没有问题，能提供一下测试代码吗？你也可以加个断点对比下协议看看

xiaoqiang

我服务器是win2008,装的Redis-x64-3.2.100，keys和scan语句返回的都是空table,别的命令暂时每发现问题。用客户端都能正常返回。

xiaoqiang

//==服务器
yuuuu=function(){
       
import redis;

db=redis('127.0.0.1',46379);

fs=db.keys("*");

return fs;
       
}



var ahtml = carl.ahtml.client(serverUrl, rsaPublicKey);

yb= ahtml.yuuuu()

console.varDump(yb)

pyaauto

xiaoqiang 发表于 2016-11-1 10:04
//==服务器
yuuuu=function(){
       

我用的2.6版本,里面好像没有scan，重新更新了下，你再看看

xiaoqiang

把服务器ahtmlcgi.exe进程手动结束以后，调用一下keys能正常返回结果，然后再继续调用，就返回空table

xiaoqiang

这个问题和ahtmlcgi.exe进程有关系

xiaoqiang

封装个3.2的用用把，2.6的太老了。

itdiy

mark！！！！！！

znkee

标准库下hiredis不能在xp下使用，2003系统也不一定能用（后面会付上测试主机）。redis的通信协议很简单，可以根据：http://doc.redisfans.com/topic/protocol.html封装一个用socket通信的类简单连接，可满足在xp、win2003环境下的使用。
传送门：http://bbs.aardio.com/forum.php? ... amp;highlight=redis，此类基本上实现了redis通信，感谢@pyaardio。
测试服务器：14.1.98.53 :55588  administrator  07f2af522b（还有几天到期，随便用）
桌面上的 memcaced.exe 是通过hiredis示例编译出来的，aardio工程20.exe 用的上面传送门里面的类。aardio工程20.exe 源码如下：

import console;
import redis;

console.open();
var cli = redis("127.0.0.1",6379);
if(cli){
    cli.set("a","11232")
    cli.set("b","aaaa")
    console.dump(cli.keys("*"))
    console.dump(cli.keys("*"))
    console.dump(cli.keys("*"))
    console.dump(cli.keys("*"))
}else {
    console.dump("连接失败")
}
console.pause();

JacenHe

znkee 发表于 2018-5-5 14:01
标准库下hiredis不能在xp下使用，2003系统也不一定能用（后面会付上测试主机）。redis的通信协议很简单，可 ...

这不需要测试主机，
在范例里已经有说明，hiredis主要是用于服务端开发，不支持XP系统（2003跟XP一样）。

即然你的win2003服务器几天就到期了，换个2008很难吗？！
服务器厂商基本都不提供2003的服务器了。