55 lines
2.0 KiB
Java
55 lines
2.0 KiB
Java
|
|
||
|
|
|
||
|
|
import com.mobilerobots.Aria.*;
|
||
|
|
|
||
|
|
public class socket {
|
||
|
|
|
||
|
|
static {
|
||
|
|
try {
|
||
|
|
System.loadLibrary("AriaJava");
|
||
|
|
} catch (UnsatisfiedLinkError e) {
|
||
|
|
System.err.println("Native code library libAriaJava failed to load. Make sure that its directory is in your library path; See javaExamples/README.txt and the chapter on Dynamic Linking Problems in the SWIG Java documentation (http://www.swig.org) for help.\n" + e);
|
||
|
|
System.exit(1);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public static void main(String argv[]) {
|
||
|
|
Aria.init();
|
||
|
|
ArSocket s1 = new ArSocket(); // server socket. accepts clients.
|
||
|
|
ArSocket s2 = new ArSocket(); // client
|
||
|
|
ArSocket s1client = new ArSocket(); // used by server to communicate with client
|
||
|
|
if (!s1.open(6789, ArSocket.Type.TCP)) {
|
||
|
|
System.err.println("Error opening first TCP socket on port 6789.");
|
||
|
|
Aria.exit(1);
|
||
|
|
}
|
||
|
|
System.out.println("First socket opened and listening on port 6789.");
|
||
|
|
System.out.println("Connecting second socket to localhost port 6789...");
|
||
|
|
if (!s2.connect("localhost", 6789)) {
|
||
|
|
System.err.println("Error connecting second TCP socket to local host port 6789");
|
||
|
|
Aria.exit(2);
|
||
|
|
}
|
||
|
|
if (!s1.accept(s1client)) {
|
||
|
|
System.err.println("Error accepting client on first socket.");
|
||
|
|
Aria.exit(3);
|
||
|
|
}
|
||
|
|
System.out.println("Connected.");
|
||
|
|
System.out.println("Second socket is sending \"hello\" to first...");
|
||
|
|
s2.write("hello");
|
||
|
|
String text = new String("");
|
||
|
|
text = s1client.read(512, 5000); // arguments are buffer size and timeout to wait
|
||
|
|
/*
|
||
|
|
while(text.length() == 0)
|
||
|
|
{
|
||
|
|
text = s1client.read(512, 5000); // arguments are buffer size and timeout to wait
|
||
|
|
}
|
||
|
|
*/
|
||
|
|
System.out.println("=> First socket recieved \""+text+"\" ("+text.length()+")");
|
||
|
|
System.out.println("First socket is sending \"hello\" to second...");
|
||
|
|
s1client.write("hello");
|
||
|
|
text = s2.read(512, 5000);
|
||
|
|
System.out.println("=> Second socket recieved \""+text+"\"");
|
||
|
|
s2.close();
|
||
|
|
Aria.exit(0);
|
||
|
|
}
|
||
|
|
}
|