上篇说给大家来写C#和Java的方案，最近工作也比较忙，迟到了一些，我先给大家补上C#的方案。
二、使用的插件
HangFire
一个开源的.NET任务调度框架，最大特点在于内置提供集成化的控制台,方便后台查看及监控，支持多种存储方式；在方案中主要使用定时任务做补偿机制，后期可能会封装一些，能通过页面的形式直接添加任务；
NLog
日志记录框架，方案中使用记录日志，后期可能回集成多个日志框架；
Autofac
依赖注入的框架，应该不用做过多介绍；
SqlSugar
ORM框架，这个从刚开始我就在使用了，在现在公司没有推行起来，不过在上两家公司都留下的遗产，据说还用的可以，当然我还是最佩服作者；
Polly
容错服务框架，类似于Java下的Hystrix，主要是为了解决分布式系统中，系统之间相互依赖，可能会因为多种因素导致服务不可用的而产生的一套框架，支持服务的超时重试、限流、熔断器等等;
RabbitMQ.Client
官方提供的C#连接RabbitMQ的SDK;
三、方案
模拟一个简单订单下单的场景，没有进行具体的实现。同时建议下游服务不要写在web端，最好以服务的形式奔跑，代码中是Web端实现的，大家不要这么搞。整体上还是实现了之前提到的两种方案：一是入库打标，二是延时队列(这块没有进行很好的测试，但是估计也没有很大的问题)；当然也是有一些特点:RabbitMQ宕机情况下无需重启服务，网络异常的情况下也可以进行断线重连。接下来聊下代码和各方插件在系统中的具体应用:
项目结构:
RabbitMQExtensions：
采用Autofac按照单例的形式注入，采用Polly进行断线重连，也开启了自身断线重连和心跳检测机制，配置方面采用最简单的URI规范进行配置，有兴趣参考下官方，整体上这块代码还相对比较规范，以后可能也不会有太多调整；
1 /// <summary> 2 /// rabbitmq持久化连接 3 /// </summary> 4 public interface IRabbitMQPersistentConnection 5 { 6 bool IsConnected { get; } 7 8 bool TryConnect(); 9 10 IModel CreateModel(); 11 } 12 /// <summary> 13 /// rabbitmq持久化连接实现 14 /// </summary> 15 public class DefaultRabbitMQPersistentConnection : IRabbitMQPersistentConnection 16 { 17 private readonly IConnectionFactory connectionFactory; 18 private readonly ILogger<DefaultRabbitMQPersistentConnection> logger; 19 20 private IConnection connection; 21 22 private const int RETTRYCOUNT = 6; 23 24 private static readonly object lockObj = new object(); 25 public DefaultRabbitMQPersistentConnection(IConnectionFactory connectionFactory, ILogger<DefaultRabbitMQPersistentConnection> logger) 26 { 27 this.connectionFactory = connectionFactory; 28 this.logger = logger; 29 } 30 31 public bool IsConnected 32 { 33 get 34 { 35 return connection != null && connection.IsOpen; 36 } 37 } 38 39 public void Cleanup() 40 { 41 try 42 { 43 connection.Dispose(); 44 connection.Close(); 45 connection = null; 46 47 } 48 catch (IOException ex) 49 { 50 logger.LogCritical(ex.ToString()); 51 } 52 } 53 54 public IModel CreateModel() 55 { 56 if (!IsConnected) 57 { 58 connection.Close(); 59 throw new InvalidOperationException("连接不到rabbitmq"); 60 } 61 return connection.CreateModel(); 62 } 63 64 public bool TryConnect() 65 { 66 logger.LogInformation("RabbitMQ客户端尝试连接"); 67 68 lock (lockObj) 69 { 70 if (connection == null) 71 { 72 var policy = RetryPolicy.Handle<SocketException>() 73 .Or<BrokerUnreachableException>() 74 .WaitAndRetry(RETTRYCOUNT, retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)), (ex, time) => 75 { 76 logger.LogWarning(ex.ToString()); 77 }); 78 79 policy.Execute(() => 80 { 81 connection = connectionFactory.CreateConnection(); 82 }); 83 } 84 85 86 87 if (IsConnected) 88 { 89 connection.ConnectionShutdown += OnConnectionShutdown; 90 connection.CallbackException += OnCallbackException; 91 connection.ConnectionBlocked += OnConnectionBlocked; 92 93 logger.LogInformation($"RabbitMQ{connection.Endpoint.HostName}获取了连接"); 94 95 return true; 96 } 97 else 98 { 99 logger.LogCritical("无法创建和打开RabbitMQ连接"); 100 101 return false; 102 } 103 } 104 } 105 106 107 private void OnConnectionBlocked(object sender, ConnectionBlockedEventArgs e) 108 { 109 110 logger.LogWarning("RabbitMQ连接异常,尝试重连..."); 111 112 Cleanup(); 113 TryConnect(); 114 } 115 116 private void OnCallbackException(object sender, CallbackExceptionEventArgs e) 117 { 118 119 logger.LogWarning("RabbitMQ连接异常,尝试重连..."); 120 121 Cleanup(); 122 TryConnect(); 123 } 124 125 private void OnConnectionShutdown(object sender, ShutdownEventArgs reason) 126 { 127 128 logger.LogWarning("RabbitMQ连接异常,尝试重连..."); 129 130 Cleanup(); 131 TryConnect(); 132 } 133 }