- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中xdi2.core.io.XDIWriter.write()
方法的一些代码示例,展示了XDIWriter.write()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XDIWriter.write()
方法的具体详情如下:
包路径:xdi2.core.io.XDIWriter
类名称:XDIWriter
方法名:write
[英]Writes an XDI context node to a byte stream.
[中]将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(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
@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
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
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
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();
我正在执行 UPDATE .WRITE() 语句,并发现它显然只有在您像这样定义它时才有效: string sql = "UPDATE [dbo].[Table] SET [Column].WRITE
我在 Unix 系统上用 C 编程。我知道: write(fd,"ABCD",4); 比这样做更好: write(fd, "A", 1); write(fd, "B", 1); write(fd, "
func hash(s string) uint32 { h := fnv.New32a() h.Write([]byte(s)) return h.Sum32() } 对于这
在经典的 asp 页面中,有人告诉我您可以使用 vbscript 或 jscript。而 jscript 就是 javascript。 所以我不确定 Response.Write、Response.W
当 openssl 子进程尝试 write() 到本地目录时,我收到此错误。在调用 write() 之前连接已关闭。它没有与 ssl 连接,因为我什至无法从 nodejs 文档启动示例代码。 我错过了
最近我在试验netty。我遇到了以下问题: ctx.channel().write(new TextWebSocketFrame("hello")) 没有在客户端返回 hello,但是 ctx.cha
请解释以下内容: def feed(data): import os print "DATA LEN: %s" % len(data) f = open("copy", "w") f.
有什么区别debug.write 和 Trace.write ?每个应该什么时候使用? 最佳答案 在典型的发布构建配置中,Debug class 被禁用并且什么都不做。 Trace但是,仍然可以在发行
我只是想知道,就性能而言,哪个更好(我在 FileStream 中使用 StreamWriter): 多次调用 Stream.Write(): StreamWriter sw = new Stream
我发现自己写给 stringwriter,然后在函数末尾执行 resp.Write(sw.ToString())。这是不必要的吗?如果我多次使用 HttpResponse.Write,即使我的页面是
我正在尝试通过 JavaScript 文件从 electron 打开一个新窗口,它可以工作,并打开了新窗口,但我无法将 HTML/文本写入新文件。我收到那个错误: Cannot read proper
我们对 QIODevice::write 的一般行为和具体的 QTcpSocket 实现感到非常困惑。有一个 similar question已经,但答案并不令人满意。主要的混淆源于分别提到的 byt
我知道这听起来像是一个愚蠢的问题: write(*,*) 和 write(6,*) ?我在我研究所的 super 计算机上运行一个复杂的代码,它通过一个不同于 6 的单元号输出一个数据文件,显然编译的
我有一个结构体,它可以通过一系列复杂的方法调用转换为文本,其中包含大量 write!调用。此文本可以写入文件或调试日志。我正在决定是否使用 fmt::Write 或 io::Write .我不能真正使
已关闭。这个问题是 not reproducible or was caused by typos 。目前不接受答案。 这个问题是由拼写错误或无法再重现的问题引起的。虽然类似的问题可能是 on-top
In the C standard library, an output can't be followed by an input and vice versa. 对于Linux API,可以在re
我希望能够为一件事做 document.write。然后延迟半秒,然后再记录。写一些。你知道这是否可能吗?而且,如果是这样,怎么办?到目前为止,我已经尝试过了,但没有奏效: document.writ
为什么通过 onclick 属性调用的 write() 函数解析为 document.write() 并替换文档?有什么办法可以阻止这种情况发生吗? Write Function Alternat
我想创建一个包含多个“页面”的文本文件,并将每个页面的字节偏移量记录在一个单独的文件中。为此,我将字符串打印到主输出文件并使用 bytes_written += file.write(str) 计算字
关闭。这个问题需要更多focused .它目前不接受答案。 想改进这个问题吗? 更新问题,使其只关注一个问题 editing this post . 关闭 8 年前。 Improve this qu
我是一名优秀的程序员,十分优秀!