队列工厂之RedisMQ威尼斯人6799.com

这一次和我们大快朵颐的是RedisMQ队列的用法,前两篇小说队列工厂之(MSMQ)队列工厂之RabbitMQ个别不难介绍对应队列环境的搭建和常用方法的行使,加上本篇分享的RedisMQ那么就做到了咋们队列工厂”三剑客“的目的了哈哈;Redis的法力不仅局限于队列,更加多的一般都采纳它的key,value的款式来囤积session可能hash的法子存款和储蓄一些常用的数据,当然那不是本章分享的内容(此前有个别文章有讲过redis的选用处境和代码分享各位能够看下),那QueueReposity-队列工厂终极一篇甘休后,小编后边分享的也许是netcore方面的一对事物了,vs2017出去了简约创设netcore项目事后察觉与事先的本子有些变动,例如:没有project.json,怎么布局生成跨平台程序等题材,供给二个二个上学和尝试,网上搜寻的小说还很少,全靠阅读全英文的官网来读书了哈哈;希望大家能够喜欢本篇小说,也希望各位多多”扫码帮衬“和”推荐“谢谢!

队列工厂之RedisMQ,队列redismq

本次和豪门享受的是RedisMQ队列的用法,前两篇文章队列工厂之(MSMQ)队列工厂之RabbitMQ分别不难介绍对应队列环境的搭建和常用方法的应用,加上本篇分享的RedisMQ那么就完事了咋们队列工厂”三剑客“的目的了哈哈;Redis的功能不仅局限于队列,越多的一般都采纳它的key,value的样式来储存session或然hash的点子存款和储蓄一些常用的数码,当然那不是本章分享的剧情(从前有个别小说有讲过redis的施用情况和代码分享各位能够看下),那QueueReposity-队列工厂最后一篇停止后,作者前边分享的或许是netcore方面包车型客车局地东西了,vs2017出去了不难创建netcore项目事后察觉与事先的本子有个别变动,例如:没有project.json,怎么安顿生成跨平台程序等题材,须求3个1个学习和品味,网上寻找的篇章还很少,全靠阅读全英文的官网来学习了哈哈;希望我们能够欣赏本篇小说,也冀望各位多多”扫码接济“和”推荐“谢谢!

 

» Redis安装和RedisClient工具的利用

**» 封装RedisMQ队列的读和写**

**» 队列工厂之RedisMQ测试用例**

 

上边一步2个脚印的来享受:

**» Redis安装和RedisClient工具的施用**

先是要采纳redis要求下载安装Redis,那里由于事先的作品有讲解在windows下怎么搭建redis服务,所以不再赘述,各位能够点击搭建Redis服务端,并用客户端连接,由此笔者这边一贯分享怎么利用**RedisClient工具**,那工具使用起来比较不难和惠及,首先去那几个地方下载:

http://dlsw.baidu.com/sw-search-sp/soft/a2/29740/RedisClient20140730.1406883096.exe

安装-》打开软件,能收看如图的界面:

威尼斯人6799.com 1

-》点击“Server”-》Add-》输入2个别称,你redis服务端的ip,端口-》确认即可:

威尼斯人6799.com 2

其目前候你redisclient的安顿工作就完了了是否很简单啊,-》再来点击刚才创设外号-》双击打开redis的首先个数据库db0(那里正是在并未点名数据库地点时候存款和储蓄数据的地点)-》能看到您存储的数额key:

威尼斯人6799.com 3

要是想看有些name的数目直接双击对应的name就行了-》那里是本身redis服务存款和储蓄的一个hash数据的截图:

威尼斯人6799.com 4

是否很有益于,那一个客户端能够平昔删除你不想要的数目-》右键选中您想删除的name-》Delete即可删除:

威尼斯人6799.com 5

怎么,这些RedisClient工具学会了么,是还是不是挺简单的吧;

 

**» 封装RedisMQ队列的读和写**

