delphi redisclient测试

1. unit Unit1;
3. interface
5. uses
6.   Winapi.Windows, Winapi.Messages, System.SysUtils, System.Variants, System.Classes, Vcl.Graphics,
7.   Vcl.Controls, Vcl.Forms, Vcl.Dialogs, Vcl.StdCtrls, Vcl.Buttons;
9. type
10.   TForm1 = class(TForm)
11.     Memo1: TMemo;
12.     BitBtn1: TBitBtn;
13.     procedure FormCreate(Sender: TObject);
14.   private
15.     { Private declarations }
16.   public
17.     { Public declarations }
18.   end;
21. var
22.   Form1: TForm1;
24. implementation
26. {$R *.dfm}
28. uses
29.   Redis.Commons, redis.Command, redis.NetLib.INDY, redis.Client;
31. var
32.   redis: IRedisClient;
33.   cmd: IRedisCommand;
35. procedure log(msg: string);
36. begin
37.   Form1.Memo1.Lines.Add(msg);
38. end;
40. procedure TForm1.FormCreate(Sender: TObject);
41.   procedure addMsg;
42.   begin
43.     if not redis.EXISTS('myStream') then
44.     begin
45.       var xaddCmd := NewRedisCommand('XADD').Add('myStream').Add('*').Add('name').Add('jjw');
46.       var ret := redis.ExecuteWithStringResult(xaddCmd);
47.       if ret.HasValue then
48.         Log(ret.Value);
49.     end;
50.   end;
52.   procedure getGroups;
53.   begin
54.     cmd := NewRedisCommand('XINFO').Add('GROUPS').Add('myStream');     //redis 无法处理
55.     var ret := redis.ExecuteAndGetMatrix(cmd);
56.     if ret.HasValue then
57.     begin
58.       var c := Length(ret.Value);
59.       var v := ret.Value[0];
60.       for var I := 0 to Length(v.Value)-1 do
61.         log(v.Value[I].Value);
62.     end;
63.   end;
65.   procedure clearGroup;
66.   begin
67.     cmd := NewRedisCommand('XGROUP').Add('DESTROY').Add('myStream').Add('myGroup');     //会清空未读，未确认的消息
68.     var ret := redis.ExecuteWithStringResult(cmd);
69.   end;
71.   procedure createGroup;
72.   begin
73.     var createGroupCmd := NewRedisCommand('XGROUP').Add('CREATE').Add('myStream').Add('myGroup').Add('0');  // $:最新消息, 即未读过的。  0:从最后一条读
74.     var ret := redis.ExecuteWithStringResult(createGroupCmd);
75.     if ret.HasValue then
76.       Log(ret.Value);
77.   end;
79.   procedure readMsg;
80.   begin
81.     cmd := NewRedisCommand('XREADGROUP').Add('GROUP').Add('myGroup').Add('cm').Add('COUNT').Add(2).Add('STREAMS').Add('myStream').Add('>');  //0，未ACK（确认）的未读消息   > 未读过的消息
82.     var val := redis.ExecuteAndGetRESPArray(cmd);
83.     if val<>nil then
84.       memo1.Text := val.ToJSON(); //[["myStream",[["1704960677439-0",["name","haha","age","100"]]]]]
85. //    Memo1.Text := val.ToString; //[["myStream",[["1704960677439-0",["name","haha","age","100"]]]]]
86. //    var y1 := val[0].ArrayValue[0].Value;  //myStream
87. //    Log(val[0].Items[1].Items[0].Items[0].Value);  //1704960677439-0
88. //    Log(val[0].Items[1].Items[0].Items[1].Items[0].Value);  //name
89.   end;
90. begin
91.   redis := NewRedisClient('192.168.88.129');
93.   getGroups;
95.   addMsg;
96.   try
97.     // if not ExistsGroup(groupName) then  //若不判断，捕获异常也可以。
98.     //   createGroup;
99.   except
100.     ;
101.   end;
102.   readMsg;
103. end;
105. end.

复制代码

注：
或IRedisClient接口中无ExecuteAndGetMatrix方法需要自行添加。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！