12345678910111213141516171819202122232425262728293031323334353637383940414243 |
- using FreeRedis;
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text;
- using System.Threading.Tasks;
- namespace WCS.DebugTool
- {
- class Program
- {
- static void Main(string[] args)
- {
- RedisClient redis = null;
- while (true)
- {
- if (redis == null)
- {
- Console.WriteLine("请输入订阅关键字(逗号分隔):");
- redis = new RedisClient(Properties.Settings.Default.Redis);
- var key = Console.ReadLine();
- var arr = key.Split(',');
- redis.PSubscribe(arr, (channel, msg) =>
- {
- Console.Write(string.Format("对象:{0};", channel));
- Console.WriteLine(string.Format("消息:{0}", msg));
- });
- }
- else
- {
- if (Console.ReadKey().Key == ConsoleKey.Escape)
- {
- Console.Clear();
- redis.Dispose();
- redis = null;
- }
- }
- }
-
- }
- }
- }
|