QpChannel add property:AuthenticateQuestion

Author: aaasoft

Quick.Protocol/QpChannel.cs

@@ -86,6 +86,10 @@ protected set
         /// 通道名称
         /// </summary>
         public abstract string ChannelName { get; }
+        /// <summary>
+        /// 认证问题
+        /// </summary>
+        public string AuthenticateQuestion { get; protected set; }
 
         //长整型数字的一半，统计大于这个数时，统计计数归零，防止溢出
         private long LONG_HALF_MAX_VALUE = long.MaxValue / 2;

Quick.Protocol/QpClient.cs

@@ -46,14 +46,15 @@ public async Task ConnectAsync()
             {
                 InstructionIds = Options.InstructionSet.Select(t => t.Id).ToArray()
             });
+            AuthenticateQuestion = repConnect.Question;
 
             //如果服务端使用的缓存大小与客户端不同，则设置缓存大小为与服务端同样的大小
             if (BufferSize != repConnect.BufferSize)
                 ChangeBufferSize(repConnect.BufferSize);
-
+            
             var repAuth = await SendCommand(new Commands.Authenticate.Request()
             {
-                Answer = CryptographyUtils.ComputeMD5Hash(repConnect.Question + Options.Password)
+                Answer = CryptographyUtils.ComputeMD5Hash(AuthenticateQuestion + Options.Password)
             });
 
             var repHandShake = await SendCommand(new Commands.HandShake.Request()

Quick.Protocol/QpServerChannel.cs

@@ -16,7 +16,6 @@ public class QpServerChannel : QpChannel
         private CancellationTokenSource cts;
         private QpServerOptions options;
         private string channelName;
-        private string question;
         //通过认证后，才允许使用的命令执行管理器列表
         private List<CommandExecuterManager> authedCommandExecuterManagerList = null;
         //通过认证后，才允许使用的通知处理器管理器列表
@@ -97,18 +96,17 @@ private Commands.Connect.Response connect(QpChannel handler, Commands.Connect.Re
                         throw new CommandException(255, $"Unknown instruction: {id}");
                 }
             }
-
-            question = Guid.NewGuid().ToString("N");
+            AuthenticateQuestion = Guid.NewGuid().ToString("N");
             return new Commands.Connect.Response()
             {
                 BufferSize = options.BufferSize,
-                Question = question
+                Question = AuthenticateQuestion
             };
         }
 
         private Commands.Authenticate.Response authenticate(QpChannel handler, Commands.Authenticate.Request request)
         {
-            if (Utils.CryptographyUtils.ComputeMD5Hash(question + options.Password) != request.Answer)
+            if (Utils.CryptographyUtils.ComputeMD5Hash(AuthenticateQuestion + options.Password) != request.Answer)
             {
                 Task.Delay(1000).ContinueWith(t =>
                 {