使用多線程設置redis時發生未知命令錯誤

Question

我正在使用C＃客戶端ServiceStack.Redis與Redis進行通信。

除了少數要求一切正常，但是當我得到LoadRunner的要求或使用多線程提出要求，我得到一些錯誤說我使用了錯誤的命令。

我檢查錯誤，看起來它切斷了命令，或者它搞砸了。

這是我的代碼，很簡單。有沒有人遇到過這個問題？我使用多線程調用Push方法時發生錯誤。

public class ImpresstionQueueService : IQueueService<InsertImpressionRequest> 
    { 
     private string _queueName; 
     private string _host; 
     private static IRedisClient redisClient = new RedisClient(ConfigHost); 
     private static string ConfigHost 
     { 
      get 
      { 
       return ConfigurationManager.AppSettings.Get("redis_host"); 
      } 
     } 
     private string Host 
     { 
      get 
      { 
       if (!string.IsNullOrEmpty(_host)) 
        return _host; 
       else 
       { 
        return ConfigurationManager.AppSettings.Get("redis_host"); 
       } 
      } 
     } 
     public ImpresstionQueueService(string queue_name) 
     { 
      this._queueName = queue_name; 
     } 

     public ImpresstionQueueService(string host, string queu_name) 
     { 
      this._queueName = queu_name; 
      this._host = host; 
     } 

     #region IQueueService<InsertImpressionRequest> Members 
     class testData 
     { 

     } 
     public int Push(InsertImpressionRequest value) 
     { 
      try 
      { 
       //using (var redisClient = new RedisClient(this.Host)) 
       { 
        //ser 
        string ser_value = TypeSerializer.SerializeToString<InsertImpressionRequest>(value); 
        //push 
        redisClient.AddItemToList(this._queueName, ser_value);//here will be error 

       } 
      } 
      catch (Exception ex) 
      { 
       HLogger.GetLogger("RedisLogger").Error(ex.Message + ex.StackTrace); 
      } 
      //throw new NotImplementedException(); 
      return 1; 
     } 

     public InsertImpressionRequest Pop() 
     { 
      InsertImpressionRequest request = null; 
      //using (var redisClient = new RedisClient(this.Host)) 
      { 
       string pop_string_value = redisClient.PopItemFromList(this._queueName); 
       //deseri 
       if (pop_string_value != null) 
       { 
        request = TypeSerializer.DeserializeFromString<InsertImpressionRequest>(pop_string_value); 
       } 
      } 
      return request; 
     } 

     #endregion 
    } 

Answer 1

您可能在多個線程中同時使用相同的Redis連接。這兩個線程都可能發送命令或同時等待回覆。發生這種情況時，一個線程會收到針對其他線程的數據。這會導致你的錯誤。

如果您爲每個線程使用一個Redis客戶端（而不是每個ImpresstionQueueService的一個客戶端），則每個線程可以同時發送命令而不會相互干擾。

或者，您可以爲單個請求（您在錯誤位置上方註釋掉）創建一個客戶端。這種替代方法的缺點是每次都有一個新連接的開銷（可能很大或很小或不明顯）。