使用包装器后,队列中的大容量,得到这个错误:
最初保存时没有错误,几分钟后,它得到了这个错误,我发现 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);
}