1

使用包装器后,队列中的大容量,得到这个错误:

最初保存时没有错误,几分钟后,它得到了这个错误,我发现 dump.rdb 保持在 1 KB 大小。大容量保存消息后似乎没有变化

由于对象的当前状态,操作无效

RedisClass.GetInstnace().Store(Msg)

if (SQLQueue == null)
  SQLQueue = new ConcurrentQueue<BMsg>();
SQLQueue.TryDequeue(out BloomberMsg);
if (BloomberMsg != null)
{
  RedisClass.GetInstnace().Store(BloomberMsg);
  RedisClass.GetInstnace().Save();
}

public class BloomMsg
        {
            public Message msg  {get; set;}
            public String TypeOfMsg { get; set; }

        }

foreach (Message msg in eventObj)
                {
                    logger.Debug(msg.ToString());
                    if (SQLQueue == null)
                        SQLQueue = new ConcurrentQueue<BloomMsg>();

                    BloomMsg b = new BloomMsg();
                    b.msg = msg;
                    b.TypeOfMsg = TypeOfMsg;
                    SQLQueue.Enqueue(b);

                }
4

0 回答 0