到那里终于来到大家代码分享的随时了,固然QueueReposity-队列工厂现已开源了源码,那里依然单身分享一次唯有RedisMQ的代码;首先创制多个称呼为:QRedisMQ的class-》继承 PublicClass.ConfClass<T>-》再落到实处接口IQueue,最后就有了小编们落到实处接口方法体代码:

 1     /// <summary>
 2     /// RedisMQ
 3     /// </summary>
 4     public class QRedisMQ : PublicClass.ConfClass<QRedisMQ>, IQueue
 5     {
 6         private IRedisClient redis = null;
 7 
 8         public void Create()
 9         {
10             if (string.IsNullOrWhiteSpace(this.ApiUrl) ||
11                 string.IsNullOrWhiteSpace(this.UserPwd)) { throw new Exception("创建QRedisMQ队列需要指定队列:ApiUrl,UserPwd"); }
12 
13             this.ApiKey = string.IsNullOrWhiteSpace(this.ApiKey) ? "6379" : this.ApiKey;
14             redis = redis ?? new RedisClient(this.ApiUrl, Convert.ToInt32(this.ApiKey), this.UserPwd);
15         }
16 
17         public long Total(string name = "Redis_01")
18         {
19             if (redis == null) { throw new Exception("请先创建队列连接"); }
20             if (string.IsNullOrWhiteSpace(name)) { throw new Exception("name不能为空"); }
21 
22             return redis.GetListCount(name);
23         }
24 
25         public Message Read(string name = "Redis_01")
26         {
27             if (redis == null) { throw new Exception("请先创建队列连接"); }
28             if (string.IsNullOrWhiteSpace(name)) { throw new Exception("name不能为空"); }
29 
30             var message = new Message();
31             try
32             {
33                 message.Label = name;
34                 var result = redis.DequeueItemFromList(name);
35                 if (string.IsNullOrWhiteSpace(result)) { return message; }
36                 message.Body = result;
37             }
38             catch (Exception ex)
39             {
40                 throw new Exception(ex.Message);
41             }
42             return message;
43         }
44 
45         public bool Write(string content, string name = "Redis_01")
46         {
47             if (redis == null) { throw new Exception("请先创建队列连接"); }
48             if (string.IsNullOrWhiteSpace(content) || string.IsNullOrWhiteSpace(name)) { throw new Exception("content和name不能为空"); }
49             redis.EnqueueItemOnList(name, content);
50             return true;
51         }
52 
53         public void Dispose()
54         {
55             if (redis != null)
56             {
57                 redis.Dispose();
58                 redis = null;
59             }
60         }
61 
62 
63         //public List<Message> ReadAll()
64         //{
65         //    throw new NotImplementedException();
66         //}
67     }

此处运用的Redis的dll是引用了连带的nuget包:

威尼斯人6799.com 6

包裹的行列Redis工厂流程同样是:创设(Create)-》读(Read)|写(Write)-》释放(Dispose);有了具体的RedisMQ完成类,然后还需利用工厂情势提供的艺术来创立这么些类的实例:

 1   /// <summary>
 2     /// ==================
 3     /// author:神牛步行3
 4     /// des:该列工厂开源,包括队列有MSMQ,RedisMQ,RabbitMQ
 5     /// blogs:http://www.cnblogs.com/wangrudong003/
 6     /// ==================
 7     /// 队列工厂
 8     /// </summary>
 9     public class QueueReposity<T> where T : class,IQueue, new()
10     {
11         public static IQueue Current
12         {
13             get
14             {
15                 return PublicClass.ConfClass<T>.Current;
16             }
17         }
18     }

到那儿RedisMQ工厂代码就形成了,上面初阶享用大家的测试用例;

 

**» 队列工厂之RedisMQ测试用例**

