3

我正在使用最新的 protobuf-net lib 和 protobuf-net memcache 提供程序。我需要序列化自定义类型 MyClass 的列表

[ProtoContract]
public class MyClass{
  [ProtoMember(1)]
  public int a {get; set;}
  [ProtoMember(2)]
  public int b {get; set;}
}

所以我需要存储/检索：

List<MyClass> myList

当值通过 protobuf 存储然后从缓存中检索时一切顺利。但是，如果值存储在 memcache 中（以正确的 protobuf 格式），即来自另一个线程/应用程序，然后由于类型字段的 NullReferenceExceptions 从缓存反序列化中检索该值失败。

因此，当首先设置时，序列化值的类型存储在 typeCache 变量中，然后从该字典中检索。但是，如果值存在于内存缓存中但未在当前线程中设置，则 typeCache var 不包含该类型并在反序列化时抛出 NullReference。

有没有办法解决这个问题或一些解决方法？

更深入的调查：enyim 的序列化/反序列化过程在ProtoTranscoder.cs. 它包含NetTranscoder具有Dictionary<ArraySegment<byte>, Type> typeCache. 因此，当 set 第一个序列化类型（即List<MyClass>）存储在typeCachevar 中时，一切顺利。如果值存在于内存缓存中，但未在当前应用程序/线程中设置反序列化，则通过此代码检索它：

type = Type.GetType(enc.GetString(buffer, keyOffset, len));
byte[] standaloneBuffer = new byte[len];
Buffer.BlockCopy(buffer, keyOffset, standaloneBuffer, 0, len);
key = new ArraySegment<byte>(standaloneBuffer, 0, len);
sync.EnterWriteLock();
try
   {
        // did somebody beat us to it?
        Type tmp;
        if (typeCache.TryGetValue(key, out tmp)) return tmp;
        typeCache.Add(key, type);
        return type;   <-- Here it returns null, if type not present in typeCache
   }
finally
   {
        sync.ExitWriteLock();
   }

要重现该错误：

  1. 项目清单
  2. 在内存缓存中创建和存储一些列表（使用配置的 prototranscoder）
  3. 重新启动当前应用程序（或启动另一个线程）
  4. 尝试从那些“另一个线程”的 memcache 中按键获取值

这是此错误的堆栈跟踪：[ArgumentNullException：值不能为空。参数名称：类型]

   ProtoBuf.Meta.TypeModel.PrepareDeserialize(Object value, Type& type) in c:\Dev\protobuf-net\protobuf-net\Meta\TypeModel.cs:592
   ProtoBuf.Meta.TypeModel.Deserialize(Stream source, Object value, Type type, SerializationContext context) in c:\Dev\protobuf-net\protobuf-net\Meta\TypeModel.cs:577
   ProtoBuf.Caching.Enyim.NetTranscoder.Enyim.Caching.Memcached.ITranscoder.Deserialize(CacheItem item) in c:\Users\akureniov\work\protobuf-net-1\protobuf-net.Enyim\protobuf-net.Enyim\ProtoTranscoder.cs:109
   Enyim.Caching.MemcachedClient.PerformTryGet(String key, UInt64& cas, Object& value) +179
   Enyim.Caching.MemcachedClient.TryGet(String key, Object& value) +42
   Enyim.Caching.MemcachedClient.Get(String key) +15
4

2 回答 2

3

在Marc Gravell的帮助下，我们在 ProtoTranscoder.cs 的类型修整中发现了“错误”：NetTranscoder: void WriteType(MemoryStream ms, Type type)。此代码块导致错误，因为它削减了太多：

int i = typeName.IndexOf(','); // first split
if (i >= 0) { i = typeName.IndexOf(',', i + 1); } // second split
if (i >= 0) { typeName = typeName.Substring(0, i); } // extract type/assembly only

它适用于简单类型，但在 List、Dictionary 等上失败。

为避免这种情况，最好使用正则表达式来减少不必要的信息（如文化、publickkeytoken 等）。所以这是一个替换（需要用这个替换上面的行），安静粗鲁，但在大多数情况下都有效：

typeName = Regex.Replace(typeName, @", Version=\d+.\d+.\d+.\d+", string.Empty);
typeName = Regex.Replace(typeName, @", Culture=\w+", string.Empty);
typeName = Regex.Replace(typeName, @", PublicKeyToken=\w+", string.Empty);

此正则表达式不会剪切类型的程序集，这是自定义类型所必需的。但是对于标准类型，mscorlib在大多数情况下可以通过添加另一行来安全地删除它：

typeName = Regex.Replace(typeName, @", mscorlib", string.Empty);
于 2013-02-19T13:48:37.583 回答
0

我认为 memcache 不理解ProtoContract，尝试将它们标记为DataContract

于 2013-02-13T20:22:10.683 回答