Java UnsafeInput类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.esotericsoftware.kryo.io.UnsafeInput类的典型用法代码示例。如果您正苦于以下问题：Java UnsafeInput类的具体用法？Java UnsafeInput怎么用？Java UnsafeInput使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

UnsafeInput类属于com.esotericsoftware.kryo.io包，在下文中一共展示了UnsafeInput类的17个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: read

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
@Override
public KryoMarker read(ObjectDataInput in)
        throws IOException {

    String className = in.readUTF();
    int dataLength = in.readInt();
    byte[] data = new byte[dataLength];
    in.readFully(data);

    try (Input input = new UnsafeInput(data)) {
        Class<? extends KryoMarker> clazz = (Class<? extends KryoMarker>) Class.forName(className);
        return getKryo().readObject(input, clazz);

    } catch (ClassNotFoundException e) {
        throw new IOException(e);
    }
}

开发者ID:noctarius，项目名称:hazelcast-unaware-serialization，代码行数:18，代码来源:KryoAvailableSerializer.java

示例2: testDeserializeJunkData

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
/**
 * Junk tolerance test.
 *
 * <p>Verifies that the Serializer only throws KryoException or IndexOutOfBoundsException.
 *
 * <p>TODO(shahan): Allowing IndexOutOfBoundsException and NegativeArraySizeException here is not
 * ideal, but Kryo itself encodes lengths in the stream and seeking to random lengths triggers
 * this.
 */
void testDeserializeJunkData() {
  Random rng = new Random(0);
  int numFailures = 0;
  for (int i = 0; i < DEFAULT_JUNK_INPUTS; ++i) {
    byte[] junkData = new byte[rng.nextInt(JUNK_LENGTH_UPPER_BOUND)];
    rng.nextBytes(junkData);
    try {
      UnsafeInput input = new UnsafeInput(junkData);
      kryo.readObject(input, type);
      // OK. Junk string was coincidentally parsed.
    } catch (IndexOutOfBoundsException | NegativeArraySizeException | KryoException e) {
      // OK. Deserialization of junk failed.
      ++numFailures;
    }
  }
  assertThat(numFailures).isAtLeast(1);
}

开发者ID:bazelbuild，项目名称:bazel，代码行数:27，代码来源:SerializerTester.java

示例3: testStrings

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
public void testStrings () throws IOException {
	runStringTest(new UnsafeOutput(4096));
	runStringTest(new UnsafeOutput(897));
	runStringTest(new UnsafeOutput(new ByteArrayOutputStream()));

	UnsafeOutput write = new UnsafeOutput(21);
	String value = "abcdef\u00E1\u00E9\u00ED\u00F3\u00FA\u1234";
	write.writeString(value);
	Input read = new UnsafeInput(write.toBytes());
	assertEquals(value, read.readString());

	runStringTest(127);
	runStringTest(256);
	runStringTest(1024 * 1023);
	runStringTest(1024 * 1024);
	runStringTest(1024 * 1025);
	runStringTest(1024 * 1026);
	runStringTest(1024 * 1024 * 2);
}

开发者ID:esialb，项目名称:kryo-mavenized，代码行数:20，代码来源:UnsafeInputOutputTest.java

示例4: runCharTest

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
private void runCharTest (UnsafeOutput write) throws IOException {
	write.writeChar((char)0);
	write.writeChar((char)63);
	write.writeChar((char)64);
	write.writeChar((char)127);
	write.writeChar((char)128);
	write.writeChar((char)8192);
	write.writeChar((char)16384);
	write.writeChar((char)32767);
	write.writeChar((char)65535);

	Input read = new UnsafeInput(write.toBytes());
	assertEquals(0, read.readChar());
	assertEquals(63, read.readChar());
	assertEquals(64, read.readChar());
	assertEquals(127, read.readChar());
	assertEquals(128, read.readChar());
	assertEquals(8192, read.readChar());
	assertEquals(16384, read.readChar());
	assertEquals(32767, read.readChar());
	assertEquals(65535, read.readChar());
}

开发者ID:esialb，项目名称:kryo-mavenized，代码行数:23，代码来源:UnsafeInputOutputTest.java

示例5: runVarIntTest

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
private void runVarIntTest (UnsafeOutput write, ByteArrayOutputStream os) throws IOException {
	write.writeVarInt(0, true);
	write.writeVarInt(63, true);
	write.writeVarInt(64, true);
	write.writeVarInt(65535, true);
	assertEquals(6, write.total());
	write.flush();
	assertEquals(6, os.size());

	Input read = new UnsafeInput(os.toByteArray());
	assertEquals(0, read.readVarInt(true));
	assertEquals(63, read.readVarInt(true));
	assertEquals(64, read.readVarInt(true));
	assertEquals(65535, read.readVarInt(true));
	assertEquals(true, read.eof());
}

