gpt4 book ai didi

com.netflix.discovery.converters.XmlXStream类的使用及代码示例

转载 作者:知者 更新时间:2024-03-19 04:54:40 38 4
gpt4 key购买 nike

本文整理了Java中com.netflix.discovery.converters.XmlXStream类的一些代码示例,展示了XmlXStream类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XmlXStream类的具体详情如下:
包路径:com.netflix.discovery.converters.XmlXStream
类名称:XmlXStream

XmlXStream介绍

[英]An Xstream specific implementation for serializing and deserializing to/from XML format.

This class also allows configuration of custom serializers with Xstream.
[中]一个特定于Xstream的实现,用于对XML格式进行序列化和反序列化。
此类还允许使用Xstream配置自定义序列化程序。

代码示例

代码示例来源:origin: Netflix/eureka

private XStream getXStreamInstance(MediaType mediaType) {
    XStream xstream = null;
    if (JSON.equalsIgnoreCase(mediaType.getSubtype())) {
      xstream = JsonXStream.getInstance();
    } else if (XML.equalsIgnoreCase(mediaType.getSubtype())) {
      xstream = XmlXStream.getInstance();
    }
    return xstream;
  }
}

代码示例来源:origin: Netflix/eureka

public XmlXStream() {
  super(new DomDriver(null, initializeNameCoder()));
  registerConverter(new Converters.ApplicationConverter());
  registerConverter(new Converters.ApplicationsConverter());
  registerConverter(new Converters.DataCenterInfoConverter());
  registerConverter(new Converters.InstanceInfoConverter());
  registerConverter(new Converters.LeaseInfoConverter());
  registerConverter(new Converters.MetadataConverter());
  setMode(XStream.NO_REFERENCES);
  processAnnotations(new Class[]{InstanceInfo.class, Application.class, Applications.class});
}

代码示例来源:origin: Netflix/eureka

@Override
public <T> String encode(T object) throws IOException {
  return codec.toXML(object);
}

代码示例来源:origin: Netflix/eureka

XmlXStream.getInstance().registerConverter(new V1AwareInstanceInfoConverter(), XStream.PRIORITY_VERY_HIGH);

代码示例来源:origin: Netflix/eureka

protected void sendOkResponseWithContent(Request request, HttpServletResponse response, Applications apps)
    throws IOException {
  String content = XmlXStream.getInstance().toXML(apps);
  response.setContentType("application/xml");
  response.setStatus(HttpServletResponse.SC_OK);
  response.getWriter().println(content);
  response.getWriter().flush();
  request.setHandled(true);
  System.out.println("Eureka port: " + port + ". " + System.currentTimeMillis() +
      ". Eureka resource mock, sent response for request path: " + request.getPathInfo() +
      ", apps count: " + apps.getRegisteredApplications().size());
}

代码示例来源:origin: Netflix/eureka

@Override
  public <T> T decode(InputStream inputStream, Class<T> type) throws IOException {
    return (T) codec.fromXML(inputStream, type);
  }
}

代码示例来源:origin: org.springframework.cloud/spring-cloud-netflix-eureka-server

protected void initEurekaServerContext() throws Exception {
  // For backward compatibility
  JsonXStream.getInstance().registerConverter(new V1AwareInstanceInfoConverter(),
      XStream.PRIORITY_VERY_HIGH);
  XmlXStream.getInstance().registerConverter(new V1AwareInstanceInfoConverter(),
      XStream.PRIORITY_VERY_HIGH);
  if (isAws(this.applicationInfoManager.getInfo())) {
    this.awsBinder = new AwsBinderDelegate(this.eurekaServerConfig,
        this.eurekaClientConfig, this.registry, this.applicationInfoManager);
    this.awsBinder.start();
  }
  EurekaServerContextHolder.initialize(this.serverContext);
  log.info("Initialized server context");
  // Copy registry from neighboring eureka node
  int registryCount = this.registry.syncUp();
  this.registry.openForTraffic(this.applicationInfoManager, registryCount);
  // Register all monitoring statistics.
  EurekaMonitors.registerAllStats();
}

代码示例来源:origin: Netflix/eureka

@Override
public <T> T decode(String textValue, Class<T> type) throws IOException {
  return (T) codec.fromXML(textValue, type);
}

代码示例来源:origin: dyc87112/didi-eureka-server

