You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
161 lines
5.5 KiB
161 lines
5.5 KiB
//package com.zerotier.libzt.javasimpleexample; |
|
|
|
import com.zerotier.libzt.ZeroTier; |
|
import com.zerotier.libzt.ZeroTierEventListener; |
|
import java.math.BigInteger; |
|
|
|
public class Example { |
|
|
|
static void sleep(int ms) { |
|
try { |
|
Thread.sleep(ms); |
|
} catch (InterruptedException e) { |
|
e.printStackTrace(); |
|
} |
|
} |
|
|
|
public static void main(String[] args) { |
|
String keyPath="."; // Default to current directory |
|
BigInteger networkId; |
|
Integer servicePort=0; |
|
if (args.length != 3) { |
|
System.err.println(" Invalid arguments"); |
|
System.err.println(" Usage: example <path_to_write_keys> <nwid> <ztServicePort>"); |
|
System.exit(1); |
|
} |
|
keyPath = args[0]; |
|
networkId = new BigInteger(args[1], 16); |
|
servicePort = Integer.parseInt(args[2]); |
|
System.out.println("networkId = " + Long.toHexString(networkId.longValue())); |
|
System.out.println("keyPath = " + keyPath); |
|
System.out.println("servicePort = " + servicePort); |
|
|
|
// |
|
// BEGIN SETUP |
|
// |
|
|
|
// Set up event listener and start service |
|
MyZeroTierEventListener listener = new MyZeroTierEventListener(); |
|
ZeroTier.start(keyPath, (ZeroTierEventListener)listener, servicePort); |
|
// Wait for EVENT_NODE_ONLINE |
|
System.out.println("waiting for node to come online..."); |
|
while (listener.isOnline == false) { sleep(50); } |
|
System.out.println("joining network"); |
|
ZeroTier.join(networkId.longValue()); |
|
// Wait for EVENT_NETWORK_READY_IP4/6 |
|
System.out.println("waiting for network config..."); |
|
while (listener.isNetworkReady == false) { sleep(50); } |
|
System.out.println("joined"); |
|
|
|
// |
|
// END SETUP |
|
// |
|
|
|
sleep(120000); |
|
|
|
/** |
|
* |
|
* Begin using socket API after this point: |
|
* |
|
* ZeroTier.ZeroTierSocket, ZeroTier.ZeroTierSocketFactory, etc |
|
* |
|
* (or) |
|
* |
|
* ZeroTier.socket(), ZeroTier.connect(), etc |
|
*/ |
|
} |
|
} |
|
|
|
/** |
|
* Example event handling |
|
*/ |
|
class MyZeroTierEventListener implements ZeroTierEventListener { |
|
|
|
public boolean isNetworkReady = false; |
|
public boolean isOnline = false; |
|
|
|
public void onZeroTierEvent(long id, int eventCode) { |
|
if (eventCode == ZeroTier.EVENT_NODE_UP) { |
|
System.out.println("EVENT_NODE_UP: nodeId=" + Long.toHexString(id)); |
|
} |
|
if (eventCode == ZeroTier.EVENT_NODE_ONLINE) { |
|
// The core service is running properly and can join networks now |
|
System.out.println("EVENT_NODE_ONLINE: nodeId=" + Long.toHexString(id)); |
|
isOnline = true; |
|
} |
|
if (eventCode == ZeroTier.EVENT_NODE_OFFLINE) { |
|
// Network does not seem to be reachable by any available strategy |
|
System.out.println("EVENT_NODE_OFFLINE"); |
|
} |
|
if (eventCode == ZeroTier.EVENT_NODE_DOWN) { |
|
// Called when the node is shutting down |
|
System.out.println("EVENT_NODE_DOWN"); |
|
} |
|
if (eventCode == ZeroTier.EVENT_NODE_IDENTITY_COLLISION) { |
|
// Another node with this identity already exists |
|
System.out.println("EVENT_NODE_IDENTITY_COLLISION"); |
|
} |
|
if (eventCode == ZeroTier.EVENT_NODE_UNRECOVERABLE_ERROR) { |
|
// Try again |
|
System.out.println("EVENT_NODE_UNRECOVERABLE_ERROR"); |
|
} |
|
if (eventCode == ZeroTier.EVENT_NODE_NORMAL_TERMINATION) { |
|
// Normal closure |
|
System.out.println("EVENT_NODE_NORMAL_TERMINATION"); |
|
} |
|
if (eventCode == ZeroTier.EVENT_NETWORK_READY_IP4) { |
|
// We have at least one assigned address and we've received a network configuration |
|
System.out.println("ZTS_EVENT_NETWORK_READY_IP4: nwid=" + Long.toHexString(id)); |
|
isNetworkReady = true; |
|
} |
|
if (eventCode == ZeroTier.EVENT_NETWORK_READY_IP6) { |
|
// We have at least one assigned address and we've received a network configuration |
|
System.out.println("ZTS_EVENT_NETWORK_READY_IP6: nwid=" + Long.toHexString(id)); |
|
//isNetworkReady = true; |
|
} |
|
if (eventCode == ZeroTier.EVENT_NETWORK_DOWN) { |
|
// Someone called leave(), we have no assigned addresses, or otherwise cannot use this interface |
|
System.out.println("EVENT_NETWORK_DOWN: nwid=" + Long.toHexString(id)); |
|
} |
|
if (eventCode == ZeroTier.EVENT_NETWORK_REQ_CONFIG) { |
|
// Waiting for network configuration |
|
System.out.println("EVENT_NETWORK_REQ_CONFIG: nwid=" + Long.toHexString(id)); |
|
} |
|
if (eventCode == ZeroTier.EVENT_NETWORK_OK) { |
|
// Config received and this node is authorized for this network |
|
System.out.println("EVENT_NETWORK_OK: nwid=" + Long.toHexString(id)); |
|
} |
|
if (eventCode == ZeroTier.EVENT_NETWORK_ACCESS_DENIED) { |
|
// You are not authorized to join this network |
|
System.out.println("EVENT_NETWORK_ACCESS_DENIED: nwid=" + Long.toHexString(id)); |
|
} |
|
if (eventCode == ZeroTier.EVENT_NETWORK_NOT_FOUND) { |
|
// The virtual network does not exist |
|
System.out.println("EVENT_NETWORK_NOT_FOUND: nwid=" + Long.toHexString(id)); |
|
} |
|
if (eventCode == ZeroTier.EVENT_NETWORK_CLIENT_TOO_OLD) { |
|
// The core version is too old |
|
System.out.println("EVENT_NETWORK_CLIENT_TOO_OLD: nwid=" + Long.toHexString(id)); |
|
} |
|
if (eventCode == ZeroTier.EVENT_PEER_DIRECT) { |
|
System.out.println("EVENT_PEER_DIRECT: id=" + Long.toHexString(id)); |
|
/* |
|
ZeroTierPeerDetails details = new ZeroTierPeerDetails(); |
|
ZeroTier.get_peer(id, details); |
|
System.out.println("address="+Long.toHexString(details.address)); |
|
System.out.println("pathCount="+details.pathCount); |
|
System.out.println("version="+details.versionMajor+"."+details.versionMinor+"."+details.versionRev); |
|
System.out.println("latency="+details.latency); // Not relevant |
|
System.out.println("role="+details.role); // Not relevent |
|
// Print all known paths |
|
for (int i=0; i<details.pathCount; i++) { |
|
System.out.println("addr="+details.paths[i].toString()); |
|
} |
|
*/ |
|
} |
|
if (eventCode == ZeroTier.EVENT_PEER_RELAY) { |
|
System.out.println("EVENT_PEER_RELAY: id=" + Long.toHexString(id)); |
|
} |
|
} |
|
} |
|
|
|
|