lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
wentch
2016-01-06 14:08:52 +08:00
parent 876dfcc8fc
commit dbf1d60593
2 changed files with 36 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
test/org/redkale/test/convert/BsonTestMain.java
View File

@@ -28,6 +28,7 @@ public class BsonTestMain {
System.out.println(Arrays.toString(a)); System.out.println(Arrays.toString(a));
main2(args); main2(args);
main3(args); main3(args);
main4(args);
} }
public static void main2(String[] args) throws Exception { public static void main2(String[] args) throws Exception {
@@ -36,11 +37,11 @@ public class BsonTestMain {
byte[] bytes = convert.convertTo(SimpleEntity.class, entry); byte[] bytes = convert.convertTo(SimpleEntity.class, entry);
System.out.println("长度: " + bytes.length); System.out.println("长度: " + bytes.length);
BsonByteBufferWriter writer = convert.pollBsonWriter(() -> ByteBuffer.allocate(1)); BsonByteBufferWriter writer = convert.pollBsonWriter(() -> ByteBuffer.allocate(1));
convert.convertTo(writer,SimpleEntity.class, entry); convert.convertTo(writer, SimpleEntity.class, entry);
ByteBuffer[] buffers = writer.toBuffers(); ByteBuffer[] buffers = writer.toBuffers();
int len = 0; int len = 0;
ByteArrayOutputStream out = new ByteArrayOutputStream(); ByteArrayOutputStream out = new ByteArrayOutputStream();
for(ByteBuffer b : buffers){ for (ByteBuffer b : buffers) {
len += b.remaining(); len += b.remaining();
byte[] ts = new byte[b.remaining()]; byte[] ts = new byte[b.remaining()];
b.get(ts); b.get(ts);
@@ -71,4 +72,17 @@ public class BsonTestMain {
bytes2 = writer.toArray(); bytes2 = writer.toArray();
System.out.println(convert.convertFrom(ComplextEntity.class, bytes2).toString()); System.out.println(convert.convertFrom(ComplextEntity.class, bytes2).toString());
} }
public static void main4(String[] args) throws Exception {
final BsonConvert convert = BsonFactory.root().getConvert();
SimpleChildEntity entry = SimpleChildEntity.create();
ByteArrayOutputStream out = new ByteArrayOutputStream();
convert.convertTo(out, SimpleEntity.class, entry);
byte[] bytes = out.toByteArray();
Utility.println(null, bytes);
System.out.println(JsonFactory.root().getConvert().convertTo(entry));
SimpleEntity rs = convert.convertFrom(SimpleEntity.class, new ByteArrayInputStream(bytes));
System.out.println(rs.toString());
}
} }

27
test/org/redkale/test/convert/JsonTestMain.java
View File

@@ -19,31 +19,31 @@ import org.redkale.convert.json.*;
public class JsonTestMain { public class JsonTestMain {
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
JsonFactory factory = JsonFactory.root(); JsonFactory factory = JsonFactory.root().tiny(true);
factory.setTiny(true);
final JsonConvert convert = JsonFactory.root().getConvert(); final JsonConvert convert = JsonFactory.root().getConvert();
String json = "{\"access_token\":\"vVX2bIjN5P9TMOphDkStM96eNWapAehTuWAlVDO74aFaYxLwj2b-9-T9p_W2mfr9\",\"expires_in\":7200, \"aa\":\"\"}"; String json = "{\"access_token\":\"vVX2bIjN5P9TMOphDkStM96eNWapAehTuWAlVDO74aFaYxLwj2b-9-T9p_W2mfr9\",\"expires_in\":7200, \"aa\":\"\"}";
Map<String, String> map = convert.convertFrom(JsonConvert.TYPE_MAP_STRING_STRING, json); Map<String, String> map = convert.convertFrom(JsonConvert.TYPE_MAP_STRING_STRING, json);
System.out.println(map); System.out.println(map);
System.out.println(convert.convertTo(map)); System.out.println(convert.convertTo(map));
ByteBuffer[] buffers = convert.convertTo(() -> ByteBuffer.allocate(1024), map); ByteBuffer[] buffers = convert.convertTo(() -> ByteBuffer.allocate(1024), map);
byte[] bs = new byte[buffers[0].remaining()]; byte[] bs = new byte[buffers[0].remaining()];
buffers[0].get(bs); buffers[0].get(bs);
System.out.println(new String(bs)); System.out.println(new String(bs));
main2(args); main2(args);
main3(args);
} }
public static void main2(String[] args) throws Exception { public static void main2(String[] args) throws Exception {
final JsonConvert convert = JsonFactory.root().getConvert(); final JsonConvert convert = JsonFactory.root().getConvert();
SimpleChildEntity entry = SimpleChildEntity.create(); SimpleChildEntity entry = SimpleChildEntity.create();
String json = convert.convertTo(SimpleEntity.class, entry); String json = convert.convertTo(SimpleEntity.class, entry);
System.out.println("长度: " + json.length()); System.out.println("长度: " + json.length());
JsonByteBufferWriter writer = convert.pollJsonWriter(() -> ByteBuffer.allocate(1)); JsonByteBufferWriter writer = convert.pollJsonWriter(() -> ByteBuffer.allocate(1));
convert.convertTo(writer,SimpleEntity.class, entry); convert.convertTo(writer, SimpleEntity.class, entry);
ByteBuffer[] buffers = writer.toBuffers(); ByteBuffer[] buffers = writer.toBuffers();
int len = 0; int len = 0;
ByteArrayOutputStream out = new ByteArrayOutputStream(); ByteArrayOutputStream out = new ByteArrayOutputStream();
for(ByteBuffer b : buffers){ for (ByteBuffer b : buffers) {
len += b.remaining(); len += b.remaining();
byte[] ts = new byte[b.remaining()]; byte[] ts = new byte[b.remaining()];
b.get(ts); b.get(ts);
@@ -57,4 +57,17 @@ public class JsonTestMain {
System.out.println(entry2); System.out.println(entry2);
} }
public static void main3(String[] args) throws Exception {
final JsonConvert convert = JsonFactory.root().getConvert();
SimpleChildEntity entry = SimpleChildEntity.create();
ByteArrayOutputStream out = new ByteArrayOutputStream();
convert.convertTo(out, SimpleEntity.class, entry);
String json = out.toString("UTF-8");
System.out.println("长度: " + json.length());
System.out.println(json);
ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
SimpleChildEntity entry2 = convert.convertFrom(SimpleChildEntity.class, in);
System.out.println(entry);
System.out.println(entry2);
}
} }