protected void initEurekaServerContext() throws Exception {
  // For backward compatibility
  JsonXStream.getInstance().registerConverter(new V1AwareInstanceInfoConverter(),
      XStream.PRIORITY_VERY_HIGH);
  XmlXStream.getInstance().registerConverter(new V1AwareInstanceInfoConverter(),
      XStream.PRIORITY_VERY_HIGH);
  if (isAws(this.applicationInfoManager.getInfo())) {
    this.awsBinder = new AwsBinderDelegate(this.eurekaServerConfig,
        this.eurekaClientConfig, this.registry, this.applicationInfoManager);
    this.awsBinder.start();
  }
  EurekaServerContextHolder.initialize(this.serverContext);
  log.info("Initialized server context");
  // Copy registry from neighboring eureka node
  int registryCount = this.registry.syncUp();
  this.registry.openForTraffic(this.applicationInfoManager, registryCount);
  // Register all monitoring statistics.
  EurekaMonitors.registerAllStats();
}

代码示例来源:origin: com.netflix.eureka/eureka-client

public XmlXStream() {
  super(new DomDriver(null, initializeNameCoder()));
  registerConverter(new Converters.ApplicationConverter());
  registerConverter(new Converters.ApplicationsConverter());
  registerConverter(new Converters.DataCenterInfoConverter());
  registerConverter(new Converters.InstanceInfoConverter());
  registerConverter(new Converters.LeaseInfoConverter());
  registerConverter(new Converters.MetadataConverter());
  setMode(XStream.NO_REFERENCES);
  processAnnotations(new Class[]{InstanceInfo.class, Application.class, Applications.class});
}

代码示例来源:origin: Netflix/eureka

/**
   * Tests: http://x-stream.github.io/CVE-2017-7957.html
   */
  @Test(expected=ForbiddenClassException.class, timeout=5000)
  public void testVoidAttributeUnmarshalling() throws Exception {
    XStream xstream = XmlXStream.getInstance();
    xstream.fromXML("<string class='void'>Hello, world!</string>");
  }
}

代码示例来源:origin: Netflix/eureka

@Override
public <T> void encode(T object, OutputStream outputStream) throws IOException {
  codec.toXML(object, outputStream);
}

代码示例来源:origin: com.netflix.eureka/eureka-client

@Override
  public <T> T decode(InputStream inputStream, Class<T> type) throws IOException {
    return (T) codec.fromXML(inputStream, type);
  }
}

代码示例来源:origin: com.netflix.eureka/eureka-core

XmlXStream.getInstance().registerConverter(new V1AwareInstanceInfoConverter(), XStream.PRIORITY_VERY_HIGH);

代码示例来源:origin: Netflix/eureka

/**
 * Tests: http://x-stream.github.io/CVE-2017-7957.html
 */
@Test(expected=ForbiddenClassException.class, timeout=5000)
public void testVoidElementUnmarshalling() throws Exception {
  XStream xstream = XmlXStream.getInstance();
  xstream.fromXML("<void/>");
}

代码示例来源:origin: com.netflix.eureka/eureka-client

@Override
public <T> String encode(T object) throws IOException {
  return codec.toXML(object);
}

代码示例来源:origin: com.netflix.eureka/eureka-client

@Override
public <T> T decode(String textValue, Class<T> type) throws IOException {
  return (T) codec.fromXML(textValue, type);
}

代码示例来源:origin: Netflix/eureka

@Test
public void testEncodingDecodingWithoutMetaData() throws Exception {
  Applications applications = InstanceInfoGenerator.newBuilder(10, 2).withMetaData(false).build().toApplications();
  XStream xstream = XmlXStream.getInstance();
  String xmlDocument = xstream.toXML(applications);
  Applications decodedApplications = (Applications) xstream.fromXML(xmlDocument);
  assertThat(EurekaEntityComparators.equal(decodedApplications, applications), is(true));
}

代码示例来源:origin: com.netflix.eureka/eureka-client

@Override
public <T> void encode(T object, OutputStream outputStream) throws IOException {
  codec.toXML(object, outputStream);
}

代码示例来源:origin: Netflix/eureka

@Test
public void testEncodingDecodingWithMetaData() throws Exception {
  Applications applications = InstanceInfoGenerator.newBuilder(10, 2).withMetaData(true).build().toApplications();
  XStream xstream = XmlXStream.getInstance();
  String xmlDocument = xstream.toXML(applications);
  Applications decodedApplications = (Applications) xstream.fromXML(xmlDocument);
  assertThat(EurekaEntityComparators.equal(decodedApplications, applications), is(true));
}

38 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com