.NET Core实现简单的Redis Client框架_实用技巧_

set a 12 set b 12 set c 12 MGET abc

本地:0>SET a 12 "OK" 本地:0>SET b 12 "OK" 本地:0>SET c 12 "OK" 本地:0>MGET a b c 1) "12" 2) "12" 3) "12"

using System; using System.Linq; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; using System.Threading.Tasks; namespace ConsoleApp { class Program { static async Task Main(string[] args) { IPAddress IP = IPAddress.Parse("127.0.0.1"); IPEndPoint IPEndPoint = new IPEndPoint(IP, 6379); Socket client = new Socket(IP.AddressFamily, SocketType.Stream, ProtocolType.Tcp); await client.ConnectAsync(IPEndPoint); if (!client.Connected) { Console.WriteLine("连接 Redis 服务器失败！"); Console.Read(); } Console.WriteLine("恭喜恭喜，连接 Redis 服务器成功"); // 后台接收消息 new Thread(() => { while (true) { byte[] data = new byte[100]; int size = client.Receive(data); Console.WriteLine(); Console.WriteLine(Encoding.UTF8.GetString(data)); Console.WriteLine(); } }).Start(); while (true) { Console.Write("$> "); string command = Console.ReadLine(); // 发送的命令必须以 \r\n 结尾 int size = client.Send(Encoding.UTF8.GetBytes(command + "\r\n")); Thread.Sleep(100); } } } }

$> SET a 123456789 +OK $> SET b 123456789 +OK $> SET c 123456789 +OK $> MGET a b c *3 $9 123456789 $9 123456789 $9 123456789

 /// 
 /// RESP Response 类型 /// 
 public static class RedisValueType { public const byte Errors = (byte)'-'; public const byte SimpleStrings = (byte)'+'; public const byte Integers = (byte)':'; public const byte BulkStrings = (byte)'$'; public const byte Arrays = (byte)'*'; public const byte R = (byte)'\r'; public const byte N = (byte)'\n'; }

 /// 
 /// 自定义消息队列状态机 /// 
 public abstract class MessageStrace { protected MessageStrace() { TaskCompletionSource = new TaskCompletionSource(); Task = TaskCompletionSource.Task; } protected readonly TaskCompletionSource TaskCompletionSource; /// 
 /// 标志任务是否完成，并接收 redis 响应的字符串数据流 /// 
 public Task Task { get; private set; } /// 
 /// 接收数据流 /// 
 ///  /// 实际长度 public abstract void Receive(MemoryStream stream, int length); /// 
 /// 响应已经完成 /// 
 ///  protected void SetValue(string data) { TaskCompletionSource.SetResult(data); } /// 
 /// 解析 $ 或 * 符号后的数字，必须传递符后后一位的下标 /// 
 ///  /// 解析到的位置 ///  protected int BulkStrings(ReadOnlySpan data, ref int index) { int start = index; int end = start; while (true) { if (index + 1 >= data.Length) throw new ArgumentOutOfRangeException("溢出"); // \r\n if (data[index].CompareTo(RedisValueType.R) == 0 && data[index + 1].CompareTo(RedisValueType.N) == 0) { index += 2; // 指向 \n 的下一位 break; } end++; index++; } // 截取 $2 *3 符号后面的数字 return Convert.ToInt32(Encoding.UTF8.GetString(data.Slice(start, end - start).ToArray())); } }

using System; using System.Collections.Generic; using System.Text; using System.Threading.Tasks; namespace CZGL.RedisClient { /// 
 /// 命令发送模板 /// 
 public abstract class CommandClient where T : CommandClient { protected RedisClient _client; protected CommandClient() { } protected CommandClient(RedisClient client) { _client = client; } /// 
 /// 复用 /// 
 ///  ///  internal virtual CommandClient Init(RedisClient client) { _client = client; return this; } /// 
 /// 请求是否成功 /// 
 /// 响应的消息 ///  protected bool IsOk(string value) { if (value[0].CompareTo('+') != 0 || value[1].CompareTo('O') != 0 || value[2].CompareTo('K') != 0) return false; return true; } /// 
 /// 发送命令 /// 
 /// 发送的命令 /// 数据类型客户端 ///  protected Task SendCommand(string command, out TStrace strace) where TStrace : MessageStrace, new() { strace = new TStrace(); return _client.SendAsync(strace, command); } } }

using System; using System.Collections.Concurrent; using System.Collections.Generic; using System.IO; using System.Net; using System.Net.Sockets; using System.Runtime.CompilerServices; using System.Text; using System.Threading; using System.Threading.Tasks; namespace CZGL.RedisClient { /// 
 /// Redis 客户端 /// 
 public class RedisClient { private readonly IPAddress IP; private readonly IPEndPoint IPEndPoint; private readonly Socket client; //private readonly Lazy stringClient; //private readonly Lazy hashClient; //private readonly Lazy listClient; //private readonly Lazy setClient; //private readonly Lazy sortedClient; // 数据流请求队列 private readonly ConcurrentQueue StringTaskQueue = new ConcurrentQueue(); public RedisClient(string ip, int port) { IP = IPAddress.Parse(ip); IPEndPoint = new IPEndPoint(IP, port); //stringClient = new Lazy(() => new StringClient(this)); //hashClient = new Lazy(() => new HashClient(this)); //listClient = new Lazy(() => new ListClient(this)); //setClient = new Lazy(() => new SetClient(this)); //sortedClient = new Lazy(() => new SortedClient(this)); client = new Socket(IP.AddressFamily, SocketType.Stream, ProtocolType.Tcp); } /// 
 /// 开始连接 Redis /// 
 public async Task ConnectAsync() { await client.ConnectAsync(IPEndPoint); new Thread(() => { ReceiveQueue(); }) { IsBackground = true }.Start(); return client.Connected; } /// 
 /// 发送一个命令，将其加入队列 /// 
 ///  ///  ///  internal Task SendAsync(MessageStrace task, string command) { var buffer = Encoding.UTF8.GetBytes(command + "\r\n"); var result = client.SendAsync(new ArraySegment(buffer, 0, buffer.Length), SocketFlags.None); StringTaskQueue.Enqueue(task); return result; } /* Microsoft 对缓冲区输入不同大小的数据，测试响应时间。 1024 - real 0m0,102s; user 0m0,018s; sys 0m0,009s 2048 - real 0m0,112s; user 0m0,017s; sys 0m0,009s 8192 - real 0m0,163s; user 0m0,017s; sys 0m0,007s 256 - real 0m0,101s; user 0m0,019s; sys 0m0,008s 16 - real 0m0,144s; user 0m0,016s; sys 0m0,010s .NET Socket，默认缓冲区的大小为 8192 字节。 Socket.ReceiveBufferSize: An Int32 that contains the size, in bytes, of the receive buffer. The default is 8192. 但响应中有很多只是 "+OK\r\n" 这样的响应，并且 MemoryStream 刚好默认是 256(当然，可以自己设置大小)，缓冲区过大，浪费内存； 超过 256 这个大小，MemoryStream 会继续分配新的 256 大小的内存区域，会消耗性能。 BufferSize 设置为 256 ，是比较合适的做法。 */ private const int BufferSize = 256; /// 
 /// 单线程串行接收数据流，调出任务队列完成任务 /// 
 private void ReceiveQueue() { while (true) { MemoryStream stream = new MemoryStream(BufferSize); // 内存缓存区 byte[] data = new byte[BufferSize]; // 分片，每次接收 N 个字节 int size = client.Receive(data); // 等待接收一个消息 int length = 
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                
                

                

                                            
上一篇：.NET Core跨平台资源监控工具CZGL.SystemInfo用法_实用技巧_
                                                                
下一篇：.net项目使用日志框架log4net_实用技巧_