mengjian
/
Kingo.XxlJob.Core
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

✨ test

Browse Source
pull/1/head
假正经哥哥 7 years ago
parent 6bd8ee846c
commit b272b54fbd
9 changed files with 167 additions and 66 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 9
      samples/HessianReader/HessianReader.csproj
  2. 28
      samples/HessianReader/Program.cs
  3. 4
      src/Hessian.NET/HessianInputReader.cs
  4. 8
      src/Hessian.NET/HessianSerializationScheme.cs
  5. 100
      src/Hessian.NET/ListElement.cs
  6. 66
      src/Hessian.NET/ListTypeResolver.cs
  7. 6
      src/Hessian.NET/ObjectElement.cs
  8. 10
      src/Hessian.NET/TypeResolver.cs
  9. 2
      src/Hessian/PeekStream.cs

9
samples/HessianReader/HessianReader.csproj
Unescape View File

@ -16,4 +16,13 @@
</Reference>
</ItemGroup>
<ItemGroup>
<None Update="1547620263.dat">
<CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
</None>
<None Update="1547621183.dat">
<CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
</None>
</ItemGroup>
</Project>

28
samples/HessianReader/Program.cs
Unescape View File

@ -24,29 +24,27 @@ namespace HessianReader
Console.WriteLine("---------------------------------------------------------------");
var serializer = new DataContractHessianSerializer(typeof (RpcRequest));
using (var stream1 = new MemoryStream(myBinary))
{
var ds = new Hessian.Deserializer(stream1);
Hessian.ClassDef def = ds.ReadClassDefinition();
Console.WriteLine(JsonConvert.SerializeObject(def));
Console.WriteLine(ds.ReadValue());
//Console.WriteLine(ds.ReadLong());
//Console.WriteLine(ds.ReadString());
//Console.WriteLine(ds.ReadString());
//Console.WriteLine(ds.ReadString());
//Console.WriteLine(ds.ReadString());
//Console.WriteLine(ds.ReadValue());
//Console.WriteLine(ds.ReadValue());
Console.WriteLine(JsonConvert.SerializeObject(def));
var s = new Hessian.Deserializer(stream1);
var a = s.ReadValue();
Console.WriteLine(a);
a = s.ReadValue();
Console.WriteLine(a);
Console.WriteLine(JsonConvert.SerializeObject(a));
a = s.ReadValue();
Console.WriteLine(a);
Console.WriteLine(JsonConvert.SerializeObject(a));
a = s.ReadValue();
Console.WriteLine(a);
Console.WriteLine(JsonConvert.SerializeObject(a));
}
return;
RpcRequest req = new RpcRequest {
RequestId = "71565f61-94e8-4dcf-9760-f2fb73a6886a",
CreateMillisTime = 1547621183585,

4
src/Hessian.NET/HessianInputReader.cs
Unescape View File

@ -355,9 +355,9 @@ namespace Hessian.Net
return ReadInt32();
}
public byte? Peek()
public byte ReadByte()
{
return this.Stream.
return (byte)Stream.ReadByte();
}
protected void ReadLeadingByte()

8
src/Hessian.NET/HessianSerializationScheme.cs
Unescape View File

@ -1,4 +1,5 @@
using System;
using System.Collections;
using System.Collections.Generic;
using System.Reflection;
using System.Runtime.Serialization;
@ -54,12 +55,11 @@ namespace Hessian.Net
if (IsListType(info))
{
return new ListElement(info);
return new ListElement(type, catalog, factory);
}
return BuildSerializationObject(type, catalog, factory);
}
private static ISerializationElement BuildSerializationObject(Type type, IDictionary<Type, ISerializationElement> catalog, IObjectSerializerFactory factory)
{
ISerializationElement existing;
@ -123,7 +123,7 @@ namespace Hessian.Net
public static bool IsListType(TypeInfo typeInfo)
{
return typeInfo.IsArray && typeInfo.HasElementType;
return typeof(IEnumerable).IsAssignableFrom(typeInfo);
}
}
}

100
src/Hessian.NET/ListElement.cs
Unescape View File