开发者ID:esialb，项目名称:kryo-mavenized，代码行数:17，代码来源:UnsafeInputOutputTest.java

示例6: unserialize

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public T unserialize(byte[] data) {
	Input in = new UnsafeInput(new ByteArrayInputStream(data));
	T t = (T) kryo.readClassAndObject(in);
	in.close();
	return t;
}

开发者ID:BRjDevs，项目名称:BRjLibs，代码行数:9，代码来源:KryoUnsafePacketFactory.java

示例7: bytesToObject

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
@Override
public <T> T bytesToObject(byte[] bytes) {
    if (bytes == null || bytes.length == 0) {
        return null;
    }
    Input input = new UnsafeInput(bytes);
    return (T) kryo.get().readClassAndObject(input);
}

开发者ID:visallo，项目名称:vertexium，代码行数:9，代码来源:KryoVertexiumSerializer.java

示例8: runShortTest

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
private void runShortTest (UnsafeOutput write) throws IOException {
	write.writeShort(0);
	write.writeShort(63);
	write.writeShort(64);
	write.writeShort(127);
	write.writeShort(128);
	write.writeShort(8192);
	write.writeShort(16384);
	write.writeShort(32767);
	write.writeShort(-63);
	write.writeShort(-64);
	write.writeShort(-127);
	write.writeShort(-128);
	write.writeShort(-8192);
	write.writeShort(-16384);
	write.writeShort(-32768);

	Input read = new UnsafeInput(write.toBytes());
	assertEquals(0, read.readShort());
	assertEquals(63, read.readShort());
	assertEquals(64, read.readShort());
	assertEquals(127, read.readShort());
	assertEquals(128, read.readShort());
	assertEquals(8192, read.readShort());
	assertEquals(16384, read.readShort());
	assertEquals(32767, read.readShort());
	assertEquals(-63, read.readShort());
	assertEquals(-64, read.readShort());
	assertEquals(-127, read.readShort());
	assertEquals(-128, read.readShort());
	assertEquals(-8192, read.readShort());
	assertEquals(-16384, read.readShort());
	assertEquals(-32768, read.readShort());
}

开发者ID:esialb，项目名称:kryo-mavenized，代码行数:35，代码来源:UnsafeInputOutputTest.java

示例9: runBooleanTest

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
private void runBooleanTest (UnsafeOutput write) throws IOException {
	for (int i = 0; i < 100; i++) {
		write.writeBoolean(true);
		write.writeBoolean(false);
	}

	Input read = new UnsafeInput(write.toBytes());
	for (int i = 0; i < 100; i++) {
		assertEquals(true, read.readBoolean());
		assertEquals(false, read.readBoolean());
	}
}

开发者ID:esialb，项目名称:kryo-mavenized，代码行数:13，代码来源:UnsafeInputOutputTest.java

示例10: testSimpleVarInt

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
public void testSimpleVarInt() {
    final int value = 39117;
    final Output out = new UnsafeOutput(1024);
    out.writeVarInt(value, true);
    out.flush();
    final Input in = new UnsafeInput(out.toBytes());
    final int actualValue = in.readVarInt(true);
    assertEquals(value, actualValue);
}

开发者ID:esialb，项目名称:kryo-mavenized，代码行数:10，代码来源:UnsafeInputOutputTest.java

示例11: read

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
@Override
public Object read(ObjectDataInput objectDataInput) throws IOException {
  final Input input = new UnsafeInput((InputStream) objectDataInput);
  final Kryo kryo = kryoThreadLocal.get();
  return kryo.readClassAndObject(input);
}

开发者ID:x10-lang，项目名称:apgas，代码行数:7，代码来源:KryoSerializer.java

示例12: valueToObject

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
@Override
public <T> T valueToObject(byte[] data) {
    Input input = new UnsafeInput(data);
    input.read();
    return (T) kryo.get().readClassAndObject(input);
}

开发者ID:visallo，项目名称:vertexium，代码行数:7，代码来源:KryoQuickTypeSerializer.java

示例13: getInput

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
@Override
public Input getInput() {
	return (isUnsafe)? new UnsafeInput() : new Input();
}

开发者ID:HoratiusTang，项目名称:EsperDist，代码行数:5，代码来源:FastestStreamFactory.java

示例14: UnSafeKryoObjectInput

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
public UnSafeKryoObjectInput(InputStream inputStream){
  input = new UnsafeInput(inputStream);
}

开发者ID:AllenRay，项目名称:dubbo-ex，代码行数:4，代码来源:UnSafeKryoObjectInput.java

示例15: fromBytes

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
private SubjectT fromBytes(byte[] bytes) {
  return kryo.readObject(new UnsafeInput(bytes), type);
}

开发者ID:bazelbuild，项目名称:bazel，代码行数:4，代码来源:SerializerTester.java