透过上面配置环境和包裹本人的方法,那里写了1个简便的测试用例,分为Server(参预新闻队列)和Client(获取音信队列),首先来看Server端的代码:

 1 /// <summary>
 2     /// 队列服务端测试用例
 3     /// </summary>
 4     class Program
 5     {
 6         static void Main(string[] args)
 7         {
 8             Redis_Server();
 9 
10             // RabbitMQ_Server();
11 
12             //MSMQ_Server();
13         }
14 
15         private static void Redis_Server()
16         {
17             //实例化QRedisMQ对象
18             var mq = QueueReposity<QRedisMQ>.Current;
19 
20             try
21             {
22                 Console.WriteLine("Server端创建:RedisMQ实例");
23                 mq.Create();
24 
25                 var num = 0;
26                 do
27                 {
28                     Console.WriteLine("输入循环数量(数字,0表示结束):");
29                     var readStr = Console.ReadLine();
30                     num = string.IsNullOrWhiteSpace(readStr) ? 0 : Convert.ToInt32(readStr);
31 
32                     Console.WriteLine("插入数据:");
33                     for (int i = 0; i < num; i++)
34                     {
35                         var str = "我的编号是:" + i;
36                         mq.Write(str);
37                         Console.WriteLine(str);
38                     }
39                 } while (num > 0);
40             }
41             catch (Exception ex)
42             {
43             }
44             finally
45             {
46                 Console.WriteLine("释放。");
47                 mq.Dispose();
48             }
49             Console.ReadLine();
50         }

由此:创立(Create)-》读(Read)|写(Write)-》释放(Dispose)
的流程来利用大家的体系工厂,此时我们运转下那么些Server端,然后分德宏药录入四回参数:

威尼斯人6799.com 7

能收看截图的文字描述,那么些测试数据插入到了redis的连串中,上边我们经过首节说的RedisClient工具查看数据,点击队列名称如:

威尼斯人6799.com 8

透过工具能来看大家刚刚插入的数据,然后大家来经过测试用例的client端读取队列,具体代码:

 1   /// <summary>
 2     /// 队列客户端测试用例
 3     /// </summary>
 4     class Program
 5     {
 6         static void Main(string[] args)
 7         {
 8             RedisMQ_Client();
 9 
10           //  RabbitMQ_Client();
11 
12             //MSMQ_Client();
13         }
14 
15         private static void RedisMQ_Client()
16         {
17             //实例化QRedisMQ对象
18             var mq = QueueReposity<QRedisMQ>.Current;
19             try
20             {
21                 Console.WriteLine("Client端创建:RedisMQ实例");
22                 mq.Create();
23 
24                 while (true)
25                 {
26                     try
27                     {
28                         var total = mq.Total();
29                         if (total > 0) { Console.WriteLine("队列条数:" + total); }
30 
31                         var result = mq.Read();
32                         if (result.Body == null) { continue; }
33                         Console.WriteLine(string.Format("接受队列{0}:{1}", result.Label, result.Body));
34                     }
35                     catch (Exception ex)
36                     { Console.WriteLine("异常信息:" + ex.Message); }
37                 }
38             }
39             catch (Exception ex)
40             {
41                 throw ex;
42             }
43             finally
44             {
45                 Console.WriteLine("释放。");
46                 mq.Dispose();
47             }
48         }

运维生成的exe,看成效:

威尼斯人6799.com 9

经过图片能收看读取队列的数额比较大家想的那么依次读取,测试用例测试RedisMQ的代码没难题;以上对封装RedisMQ的代码分享和条件搭建讲解,到那里队列工厂(MSMQ,RabbitMQ,RedisMQ)就享受完了,希望能给你带来好的救助,谢谢阅读;

http://www.bkjia.com/C\_jc/1200885.htmlwww.bkjia.comtruehttp://www.bkjia.com/C\_jc/1200885.htmlTechArticle队列工厂之RedisMQ,队列redismq
此次和豪门享受的是RedisMQ队列的用法,前两篇小说 队列工厂之(MSMQ) 和
队列工厂之RabbitMQ 分别简单介绍对应队…

此次和豪门享受的是RedisMQ队列的用法,前两篇小说队列工厂之(MSMQ)队列工厂之RabbitMQ独家简单介绍对应队列环境的搭建和常用方法的施用,加上本篇分享的RedisMQ那么就形成了咋们队列工厂”三剑客“的指标了哈哈;Redis的作用不仅局限于队列,更加多的一般都选拔它的key,value的格局来囤积session或许hash的方法存款和储蓄一些常用的数目,当然这不是本章分享的剧情(以前有些作品有讲过redis的利用情形和代码分享各位能够看下),那QueueReposity-队列工厂终极一篇截止后,作者后边分享的恐怕是netcore方面包车型客车有个别事物了,vs2017出来了差不离创立netcore项目然后发现与后边的本子有些变动,例如:没有project.json,怎么布局生成跨平台程序等难点,须求2个三个上学和品尝,网上检索的篇章还很少,全靠阅读全英文的官网来上学了哈哈;希望大家能够欣赏本篇文章,也目的在于各位多多”扫码协理“和”推荐“谢谢!

 

 

» Redis安装和RedisClient工具的运用

» Redis安装和RedisClient工具的使用

**» 封装RedisMQ队列的读和写**

**» 封装RedisMQ队列的读和写**

**» 队列工厂之RedisMQ测试用例**

**» 队列工厂之RedisMQ测试用例**

 

 

上面一步1个脚印的来分享:

下边一步1个脚印的来分享:

**» Redis安装和RedisClient工具的行使**

**» Redis安装和RedisClient工具的使用**

先是要运用redis供给下载安装Redis,那里由于以前的篇章有教书在windows下怎么搭建redis服务,所以不再赘述,各位能够点击搭建Redis服务端,并用客户端连接,因而笔者那边一贯分享怎么使用**RedisClient工具**,那工具使用起来相比较简单和便利,首先去这么些地方下载:

第三要使用redis必要下载安装Redis,那里由于在此以前的篇章有教书在windows下怎么搭建redis服务,所以不再赘言,各位能够点击搭建Redis服务端,并用客户端连接,因而小编那里直接分享怎么使用**RedisClient工具**,那工具使用起来相比不难和惠及,首先去这些地点下载:

http://dlsw.baidu.com/sw-search-sp/soft/a2/29740/RedisClient20140730.1406883096.exe

http://dlsw.baidu.com/sw-search-sp/soft/a2/29740/RedisClient20140730.1406883096.exe

安装-》打开软件,能见到如图的界面:

设置-》打开软件,能见到如图的界面:

威尼斯人6799.com 10

威尼斯人6799.com 11

-》点击“Server”-》Add-》输入3个外号,你redis服务端的ip,端口-》确认即可:

-》点击“Server”-》Add-》输入1个小名,你redis服务端的ip,端口-》确认即可:

威尼斯人6799.com 12

威尼斯人6799.com 13

以此时候你redisclient的陈设工作就成功了是否很简单啊,-》再来点击刚才创立别称-》双击打开redis的第一个数据库db0(这里正是在没有点名数据库地方时候存款和储蓄数据的地点)-》能收看您存款和储蓄的数码key:

本条时候你redisclient的配备工作就完结了是还是不是很简短啊,-》再来点击刚才成立别称-》双击打开redis的首先个数据库db0(那里正是在并未点名数据库地方时候存款和储蓄数据的地点)-》能见到你存款和储蓄的数量key:

威尼斯人6799.com 14

威尼斯人6799.com 15

只要想看有些name的多寡间接双击对应的name就行了-》这里是自家redis服务存款和储蓄的二个hash数据的截图:

比方想看有个别name的数额直接双击对应的name就行了-》那里是本人redis服务存款和储蓄的1个hash数据的截图:

威尼斯人6799.com 16

威尼斯人6799.com 17

是还是不是很有利,这几个客户端能够一贯删除你不想要的数量-》右键选中您想删除的name-》Delete即可删除:

是或不是很有利,那个客户端可以直接删除你不想要的数据-》右键选中您想删除的name-》Delete即可删除:

威尼斯人6799.com 18

威尼斯人6799.com 19

怎么,那么些RedisClient工具学会了么,是还是不是挺简单的啊;

何以,那么些RedisClient工具学会了么,是还是不是挺不难的啊;

 

 

**» 封装RedisMQ队列的读和写**

**» 封装RedisMQ队列的读和写**

到那边终于来到大家代码分享的随时了,即使QueueReposity-队列工厂早已开源了源码,那里依然单身分享1回只有RedisMQ的代码;首先成立一个名号为:QRedisMQ的class-》继承 PublicClass.ConfClass<T>-》再落到实处接口IQueue,最终就有了笔者们达成接口方法体代码:

到那里终于来到大家代码分享的随时了,固然QueueReposity-队列工厂早已开源了源码,那里依旧独立分享3回唯有RedisMQ的代码;首先创立一个名号为:QRedisMQ的class-》继承 PublicClass.ConfClass<T>-》再落到实处接口IQueue,最终就有了我们落到实处接口方法体代码:

 1     /// <summary>
 2     /// RedisMQ
 3     /// </summary>
 4     public class QRedisMQ : PublicClass.ConfClass<QRedisMQ>, IQueue
 5     {
 6         private IRedisClient redis = null;
 7 
 8         public void Create()
 9         {
10             if (string.IsNullOrWhiteSpace(this.ApiUrl) ||
11                 string.IsNullOrWhiteSpace(this.UserPwd)) { throw new Exception("创建QRedisMQ队列需要指定队列:ApiUrl,UserPwd"); }
12 
13             this.ApiKey = string.IsNullOrWhiteSpace(this.ApiKey) ? "6379" : this.ApiKey;
14             redis = redis ?? new RedisClient(this.ApiUrl, Convert.ToInt32(this.ApiKey), this.UserPwd);
15         }
16 
17         public long Total(string name = "Redis_01")
18         {
19             if (redis == null) { throw new Exception("请先创建队列连接"); }
20             if (string.IsNullOrWhiteSpace(name)) { throw new Exception("name不能为空"); }
21 
22             return redis.GetListCount(name);
23         }
24 
25         public Message Read(string name = "Redis_01")
26         {
27             if (redis == null) { throw new Exception("请先创建队列连接"); }
28             if (string.IsNullOrWhiteSpace(name)) { throw new Exception("name不能为空"); }
29 
30             var message = new Message();
31             try
32             {
33                 message.Label = name;
34                 var result = redis.DequeueItemFromList(name);
35                 if (string.IsNullOrWhiteSpace(result)) { return message; }
36                 message.Body = result;
37             }
38             catch (Exception ex)
39             {
40                 throw new Exception(ex.Message);
41             }
42             return message;
43         }
44 
45         public bool Write(string content, string name = "Redis_01")
46         {
47             if (redis == null) { throw new Exception("请先创建队列连接"); }
48             if (string.IsNullOrWhiteSpace(content) || string.IsNullOrWhiteSpace(name)) { throw new Exception("content和name不能为空"); }
49             redis.EnqueueItemOnList(name, content);
50             return true;
51         }
52 
53         public void Dispose()
54         {
55             if (redis != null)
56             {
57                 redis.Dispose();
58                 redis = null;
59             }
60         }
61 
62 
63         //public List<Message> ReadAll()
64         //{
65         //    throw new NotImplementedException();
66         //}
67     }
 1     /// <summary>
 2     /// RedisMQ
 3     /// </summary>
 4     public class QRedisMQ : PublicClass.ConfClass<QRedisMQ>, IQueue
 5     {
 6         private IRedisClient redis = null;
 7 
 8         public void Create()
 9         {
10             if (string.IsNullOrWhiteSpace(this.ApiUrl) ||
11                 string.IsNullOrWhiteSpace(this.UserPwd)) { throw new Exception("创建QRedisMQ队列需要指定队列:ApiUrl,UserPwd"); }
12 
13             this.ApiKey = string.IsNullOrWhiteSpace(this.ApiKey) ? "6379" : this.ApiKey;
14             redis = redis ?? new RedisClient(this.ApiUrl, Convert.ToInt32(this.ApiKey), this.UserPwd);
15         }
16 
17         public long Total(string name = "Redis_01")
18         {
19             if (redis == null) { throw new Exception("请先创建队列连接"); }
20             if (string.IsNullOrWhiteSpace(name)) { throw new Exception("name不能为空"); }
21 
22             return redis.GetListCount(name);
23         }
24 
25         public Message Read(string name = "Redis_01")
26         {
27             if (redis == null) { throw new Exception("请先创建队列连接"); }
28             if (string.IsNullOrWhiteSpace(name)) { throw new Exception("name不能为空"); }
29 
30             var message = new Message();
31             try
32             {
33                 message.Label = name;
34                 var result = redis.DequeueItemFromList(name);
35                 if (string.IsNullOrWhiteSpace(result)) { return message; }
36                 message.Body = result;
37             }
38             catch (Exception ex)
39             {
40                 throw new Exception(ex.Message);
41             }
42             return message;
43         }
44 
45         public bool Write(string content, string name = "Redis_01")
46         {
47             if (redis == null) { throw new Exception("请先创建队列连接"); }
48             if (string.IsNullOrWhiteSpace(content) || string.IsNullOrWhiteSpace(name)) { throw new Exception("content和name不能为空"); }
49             redis.EnqueueItemOnList(name, content);
50             return true;
51         }
52 
53         public void Dispose()
54         {
55             if (redis != null)
56             {
57                 redis.Dispose();
58                 redis = null;
59             }
60         }
61 
62 
63         //public List<Message> ReadAll()
64         //{
65         //    throw new NotImplementedException();
66         //}
67     }

此地运用的Redis的dll是引用了有关的nuget包:

那边运用的Redis的dll是引用了连带的nuget包:

威尼斯人6799.com 20

威尼斯人6799.com 21

包装的行列Redis工厂流程同样是:成立(Create)-》读(Read)|写(Write)-》释放(Dispose);有了具体的RedisMQ实现类,然后还需选用工厂形式提供的点子来创制那些类的实例:

包裹的行列Redis工厂流程同样是:创造(Create)-》读(Read)|写(Write)-》释放(Dispose);有了切实可行的RedisMQ达成类,然后还需使用工厂格局提供的艺术来成立这么些类的实例:

 1   /// <summary>
 2     /// ==================
 3     /// author:神牛步行3
 4     /// des:该列工厂开源,包括队列有MSMQ,RedisMQ,RabbitMQ
 5     /// blogs:http://www.cnblogs.com/wangrudong003/
 6     /// ==================
 7     /// 队列工厂
 8     /// </summary>
 9     public class QueueReposity<T> where T : class,IQueue, new()
10     {
11         public static IQueue Current
12         {
13             get
14             {
15                 return PublicClass.ConfClass<T>.Current;
16             }
17         }
18     }
 1   /// <summary>
 2     /// ==================
 3     /// author:神牛步行3
 4     /// des:该列工厂开源,包括队列有MSMQ,RedisMQ,RabbitMQ
 5     /// blogs:http://www.cnblogs.com/wangrudong003/
 6     /// ==================
 7     /// 队列工厂
 8     /// </summary>
 9     public class QueueReposity<T> where T : class,IQueue, new()
10     {
11         public static IQueue Current
12         {
13             get
14             {
15                 return PublicClass.ConfClass<T>.Current;
16             }
17         }
18     }

到那儿RedisMQ工厂代码就形成了,上边起先享用大家的测试用例;

到那儿RedisMQ工厂代码就到位了,上边开头大快朵颐我们的测试用例;

 

 

**» 队列工厂之RedisMQ测试用例**

**» 队列工厂之RedisMQ测试用例**

由此上边配置环境和打包自个儿的点子,那里写了四个简短的测试用例,分为Server(参加新闻队列)和Client(获取新闻队列),首先来看Server端的代码:

通过上边配置环境和打包自身的法门,那里写了一个粗略的测试用例,分为Server(参预新闻队列)和Client(获取音讯队列),首先来看Server端的代码:

 1 /// <summary>
 2     /// 队列服务端测试用例
 3     /// </summary>
 4     class Program
 5     {
 6         static void Main(string[] args)
 7         {
 8             Redis_Server();
 9 
10             // RabbitMQ_Server();
11 
12             //MSMQ_Server();
13         }
14 
15         private static void Redis_Server()
16         {
17             //实例化QRedisMQ对象
18             var mq = QueueReposity<QRedisMQ>.Current;
19 
20             try
21             {
22                 Console.WriteLine("Server端创建:RedisMQ实例");
23                 mq.Create();
24 
25                 var num = 0;
26                 do
27                 {
28                     Console.WriteLine("输入循环数量(数字,0表示结束):");
29                     var readStr = Console.ReadLine();
30                     num = string.IsNullOrWhiteSpace(readStr) ? 0 : Convert.ToInt32(readStr);
31 
32                     Console.WriteLine("插入数据:");
33                     for (int i = 0; i < num; i++)
34                     {
35                         var str = "我的编号是:" + i;
36                         mq.Write(str);
37                         Console.WriteLine(str);
38                     }
39                 } while (num > 0);
40             }
41             catch (Exception ex)
42             {
43             }
44             finally
45             {
46                 Console.WriteLine("释放。");
47                 mq.Dispose();
48             }
49             Console.ReadLine();
50         }
 1 /// <summary>
 2     /// 队列服务端测试用例
 3     /// </summary>
 4     class Program
 5     {
 6         static void Main(string[] args)
 7         {
 8             Redis_Server();
 9 
10             // RabbitMQ_Server();
11 
12             //MSMQ_Server();
13         }
14 
15         private static void Redis_Server()
16         {
17             //实例化QRedisMQ对象
18             var mq = QueueReposity<QRedisMQ>.Current;
19 
20             try
21             {
22                 Console.WriteLine("Server端创建:RedisMQ实例");
23                 mq.Create();
24 
25                 var num = 0;
26                 do
27                 {
28                     Console.WriteLine("输入循环数量(数字,0表示结束):");
29                     var readStr = Console.ReadLine();
30                     num = string.IsNullOrWhiteSpace(readStr) ? 0 : Convert.ToInt32(readStr);
31 
32                     Console.WriteLine("插入数据:");
33                     for (int i = 0; i < num; i++)
34                     {
35                         var str = "我的编号是:" + i;
36                         mq.Write(str);
37                         Console.WriteLine(str);
38                     }
39                 } while (num > 0);
40             }
41             catch (Exception ex)
42             {
43             }
44             finally
45             {
46                 Console.WriteLine("释放。");
47                 mq.Dispose();
48             }
49             Console.ReadLine();
50         }

经过:创造(Create)-》读(Read)|写(Write)-》释放(Dispose)
的流水生产线来利用大家的行列工厂,此时大家运营下那些Server端,然后分本草求真入5回参数:

透过:创建(Create)-》读(Read)|写(Write)-》释放(Dispose)
的流水生产线来使用大家的行列工厂,此时大家运转下那么些Server端,然后分本草求原入陆次参数:

威尼斯人6799.com 22

威尼斯人6799.com 23

能见到截图的文字描述,那一个测试数据插入到了redis的队列中,上边大家经过第四节说的RedisClient工具查看数据,点击队列名称如:

能看到截图的文字描述,这么些测试数据插入到了redis的行列中,上边大家通过首节说的RedisClient工具查看数据,点击队列名称如:

威尼斯人6799.com 24

威尼斯人6799.com 25

经过工具能看到我们刚刚插入的数目,然后大家来经过测试用例的client端读取队列,具体代码:

由此工具能看到大家刚刚插入的数据,然后大家来通过测试用例的client端读取队列,具体代码:

 1   /// <summary>
 2     /// 队列客户端测试用例
 3     /// </summary>
 4     class Program
 5     {
 6         static void Main(string[] args)
 7         {
 8             RedisMQ_Client();
 9 
10           //  RabbitMQ_Client();
11 
12             //MSMQ_Client();
13         }
14 
15         private static void RedisMQ_Client()
16         {
17             //实例化QRedisMQ对象
18             var mq = QueueReposity<QRedisMQ>.Current;
19             try
20             {
21                 Console.WriteLine("Client端创建:RedisMQ实例");
22                 mq.Create();
23 
24                 while (true)
25                 {
26                     try
27                     {
28                         var total = mq.Total();
29                         if (total > 0) { Console.WriteLine("队列条数:" + total); }
30 
31                         var result = mq.Read();
32                         if (result.Body == null) { continue; }
33                         Console.WriteLine(string.Format("接受队列{0}:{1}", result.Label, result.Body));
34                     }
35                     catch (Exception ex)
36                     { Console.WriteLine("异常信息:" + ex.Message); }
37                 }
38             }
39             catch (Exception ex)
40             {
41                 throw ex;
42             }
43             finally
44             {
45                 Console.WriteLine("释放。");
46                 mq.Dispose();
47             }
48         }
 1   /// <summary>
 2     /// 队列客户端测试用例
 3     /// </summary>
 4     class Program
 5     {
 6         static void Main(string[] args)
 7         {
 8             RedisMQ_Client();
 9 
10           //  RabbitMQ_Client();
11 
12             //MSMQ_Client();
13         }
14 
15         private static void RedisMQ_Client()
16         {
17             //实例化QRedisMQ对象
18             var mq = QueueReposity<QRedisMQ>.Current;
19             try
20             {
21                 Console.WriteLine("Client端创建:RedisMQ实例");
22                 mq.Create();
23 
24                 while (true)
25                 {
26                     try
27                     {
28                         var total = mq.Total();
29                         if (total > 0) { Console.WriteLine("队列条数:" + total); }
30 
31                         var result = mq.Read();
32                         if (result.Body == null) { continue; }
33                         Console.WriteLine(string.Format("接受队列{0}:{1}", result.Label, result.Body));
34                     }
35                     catch (Exception ex)
36                     { Console.WriteLine("异常信息:" + ex.Message); }
37                 }
38             }
39             catch (Exception ex)
40             {
41                 throw ex;
42             }
43             finally
44             {
45                 Console.WriteLine("释放。");
46                 mq.Dispose();
47             }
48         }

运营生成的exe,看功效:

运作生成的exe,看效果:

威尼斯人6799.com 26

威尼斯人6799.com 27

透过图形能看出读取队列的数额相比大家想的那么依次读取,测试用例测试RedisMQ的代码没难点;以上对封装RedisMQ的代码分享和条件搭建讲解,到那边队列工厂(MSMQ,RabbitMQ,RedisMQ)就享受完了,希望能给您带来好的协理,多谢阅读;

经过图片能来看读取队列的数量相比较大家想的那么依次读取,测试用例测试RedisMQ的代码没难题;以上对封装RedisMQ的代码分享和环境搭建讲解,到那边队列工厂(MSMQ,RabbitMQ,RedisMQ)就享受完了,希望能给你带来好的扶持,多谢阅读;

相关文章