@ -2,16 +2,24 @@ using System;
using System.Collections.Generic;
using System.IO;
namespace Hessian.Net
{
public class ListElement: ISerializationElement
{
public ListElement(Type listType)
private readonly IDictionary<Type, ISerializationElement> _catalog;
private readonly IObjectSerializerFactory _factory;
public ListElement(Type listType, IDictionary<Type, ISerializationElement> catalog, IObjectSerializerFactory factory)
{
this.ObjectType = listType.GetElementType();
this.ObjectType = listType;
this._catalog = catalog;
this._factory = factory;
}
private readonly Lazy<ListTypeResolver> listTypeResolver = new Lazy<ListTypeResolver>();
public Type ObjectType { get; }
public ISerializationElement ChildSerializationElement { get; }
public void Serialize(HessianOutputWriter writer, object graph, HessianSerializationContext context)
{
throw new NotImplementedException();
@ -19,106 +27,112 @@ namespace Hessian.Net
public object Deserialize(HessianInputReader reader, HessianSerializationContext context)
{
object ret=null;
var preamble = reader.BeginList();
switch (preamble)
{
case ObjectPreamble.FixList:
ret =ReadFixList(reader, context);
break;
case ObjectPreamble.VarList:
ret = ReadVarList(reader, context);
break;
case ObjectPreamble.FixListUntyped:
ret = ReadFixListUntyped(reader, context);
break;
case ObjectPreamble.VarListUntyped:
ret = ReadVarListUntyped(reader, context);
break;
case ObjectPreamble.CompactFixList:
ret = ReadCompactFixList(reader, context);
break;
case ObjectPreamble.CompactFixListUntyped:
ret = ReadCompactFixListUntyped(reader, context);
break;
}
}
reader.EndList();
return ret;
}
private string ReadTypeName(HessianInputReader reader)
private string ReadTypeName(HessianInputReader reader)
{
reader.re
var tag = reader.Peek();
if (!tag.HasValue) {
throw new EndOfStreamException();
}
var tag = reader.ReadByte();
// A type name is either a string, or an integer reference to a
// string already read and stored in the type-name ref map.
if ((tag >= 0x00 && tag < 0x20)
|| (tag >= 0x30 && tag < 0x34)
|| tag == 0x52
|| tag == 0x53) {
var typeName = ReadString();
typeNameRefs.Add(typeName);
var typeName = reader.ReadString();
return typeName;
}
return typeNameRefs.Get(ReadInteger());
throw new HessianSerializerException();
}
#region List
private IList<object> ReadVarList()
private IList<object> ReadVarList(HessianInputReader reader, HessianSerializationContext context)
{
reader.ReadByte();
var type = ReadTypeName();
return ReadListCore(type: type);
var type = ReadTypeName(reader);
return ReadListCore(reader, context, type: type);
}
private IList<object> ReadFixList()
private IList<object> ReadFixList(HessianInputReader reader, HessianSerializationContext context)
{
reader.ReadByte();
var type = ReadTypeName();
var length = ReadInteger();
return ReadListCore(length, type);
var type = ReadTypeName(reader);
var length = reader.ReadInt32();
return ReadListCore(reader, context, length, type);
}
private IList<object> ReadVarListUntyped()
private IList<object> ReadVarListUntyped(HessianInputReader reader, HessianSerializationContext context)
{
reader.ReadByte();
return ReadListCore();
return ReadListCore(reader, context);
}
private IList<object> ReadFixListUntyped()
private IList<object> ReadFixListUntyped(HessianInputReader reader, HessianSerializationContext context)
{
reader.ReadByte();
var length = ReadInteger();
return ReadListCore(length);
var length = reader.ReadInt32();
return ReadListCore(reader, context, length);
}
private IList<object> ReadCompactFixList()
private IList<object> ReadCompactFixList(HessianInputReader reader, HessianSerializationContext context)
{
var tag = reader.ReadByte();
var length = tag - 0x70;
var type = ReadTypeName();
return ReadListCore(length, type);
var type = ReadTypeName(reader);
return ReadListCore(reader, context, length, type);
}
private IList<object> ReadCompactFixListUntyped()
private IList<object> ReadCompactFixListUntyped(HessianInputReader reader, HessianSerializationContext context)
{
var tag = reader.ReadByte();
var length = tag - 0x70;
return ReadListCore(length);
return ReadListCore(reader, context, length);
}
private IList<object> ReadListCore(int? length = null, string type = null)
private IList<object> ReadListCore(HessianInputReader reader, HessianSerializationContext context, int? length = null, string type = null)
{
var list = GetListIntance(type, length);
objectRefs.Add(list);
//objectRefs.Add(list);
if (length.HasValue) {
PopulateFixLengthList(list, length.Value);
PopulateFixLengthList(reader, context, list, length.Value);
} else {
PopulateVarList(list);
PopulateVarList(reader, context, list);
}
return list;
}
@ -140,25 +154,23 @@ namespace Hessian.Net
return list;
}
private void PopulateFixLengthList(IList<object> list, int length)
private void PopulateFixLengthList(HessianInputReader reader, HessianSerializationContext context, IList<object> list, int length)
{
for (var i = 0; i < length; ++i) {
list.Add(ReadValue());
//ObjectElement objectElement = new ObjectElement()
list.Add(this.ChildSerializationElement.Deserialize(reader,context));
}
}
private void PopulateVarList(IList<object> list)
private void PopulateVarList(HessianInputReader reader, HessianSerializationContext context, IList<object> list)
{
while (true) {
var tag = reader.Peek();
if (!tag.HasValue) {
throw new EndOfStreamException();
}
var tag = reader.ReadByte();
if (tag == 'Z') {
reader.ReadByte();
break;
}
list.Add(ReadValue());
list.Add(this.ChildSerializationElement.Deserialize(reader, context));
}
}

66
src/Hessian.NET/ListTypeResolver.cs
Unescape View File

@ -0,0 +1,66 @@
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Text;
namespace Hessian.Net
{
public class ListTypeResolver
{
private readonly Dictionary<string, Func<IList<object>>> constructors = new Dictionary<string, Func<IList<object>>>();
private readonly Dictionary<string, Func<int, IList<object>>> length_constructors = new Dictionary<string, Func<int, IList<object>>>();
private readonly Func<IList<object>> empty_list_ctor = () => new List<object>();
private readonly Func<int, IList<object>> empty_list_ctor_with_length = length => new List<object>(length);
public ListTypeResolver()
{
constructors.Add("System.Collections.ArrayList", empty_list_ctor);
constructors.Add("System.Collections.List", empty_list_ctor);
constructors.Add("System.Collections.IList", empty_list_ctor);
constructors.Add("System.Collections.Generic.List`1", empty_list_ctor);
constructors.Add("System.Collections.Generic.IList`1", empty_list_ctor);
constructors.Add("System.Collections.ObjectModel.Collection`1", () => new Collection<object>());
constructors.Add("java.util.List", empty_list_ctor);
constructors.Add("java.util.Vector", empty_list_ctor);
constructors.Add("java.util.ArrayList", empty_list_ctor);
constructors.Add("java.util.LinkedList", empty_list_ctor);
length_constructors.Add("System.Collections.List", empty_list_ctor_with_length);
length_constructors.Add("System.Collections.IList", empty_list_ctor_with_length);
length_constructors.Add("System.Collections.Generic.List`1", empty_list_ctor_with_length);
length_constructors.Add("System.Collections.Generic.IList`1", empty_list_ctor_with_length);
length_constructors.Add("java.util.List", empty_list_ctor_with_length);
length_constructors.Add("java.util.Vector", empty_list_ctor_with_length);
length_constructors.Add("java.util.ArrayList", empty_list_ctor_with_length);
length_constructors.Add("java.util.LinkedList", empty_list_ctor_with_length);
}
public bool TryGetListInstance(string type, out IList<object> list)
{
list = null;
Func<IList<object>> ctor;
if (!constructors.TryGetValue(type, out ctor))
{
return false;
}
list = ctor();
return true;
}
public bool TryGetListInstance(string type, int length, out IList<object> list)
{
list = null;
Func<int, IList<object>> ctor;
if (!length_constructors.TryGetValue(type, out ctor))
{
return false;
}
list = ctor(length);
return true;
}
}
}

6
src/Hessian.NET/ObjectElement.cs
Unescape View File

@ -38,6 +38,10 @@ namespace Hessian.Net
{
get;
}
public ObjectElement()
{
}
public ObjectElement(Type objectType, IList<PropertyElement> objectProperties)
{
@ -95,6 +99,8 @@ namespace Hessian.Net
var className = reader.ReadString();
var propertiesCount = reader.ReadInt32();
if (!String.Equals(ClassName, className))
{
throw new HessianSerializerException();

10
src/Hessian.NET/TypeResolver.cs
Unescape View File

@ -0,0 +1,10 @@
using System;
using System.Collections.Generic;
using System.Text;
namespace Hessian.NET
{
class TypeResolver
{
}
}

2
src/Hessian/PeekStream.cs
Unescape View File

@ -84,7 +84,7 @@ namespace Hessian
Conditions.CheckLess(offset, buffer.Length, "offset");
Conditions.CheckGreaterOrEqual(count, 0, "count");
Conditions.CheckArgument(
offset + count < buffer.Length,
offset + count <= buffer.Length,
"Buffer is not big enough to contain the requested amount of data at the given offset.");
if (count == 0) {

Write Preview
Loading…
Cancel
Save