这次与我们大快朵颐的是RedisMQ队排的用法,前少首作品排工厂的(MSMQ)班工厂之RabbitMQ分级简单介绍对许队列环境的搭建与常用方法的运用,加上本篇分享的RedisMQ那么尽管完事了咋们队列工厂”三剑客“的目的了哄;Redis的用意不仅局限为队列,更多之形似都下其的key,value的样式来存储session或者hash的措施囤一些常用的数额,当然就不是本章分享的情节(往日有些随笔发生说话过redis的运用境况以及代码分享各位可看下),这QueueReposity-队列工厂说到底一首了晚,笔者前边分享的或是是netcore方面的组成部分事物了,vs2017出来了简便创立netcore项目下察觉同在此以前的本有些改,例如:没有project.json,怎么安排生成跨平台程序等题材,需要一个一个读及品尝,网上检索的稿子还老少,全因看全英文的官网来读书了哄;希望我们能欣赏本篇作品,也想各位多多”扫码扶助“和”推荐“谢谢!

 

» Redis安装及RedisClient工具的应用

**» 封装RedisMQ队排的念与描绘**

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

 

下边一步一个脚印的来享受:

**» Redis安装与RedisClient工具的用**

首先要利用redis需要下载安装Redis,这里由于在此之前的篇章暴发教学在windows下怎么搭建redis服务,所以不再赘述,各位好点击搭建Redis服务端,并就此客户端连接,因而我此一向分享怎么下**RedisClient工具**,那家伙使用起来相比简单和有利,首先去是地址下充斥:

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

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

图片 1

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

图片 2

其一时候你redisclient的部署工作就成功了凡匪是很粗略啊,-》再来点击刚才创立昵称-》双击打开redis的率先单数据库db0(这里虽是于尚未点名数据库地方上存储数据的地点)-》能阅览您存储的数据key:

图片 3

而想看有name的数码直接双击对应之name就举办了-》这里是自己redis服务存储的一个hash数据的截图:

图片 4

大凡匪是坏有益于,这些客户端可直接删除你不牵记使之数码-》右键选中您想抹的name-》Delete即可删除:

图片 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包:

图片 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测试用例**

通过地点配置环境和打包好之措施,这里描绘了一个简单的测试用例,分为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端,然后分别录入4不成参数:

图片 7

可知来看截图的文字描述,这个测试数据插入到了redis的排中,下面我们因此第一省说之RedisClient工具查看数据,点击队名次称如:

图片 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,看效用:

图片 9

透过图形能望读取队列的数据比我们记挂的这样依次读取,测试用例测试RedisMQ的代码没问题;以上对封装RedisMQ的代码分享和环境搭建讲解,到此地队列工厂(MSMQ,RabbitMQ,RedisMQ)就享受了了,希望会被你带来好之援救,谢谢阅读;

相关文章

网站地图xml地图