import xdi2.core.io.XDIWriterRegistry; //导入依赖的package包/类
public static void main(String[] args) throws Exception {

		// create a simple graph with context nodes, a relation, and a literal

		Graph graph = MemoryGraphFactory.getInstance().openGraph();

		ContextNode root = graph.getRootContextNode();
		ContextNode markus = root.setContextNode(XDIArc.create("=markus"));
		ContextNode animesh = root.setContextNode(XDIArc.create("=animesh"));
		ContextNode name = markus.setContextNode(XDIArc.create("<#name>"));
		Relation relation = markus.setRelation(XDIAddress.create("#friend"), animesh);
		LiteralNode literalNode = name.setLiteralNode("Markus Sabadello");

		// write some statements from our graph

		System.out.println("Statement associated with a context node: " + markus.getStatement());
		System.out.println("Statement associated with a relation: " + relation.getStatement());
		System.out.println("Statement associated with a literal: " + literalNode.getStatement());
		System.out.println();

		// we can also add a whole new statement to the graph

		graph.setStatement(XDIStatement.create("=alice/#friend/=bob"));

		// write the whole graph in different serialization formats

		System.out.println("Serialization in XDI/JSON: \n");
		XDIWriterRegistry.forFormat("XDI/JSON", null).write(graph, System.out);
		System.out.println();
		System.out.println();

		System.out.println("Serialization in XDI statements:\n");
		XDIWriterRegistry.forFormat("XDI DISPLAY", null).write(graph, System.out);

		// close the graph

		graph.close();
	}
 

import xdi2.core.io.XDIWriterRegistry; //导入依赖的package包/类
public boolean linkContractExists(String connectRequest) {
	System.out.println("\nChecking if a link contract exists\n");
	boolean result = false;
	MemoryJSONGraphFactory graphFactory = new MemoryJSONGraphFactory();
	String templateOwnerInumber = null;
	try {
		Graph g = graphFactory.parseGraph(connectRequest);
		// get remote cloud number

		XDIWriterRegistry.forFormat("XDI DISPLAY", null).write(g,
				System.out);
		ContextNode c = g.getRootContextNode();
		ReadOnlyIterator<ContextNode> allCNodes = c.getAllContextNodes();
		for (ContextNode ci : allCNodes) {
			if (ci.containsContextNode(XDI3SubSegment.create("[$msg]"))) {
				templateOwnerInumber = ci.toString();
				System.out.println(templateOwnerInumber);
				break;
			}
		}
		if (templateOwnerInumber == null) {
			System.out
					.println("No cloudnumber for requestor/template owner");
			return result;
		}
		// get the address of the link contract template
		// $set{$do}

		String lcTemplateAddress = null;

		ReadOnlyIterator<Relation> allRelations = c.getAllRelations(); // g.getDeepRelations(XDI3Segment.create(templateOwnerInumber),XDI3Segment.create("$get"));
		for (Relation r : allRelations) {
			if (r.getArcXri().toString().equals("$set{$do}")) {
				lcTemplateAddress = r.getTargetContextNodeXri().toString();
				System.out.println(r.getTargetContextNodeXri());
			}

		}
		if (lcTemplateAddress == null) {
			System.out.println("No LC template address provided");
			return result;
		}
	} catch (Exception io) {
		io.printStackTrace();
		return result;
	}

	String isPlusstmt = new String();
	isPlusstmt += this.cloudNumber;
	isPlusstmt += "$to";
	isPlusstmt += templateOwnerInumber;
	isPlusstmt += "$from";
	isPlusstmt += templateOwnerInumber;
	isPlusstmt += "+registration$do";

	ArrayList<XDI3Segment> querySegments = new ArrayList<XDI3Segment>();

	querySegments.add(XDI3Segment.create(isPlusstmt));

	MessageResult responseFromRemoteCloud = this.sendQueries(querySegments,
			null, false);

	Graph responseGraph = responseFromRemoteCloud.getGraph();
	ContextNode responseRootContext = responseGraph.getRootContextNode();
	System.out.println("\n\nLink Contract exists check\n\n"
			+ responseGraph.toString());
	if (responseRootContext.getContextNodeCount() > 1) {
		result = true;
	}

	return result;
}
 

import xdi2.core.io.XDIWriterRegistry; //导入依赖的package包/类
@Override
protected void callbackGraph(String messagingContainerPath, Graph graph, MyState state) throws Xdi2ClientException, IOException {

	GraphMessagingContainer commandGraphMessagingContainer = new GraphMessagingContainer();
	commandGraphMessagingContainer.setGraph(graph);

	MessageEnvelope commandMessageEnvelope = MessageEnvelope.fromOperationXDIAddressAndTargetXDIAddressOrTargetXDIStatement(XDIAddress.create(state.operation), state.target);
	MessagingResponse commandMessagingResponse;

	commandMessagingResponse = new XDILocalClient(commandGraphMessagingContainer).send(commandMessageEnvelope);

	XDIWriter writer = state.mimeType == null ? XDIWriterRegistry.getDefault() : XDIWriterRegistry.forMimeType(new MimeType(state.mimeType));
	writer.write(commandMessagingResponse.getResultGraph(), System.out);

	System.out.println("At path " + messagingContainerPath + " executed message on graph " + graph.getClass().getSimpleName());
}
 

