- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中xdi2.core.io.XDIWriter
类的一些代码示例,展示了XDIWriter
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XDIWriter
类的具体详情如下:
包路径:xdi2.core.io.XDIWriter
类名称:XDIWriter
[英]Provides methods for writing an XDI graph.
[中]提供用于编写XDI图的方法。
代码示例来源:origin: projectdanube/xdi2
@Override
public void save(MemoryGraph memoryGraph) {
try {
File file = new File(this.path);
if (! file.exists()) {
if (log.isDebugEnabled()) log.debug("File " + file.getAbsolutePath() + " does not exist. Creating file.");
file.createNewFile();
}
if (log.isDebugEnabled()) log.debug("Saving file " + file.getAbsolutePath());
Writer writer = new FileWriter(this.path);
this.xdiWriter.write(memoryGraph, writer);
writer.close();
} catch (Exception ex) {
throw new Xdi2RuntimeException("Cannot save file at " + this.path, ex);
}
}
代码示例来源:origin: projectdanube/xdi2
@Override
public String toString(String format, Properties parameters) {
if (format == null) format = XDIWriterRegistry.getDefault().getFormat();
XDIWriter writer = XDIWriterRegistry.forFormat(format, parameters);
if (writer == null) throw new Xdi2RuntimeException("Unknown format for XDI serialization: " + format);
StringWriter buffer = new StringWriter();
try {
writer.write(this, buffer);
} catch (IOException ex) {
return "[Exception: " + ex.getMessage() + "]";
}
return buffer.toString();
}
代码示例来源:origin: projectdanube/xdi2
public static void addWriter(Class<? extends XDIWriter> writerClass) {
XDIWriter writer;
try {
Constructor<? extends XDIWriter> constructor = writerClass.getConstructor(Properties.class);
writer = constructor.newInstance((Properties) null);
} catch (Exception ex) {
throw new RuntimeException(ex);
}
String format = writer.getFormat();
String fileExtension = writer.getFileExtension();
MimeType mimeType = writer.getMimeType();
if (format != null) writerClassesByFormat.put(format, writerClass);
if (fileExtension != null) writerClassesByFileExtension.put(fileExtension, writerClass);
if (mimeType != null) writerClassesByMimeType.put(mimeType, writerClass);
}
代码示例来源:origin: projectdanube/xdi2
private void sendOk(HttpTransportRequest request, HttpTransportResponse response, TransportMessagingResponse messagingResponse) throws IOException {
response.setStatus(HttpTransportResponse.SC_OK);
Map<String, String> headers = new HashMap<String, String> ();
headers.putAll(this.getHeaders());
if (HttpTransportRequest.METHOD_GET.equals(request.getMethod())) headers.putAll(this.getHeadersGet());
if (HttpTransportRequest.METHOD_POST.equals(request.getMethod())) headers.putAll(this.getHeadersPost());
if (HttpTransportRequest.METHOD_PUT.equals(request.getMethod())) headers.putAll(this.getHeadersPut());
if (HttpTransportRequest.METHOD_DELETE.equals(request.getMethod())) headers.putAll(this.getHeadersDelete());
if (HttpTransportRequest.METHOD_OPTIONS.equals(request.getMethod())) headers.putAll(this.getHeadersOptions());
for (Map.Entry<String, String> header : headers.entrySet()) {
response.setHeader(header.getKey(), header.getValue());
}
if (messagingResponse != null) {
// find a suitable writer based on accept headers
if (log.isDebugEnabled()) log.debug("Accept: " + request.getHeader("Accept"));
XDIWriter writer = null;
String acceptHeader = request.getHeader("Accept");
MimeType sendMimeType = acceptHeader != null ? AcceptHeader.parse(acceptHeader).bestMimeType(false, true) : null;
writer = sendMimeType != null ? XDIWriterRegistry.forMimeType(sendMimeType) : null;
if (writer == null) writer = XDIWriterRegistry.getDefault();
// send out the message result
if (log.isDebugEnabled()) log.debug("Sending result in " + sendMimeType + " with writer " + writer.getClass().getSimpleName() + ".");
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
writer.write(messagingResponse.getGraph(), buffer);
response.setContentType(writer.getMimeType().toString());
response.setContentLength(buffer.size());
response.writeBody(buffer.toByteArray(), true);
}
if (log.isDebugEnabled()) log.debug("Output complete.");
}
代码示例来源:origin: projectdanube/xdi2
public void testWriters() throws Exception {
String[] formats = new String[] { "XDI/JSON", "XDI DISPLAY", "KEYVALUE" };
String[] fileExtensions = new String[] { "json", "xdi" };
MimeType[] mimeTypes = new MimeType[] { new MimeType("application/xdi+json"), new MimeType("application/xdi+json;contexts=0"), new MimeType("application/xdi+json;contexts=1"), new MimeType("text/xdi"), new MimeType("text/xdi;contexts=0"), new MimeType("text/xdi;contexts=1") };
for (String format : formats) assertTrue(XDIWriterRegistry.forFormat(format, null).supportsFormat(format));
for (String fileExtension : fileExtensions) assertTrue(XDIWriterRegistry.forFileExtension(fileExtension, null).supportsFileExtension(fileExtension));
for (MimeType mimeType : mimeTypes) assertTrue(XDIWriterRegistry.forMimeType(mimeType).supportsMimeType(mimeType));
}
}
代码示例来源:origin: projectdanube/xdi2
private void readGraph(ExecutionContext executionContext) throws Xdi2MessagingException {
XDIReader xdiReader = XDIReaderRegistry.forFormat(this.mimeType, null);
if (xdiReader == null) throw new Xdi2MessagingException("Cannot read this format: " + this.mimeType, null, executionContext);
Graph graph = this.getGraph();
graph.clear();
FileReader reader = null;
try {
File file = new File(this.path);
reader = new FileReader(file);
xdiReader.read(graph, reader);
reader.close();
} catch (FileNotFoundException ex) {
} catch (Exception ex) {
throw new Xdi2MessagingException("Cannot read file: " + ex.getMessage(), ex, executionContext);
} finally {
if (reader != null) {
try {
reader.close();
} catch (Exception ex) { }
}
}
if (xdiReader instanceof AutoReader) this.mimeType = ((AutoReader) xdiReader).getLastSuccessfulReader().getFormat();
if (this.mimeType == null) this.mimeType = XDIWriterRegistry.getDefault().getFormat();
}
代码示例来源:origin: projectdanube/xdi2
@Override
public String toString(MimeType mimeType) {
if (mimeType == null) throw new NullPointerException();
XDIWriter writer = XDIWriterRegistry.forMimeType(mimeType);
if (writer == null) throw new Xdi2RuntimeException("Unknown MIME type for XDI serialization: " + mimeType);
StringWriter buffer = new StringWriter();
try {
writer.write(this, buffer);
} catch (IOException ex) {
return "[Exception: " + ex.getMessage() + "]";
}
return buffer.toString();
}
代码示例来源:origin: projectdanube/xdi2
private void writeGraph(ExecutionContext executionContext) throws Xdi2MessagingException {
XDIWriter xdiWriter = XDIWriterRegistry.forFormat(this.mimeType, null);
if (xdiWriter == null) throw new Xdi2MessagingException("Cannot write this format: " + this.mimeType, null, executionContext);
Graph graph = this.getGraph();
FileWriter writer = null;
try {
File file = new File(this.path);
file.createNewFile();
writer = new FileWriter(file);
xdiWriter.write(graph, writer);
writer.close();
} catch (Exception ex) {
throw new Xdi2MessagingException("Cannot write file: " + ex.getMessage(), ex, executionContext);
} finally {
if (writer != null) try { writer.close(); } catch (Exception ex) { }
}
graph.close();
}
代码示例来源:origin: projectdanube/xdi2
private static void sendText(WebSocketTransportRequest request, WebSocketTransportResponse response, TransportMessagingResponse messagingResponse) throws IOException {
// use default writer
XDIWriter writer = null;
MimeType sendMimeType = null;
writer = sendMimeType != null ? XDIWriterRegistry.forMimeType(sendMimeType) : null;
if (writer == null) writer = XDIWriterRegistry.getDefault();
// send out the message result
if (log.isDebugEnabled()) log.debug("Sending result in " + sendMimeType + " with writer " + writer.getClass().getSimpleName() + ".");
StringWriter buffer = new StringWriter();
writer.write(messagingResponse.getGraph(), buffer);
// TODO figure out if we can use .getAsync() and avoid concurrency problems
if (buffer.getBuffer().length() > 0) {
synchronized (response.getBasic()) {
response.getBasic().sendText(buffer.getBuffer().toString());
}
}
if (log.isDebugEnabled()) log.debug("Output complete.");
}
代码示例来源:origin: projectdanube/xdi2
@Override
public InterceptorResult before(MessageEnvelope messageEnvelope, ExecutionContext executionContext, ExecutionResult executionResult) throws Xdi2MessagingException {
if (this.isEnableMessageEnvelope()) {
StringWriter stringWriter = new StringWriter();
try {
XDIWriterRegistry.getDefault().write(messageEnvelope.getGraph(), stringWriter);
} catch (IOException ex) {
throw new Xdi2MessagingException("Cannot write graph: " + ex.getMessage(), ex, executionContext);
}
String param = stringWriter.getBuffer().toString();
this.executeCommandLine(param, executionContext);
}
return InterceptorResult.DEFAULT;
}
代码示例来源:origin: projectdanube/xdi2
/**
* Returns the normalized serialization string of a context node, to be used
* e.g. for signatures and encryptions.
*/
public static String serialize(ContextNode contextNode, CopyStrategy copyStrategy) {
Graph tempGraph;
tempGraph = MemoryGraphFactory.getInstance().openGraph();
CopyUtil.copyContextNode(contextNode, tempGraph, copyStrategy);
StringWriter buffer = new StringWriter();
String string;
try {
XDIWRITER.write(tempGraph, buffer);
string = buffer.toString();
} catch (IOException ex) {
throw new Xdi2RuntimeException("Cannot serialize " + contextNode + ": " + ex.getMessage(), ex);
} finally {
try { buffer.close(); } catch (Exception ex) { }
tempGraph.close();
}
if (log.isDebugEnabled()) log.debug("Normalized context node " + contextNode.getXDIAddress() + ": " + string);
return string;
}
代码示例来源:origin: projectdanube/xdi2
StringWriter stringWriter = new StringWriter();
writer.write(messageEnvelope.getGraph(), stringWriter);
async.sendText(stringWriter.getBuffer().toString());
} catch (Exception ex) {
代码示例来源:origin: projectdanube/xdi2
writer.write(messageEnvelope.getGraph(), outputStream);
outputStream.flush();
outputStream.close();
代码示例来源:origin: projectdanube/xdi2
xdiWriter.write(graph, xdiStringWriter);
graphstring = xdiStringWriter.getBuffer().toString();
xdiWriter.write(graph, xdiStringWriter);
graphstring = xdiStringWriter.getBuffer().toString();
xdiWriter.write(resultGraph, stringWriter);
resultstring = stringWriter.getBuffer().toString();
} else {
代码示例来源:origin: projectdanube/xdi2
public void testReadWriteFormats() throws Exception {
String[] formats = new String[] { "XDI/JSON", "XDI DISPLAY" };
for (int i=0; i<formats.length; i++) {
File file = new File("xdi.out");
Graph graph4 = this.getGraphFactory().openGraph(this.getClass().getName() + "-graph-4" + "-" + i);
Graph graph5 = this.getGraphFactory().openGraph(this.getClass().getName() + "-graph-5" + "-" + i);
XDIWriter writer = XDIWriterRegistry.forFormat(formats[i], null);
XDIReader reader = XDIReaderRegistry.forFormat(formats[i], null);
FileWriter fileWriter = new FileWriter(file);
FileReader fileReader = new FileReader(file);
makeGraph(graph4);
writer.write(graph4, fileWriter);
reader.read(graph5, fileReader);
fileWriter.close();
fileReader.close();
testGraph(graph5);
testGraphsEqual(graph4, graph5);
graph4.close();
graph5.close();
file.delete();
}
}
代码示例来源:origin: projectdanube/xdi2
XDIWriterRegistry.forFormat("XDI/JSON", null).write(graph10, buffer1);
XDIWriterRegistry.forFormat("XDI DISPLAY", null).write(graph11, buffer2);
graph10.clear();
graph11.clear();
主要思想是将 EF Core nuget 包添加到 .NET Core 库项目,然后在一堆应用程序(例如 ASP.NET Core、Win 服务、控制台应用程序)中使用该库,而无需在每个应用程序中配置
我想要实现的是编写一个简单的.net核心后台工作程序(.net core 3.1)的代码,在该工作程序作为Windows服务运行时,我在其中将数据写入SQL Server数据库(通过EF Core 3
关于 .Net Core SDK download page 二进制文件有什么用?它与安装程序有何不同? 最佳答案 二进制文件是 .NET Core 的编译代码。它们拥有运行 .NET Core 所需
.NET Core 和 Entity Framework Core 之间的区别?我们可以在 .NET Core 中使用 Entity Framework Core 吗?两者都有什么优势? 最佳答案 E
.NET Core 和 ASP.NET Core 到底有什么区别? 它们是相互排斥的吗?我听说 ASP.NET Core 是基于 .NET Core 构建的,但它也可以基于完整的 .NET 框架构建。
我对 ASP.NET Core 开发完全陌生。我正在尝试使用单个模型和 mysql 创建一个简单的 asp.net core Web api 来存储模型数据,然后我想使用 Swagger 将其作为 R
.NET Core 和 Entity Framework Core 之间的区别?我们可以在 .NET Core 中使用 Entity Framework Core 吗?两者都有什么优势? 最佳答案 E
好吧,作为一个新的 .net 开发生态系统,我有点迷失在核心工具、版本等方面。 有人可以解释我之间的区别吗 VS 2015 核心工具预览版 x - See here .NET Core/SDK 与否
我已阅读有关如何通过信号器核心集线器从后台服务向客户端发送通知的文档。如何从客户端接收到后台服务的通知? 后台服务应该只是一个单例。 public class Startup { public
关闭。这个问题是opinion-based .它目前不接受答案。 想改善这个问题吗?更新问题,以便可以通过 editing this post 用事实和引文回答问题. 4年前关闭。 Improve t
非常简单的问题: 我正在尝试创建一个像这样的谓词构建器: var predicate = PredicateBuilder.False(); 但似乎在Net Core和EF Core中不可用。
在 .NET Core 自包含应用程序 中...我们需要在 project.json 中指定运行时 (RID) 我们希望我们的应用程序针对...发布为什么会这样? .NET Core 是跨平台的,与我
如何用 iCloud Core Data 替换我现有的 Core Data?这是我的持久商店协调员: lazy var persistentStoreCoordinator: NSPersistent
关闭。这个问题是opinion-based 。目前不接受答案。 想要改进这个问题吗?更新问题,以便 editing this post 可以用事实和引文来回答它。 . 已关闭 2 年前。 Improv
今天我正在学习新的 ASP.net 核心 API 3.1,我想将我的旧网站从 MVC4 转移到 Web API。除了一件事,一切都很好。数据库连接。在我的旧网站中,我为每个客户端(10/15 数据库)
我在 Visual Studio 2015 Update 3 和 .NET Core 1.0 中工作。我有一个 .NETCoreApp v1.0 类型的 Web API 项目。当我添加一个 .NET
我一直在尝试遵循 Ben Cull ( http://benjii.me/2016/06/entity-framework-core-migrations-for-class-library-proj
当我打开我的 vs 代码程序时,我收到以下消息: 无法找到 .NET Core SDK。 .NET Core 调试将不会启用。确保 .NET Core SDK 已安装并且在路径上。 如果我安装甚至卸载
我偶然发现了一个非常奇怪的问题。每当 Web 应用程序启动时,dotnet.exe 都会使用相当多的内存(大约 300M)。然而,当它触及某些部分时(我感觉这与 EF Core 使用有关),它会在短时
ASP.NET Core Web (.NET Core) 与 ASP.NET Core Web (.NET Framework) 有什么区别? .NET Framework 是否提供 similar
我是一名优秀的程序员,十分优秀!