ServiceStack Redis erros: "Неожиданный ответ: *", "Ошибка протокола: ожидается" $ ", получено" C "", потеряно соединение и т. Д. "

Question

Я получаю много ошибок при работе с редисом.

Это мой конфиг:

container.Register<IRedisClientsManager>(c => new PooledRedisClientManager("localhost:6379"));
container.Register(c => c.Resolve<IRedisClientsManager>().GetCacheClient());

container.Register(new GameDispatchService(container.Resolve<IRedisClientsManager>()));

Это класс, который изменяет данные в радиусах

public class GameDispatchService {
        private readonly IRedisClientsManager redisManager;
        private Timer mTimer;

        public GameDispatchService(IRedisClientsManager redisManager) {
            this.redisManager = redisManager;

            mTimer = new Timer();

            mTimer.Elapsed += new ElapsedEventHandler(OnTimedEvent);
            mTimer.Interval = 1000;
            mTimer.Enabled = true;
        }

        private void OnTimedEvent(object sender, ElapsedEventArgs e) {
            mTimer.Stop();

            try {
                using (IRedisClient cacheClient = redisManager.GetClient()) {
                    var sessionPattern = "game:Created*";
                    var tSessionKeys = cacheClient.GetKeysStartingWith(sessionPattern).ToList();

                    if (!tSessionKeys.IsNullOrEmpty()) {
                        var list = cacheClient.GetAll<GameCachModel>(tSessionKeys);

                        foreach (var item in list) {
                            var lastKey = item.Key;
                            var newKey = $"game:{GameStatuses.Waiting}:{item.Value.GameNumber}";
                            item.Value.Status = GameStatuses.Waiting;

                            cacheClient.Remove(lastKey);
                            cacheClient.Add(newKey, item.Value);
                        }
                    }
                }
            } catch (Exception ex) {
                 var t = ex.Message;
                t.PrintDump();
            } finally {
                mTimer.Start();
            }

        }

        .......
    }

и поэтому я получаю данные от Redis

    List<GameRetModel> gamesList = new List<GameRetModel>();

                try {
                    using (var cacheClient = this.GetCacheClient()) {
                        var sessionPattern = "game:Waiting*";
                        var tSessionKeys = cacheClient.GetKeysStartingWith(sessionPattern)?.ToList();

                        if (!tSessionKeys.IsNullOrEmpty()) {
                            var list = cacheClient.GetAll<GameCachModel>(tSessionKeys);

                            foreach (var item in list.Values) {
                                if (item.Rate >= request.MinVal && item.Rate <= request.MaxVal) {
                                    gamesList.Add(new GameRetModel {
                                        Author = item.Author,
                                        Avatar = item.Avatar,
                                        GameNumber = item.GameNumber,
                                        Count = item.Users.Count,
                                        Rate = item.Rate
                                    });
                                }
                            }
                        }
                    }
                } catch (Exception e) {
                    e.Message.PrintDump();
                    return new { error = true };
                }

                return new { error = false, gamesList = gamesList };
}

и я получаю много ошибок, я искал в Интернете, и я понимаю, что проблема с несколькими потоками, но я не могу решить эту проблему.

Пожалуйста, помогите, если вы знаете, как сделать это правильно.

ServiceStack версия 4.5.5 Redis 3.0.501

Спасибо!

Я получаю следующую ошибку:

1. Сообщение: Ошибка протокола: ожидалось '$', получено 'C'

Трассировка:

в ServiceStack.Redis.RedisNativeClient.ReadDeeplyNestedMultiDataItem()
   в ServiceStack.Redis.RedisNativeClient.ReadDeeplyNestedMultiData()
   в ServiceStack.Redis.RedisNativeClient.SendReceive[T](Byte[][] cmdWithBinaryArgs, Func`1 fn, Action`1 completePipelineFn, Boolean sendWithoutRead)
   в ServiceStack.Redis.RedisNativeClient.SendExpectDeeplyNestedMultiData(Byte[][] cmdWithBinaryArgs)
   в ServiceStack.Redis.RedisNativeClient.SendExpectScanResult(Byte[] cmd, Byte[][] args)
   в ServiceStack.Redis.RedisNativeClient.Scan(UInt64 cursor, Int32 count, String match)
   в ServiceStack.Redis.RedisClient.<ScanAllKeys>d__159.MoveNext()
   в System.Collections.Generic.List`1..ctor(IEnumerable`1 collection)
   в System.Linq.Enumerable.ToList[TSource](IEnumerable`1 source)
   в loto.ServiceInterface.LotoServices.Post(GetGames request) в D:\Documents\Visual Studio 2015\Projects\loto\loto\loto.ServiceInterface\LotoServices.cs:строка 144

2. Сообщение: неожиданный ответ: *2

Трассировка:

в ServiceStack.Redis.RedisNativeClient.ParseSingleLine(String r)
   в ServiceStack.Redis.RedisNativeClient.ReadData()
   в ServiceStack.Redis.RedisNativeClient.SendReceive[T](Byte[][] cmdWithBinaryArgs, Func`1 fn, Action`1 completePipelineFn, Boolean sendWithoutRead)
   в ServiceStack.Redis.RedisNativeClient.SendExpectData(Byte[][] cmdWithBinaryArgs)
   в ServiceStack.Redis.RedisNativeClient.Set(String key, Byte[] value, Boolean exists, Int32 expirySeconds, Int64 expiryMs)
   в ServiceStack.Redis.RedisClient.<>c__DisplayClass21_0`1.<Add>b__0(RedisClient r)
   в ServiceStack.Redis.RedisClient.Exec[T](Func`2 action)
   в ServiceStack.Redis.RedisClient.Add[T](String key, T value)
   в ServiceStack.Redis.RedisClientManagerCacheClient.Add[T](String key, T value)
   в loto.ServiceInterface.LotoServices.Post(CreateGame request) в D:\Documents\Visual Studio 2015\Projects\loto\loto\loto.ServiceInterface\LotoServices.cs:строка 42

3. Сообщение: Неизвестный ответ на целочисленный ответ: 422

Трассировка:

 в ServiceStack.Redis.RedisNativeClient.ReadLong()
   в ServiceStack.Redis.RedisNativeClient.SendReceive[T](Byte[][] cmdWithBinaryArgs, Func`1 fn, Action`1 completePipelineFn, Boolean sendWithoutRead)
   в ServiceStack.Redis.RedisNativeClient.SendExpectLong(Byte[][] cmdWithBinaryArgs)
   в ServiceStack.Redis.RedisNativeClient.Del(Byte[] key)
   в ServiceStack.Redis.RedisClient.Remove(String key)
   в ServiceStack.Redis.RedisClientManagerCacheClient.Remove(String key)
   в loto.ServiceInterface.GameDispatchService.OnTimedEvent(Object sender, ElapsedEventArgs e) в D:\Documents\Visual Studio 2015\Projects\loto\loto\loto.ServiceInterface\GameDispatchService.cs:строка 67

У меня разные данные так много ошибок

Answer 1

ICacheClient является синглтоном, он не должен утилизироваться, поэтому его не следует использовать, например:

using (var cacheClient = this.GetCacheClient()) {

Поскольку он зарегистрирован как ICacheClient вместо этого вы можете решить это с помощью:

var cacheClient = HostContext.Cache;

Который является просто оберткой для:

var cacheClient = HostContext.TryResolve<ICacheClient>();