import xdi2.core.io.XDIWriterRegistry; //导入依赖的package包/类
@Override
protected void callbackGraph(String messagingContainerPath, Graph graph, MyState state) throws Xdi2MessagingException, IOException {

	System.out.println("Rebuilding graph " + messagingContainerPath + ".");

	XDIWriter writer = state.mimeType == null ? XDIWriterRegistry.getDefault() : XDIWriterRegistry.forMimeType(new MimeType(state.mimeType));
	XDIReader reader = new AutoReader(null);

	try {

		if (writer == null) throw new RuntimeException("Unknown MIME type " + state.mimeType);

		StringWriter stringWriter = new StringWriter();
		writer.write(graph, stringWriter);

		graph.clear();

		StringReader stringReader = new StringReader(stringWriter.toString());
		reader.read(graph, stringReader);
	} catch (Exception ex) {

		System.err.println("Problem while rebuilding graph " + messagingContainerPath);
		ex.printStackTrace(System.err);
	}
}
 

import xdi2.core.io.XDIWriterRegistry; //导入依赖的package包/类
@Override
protected void callbackGraph(String messagingContainerPath, Graph graph, MyState state) throws Xdi2MessagingException, IOException {

	XDIWriter writer = state.mimeType == null ? XDIWriterRegistry.getDefault() : XDIWriterRegistry.forMimeType(new MimeType(state.mimeType));

	try {

		if (writer == null) throw new RuntimeException("Unknown MIME type " + state.mimeType);

		writer.write(graph, System.out);
	} catch (Exception ex) {

		System.err.println("Problem while dumping graph " + messagingContainerPath);
		ex.printStackTrace(System.err);
	}
}
 

import xdi2.core.io.XDIWriterRegistry; //导入依赖的package包/类
@Override
protected void callbackGraph(String messagingContainerPath, Graph graph, MyState state) throws Xdi2MessagingException, IOException {

	String zipEntryName = messagingContainerPath + ".xdi";
	if (zipEntryName.startsWith("/")) zipEntryName = zipEntryName.substring(1);

	ZipEntry zipEntry = new ZipEntry(zipEntryName);
	state.zipOutputStream.putNextEntry(zipEntry);

	System.out.println("Backing up graph " + messagingContainerPath + ".");

	XDIWriter writer = state.mimeType == null ? XDIWriterRegistry.getDefault() : XDIWriterRegistry.forMimeType(new MimeType(state.mimeType));

	try {

		if (writer == null) throw new RuntimeException("Unknown MIME type " + state.mimeType);

		writer.write(graph, state.zipOutputStream);
	} catch (Exception ex) {

		System.err.println("Problem while backing up graph " + messagingContainerPath);
		ex.printStackTrace(System.err);
	}

	state.zipOutputStream.closeEntry();
}
 

import xdi2.core.io.XDIWriterRegistry; //导入依赖的package包/类
public static void main(String[] args) throws Exception {

		LogManager.getLogger("xdi2").setLevel(Level.OFF);

		XDIWriter writer = XDIWriterRegistry.forFormat("XDI DISPLAY", null);

		// discovery

		XDIDiscoveryClient xdiDiscoveryClient = XDIDiscoveryClient.DEFAULT_DISCOVERY_CLIENT;
		XDIDiscoveryResult xdiDiscoveryResult = xdiDiscoveryClient.discoverFromRegistry(XDIAddress.create("=markus"));

		// construct message

		MessageEnvelope messageEnvelope = new MessageEnvelope();
		Message message = messageEnvelope.createMessage(XDIAddress.create("=sender"));
		message.createGetOperation(XDIAddress.create("=markus<#email>"));
		message.setToPeerRootXDIArc(xdiDiscoveryResult.getCloudNumber().getPeerRootXDIArc());
		message.setLinkContractClass(PublicLinkContract.class);

		// construct client, send message, read result

		XDIClient client = new XDIHttpClient(xdiDiscoveryResult.getXdiEndpointUri());

		MessagingResponse messagingResponse = client.send(messageEnvelope);

		// print results

		System.out.println("Discovery result: ");
		writer.write(xdiDiscoveryResult.getMessagingResponse().getGraph(), System.out);
		System.out.println();

		System.out.println("Message envelope: ");
		writer.write(messageEnvelope.getGraph(), System.out);
		System.out.println();

		System.out.println("Messaging response: ");
		writer.write(messagingResponse.getGraph(), System.out);
	}