示例16: streamedRead

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
@Override
protected T streamedRead(InputStream inputStream) throws IOException {
    return get().readObject(new UnsafeInput(inputStream), getType());
}

开发者ID:lburgazzoli，项目名称:lb-hazelcast，代码行数:5，代码来源:KryoSerializer.java

示例17: runStringTest

import com.esotericsoftware.kryo.io.UnsafeInput; //导入依赖的package包/类
public void runStringTest (UnsafeOutput write) throws IOException {
	String value1 = "ABCDEFGHIJKLMNOPQRSTUVWXYZ\rabcdefghijklmnopqrstuvwxyz\n1234567890\t\"!`?'.,;:()[]{}<>|/@\\^$-%+=#_&~*";
	String value2 = "abcdef\u00E1\u00E9\u00ED\u00F3\u00FA\u1234";

	write.writeString("");
	write.writeString("1");
	write.writeString("22");
	write.writeString("uno");
	write.writeString("dos");
	write.writeString("tres");
	write.writeString(null);
	write.writeString(value1);
	write.writeString(value2);
	for (int i = 0; i < 127; i++)
		write.writeString(String.valueOf((char)i));
	for (int i = 0; i < 127; i++)
		write.writeString(String.valueOf((char)i) + "abc");

	Input read = new UnsafeInput(write.toBytes());
	assertEquals("", read.readString());
	assertEquals("1", read.readString());
	assertEquals("22", read.readString());
	assertEquals("uno", read.readString());
	assertEquals("dos", read.readString());
	assertEquals("tres", read.readString());
	assertEquals(null, read.readString());
	assertEquals(value1, read.readString());
	assertEquals(value2, read.readString());
	for (int i = 0; i < 127; i++)
		assertEquals(String.valueOf((char)i), read.readString());
	for (int i = 0; i < 127; i++)
		assertEquals(String.valueOf((char)i) + "abc", read.readString());

	read.rewind();
	assertEquals("", read.readStringBuilder().toString());
	assertEquals("1", read.readStringBuilder().toString());
	assertEquals("22", read.readStringBuilder().toString());
	assertEquals("uno", read.readStringBuilder().toString());
	assertEquals("dos", read.readStringBuilder().toString());
	assertEquals("tres", read.readStringBuilder().toString());
	assertEquals(null, read.readStringBuilder());
	assertEquals(value1, read.readStringBuilder().toString());
	assertEquals(value2, read.readStringBuilder().toString());
	for (int i = 0; i < 127; i++)
		assertEquals(String.valueOf((char)i), read.readStringBuilder().toString());
	for (int i = 0; i < 127; i++)
		assertEquals(String.valueOf((char)i) + "abc", read.readStringBuilder().toString());
}

开发者ID:esialb，项目名称:kryo-mavenized，代码行数:49，代码来源:UnsafeInputOutputTest.java

注：本文中的com.esotericsoftware.kryo.io.UnsafeInput类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java GzipUtils类代码示例发布时间：2022-05-22

Java ProjectionType类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19227|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9996|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8331|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8700|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8645|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9666|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8630|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：8004|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8664|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7540|2022-11-06

客服电话

电子邮件

Java UnsafeInput类代码示例

示例1: read

示例2: testDeserializeJunkData

示例3: testStrings

示例4: runCharTest

示例5: runVarIntTest

示例6: unserialize

示例7: bytesToObject

示例8: runShortTest

示例9: runBooleanTest

示例10: testSimpleVarInt

示例11: read

示例12: valueToObject

示例13: getInput

示例14: UnSafeKryoObjectInput

示例15: fromBytes

示例16: streamedRead

示例17: runStringTest

请发表评论

全部评论

上一篇：

下一篇：

相机标定过程(opencv) + matlab参数导入ope

ashchan/mail-notifr: Mail Notifr - Gmail

TwistedAsylumMC/bedrock-unicode-characte

uber/RIBs: Uber's cross-platform mob

ajtowf/ng2_play: Angular 2 Play with Mat

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053

客服电话

电子邮件

Java UnsafeInput类代码示例

示例1: read

示例2: testDeserializeJunkData

示例3: testStrings

示例4: runCharTest

示例5: runVarIntTest

示例6: unserialize

示例7: bytesToObject

示例8: runShortTest

示例9: runBooleanTest

示例10: testSimpleVarInt

示例11: read

示例12: valueToObject

示例13: getInput

示例14: UnSafeKryoObjectInput

示例15: fromBytes

示例16: streamedRead

示例17: runStringTest

请发表评论

全部评论

上一篇：

下一篇：

相机标定过程(opencv) + matlab参数导入ope

ashchan/mail-notifr: Mail Notifr - Gmail

TwistedAsylumMC/bedrock-unicode-characte

uber/RIBs: Uber&#39;s cross-platform mob

ajtowf/ng2_play: Angular 2 Play with Mat

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053

uber/RIBs: Uber's cross-platform mob