Для получения входных данных вы можете использовать поток, подобный этому:
public class MyReceiver extends Thread {
...
public void run() {
try {
Message msgIn = inputStream.read();
msgIn.processMessage();
// Create a class Message with a method like this for generic data handling
// so if you have different types of message (text, comands, ...) each one becomes a class extending
// Message and implementing this method for its own purpose
} catch {
// Error handling, like disconections...
}
}
...
}
Для отправки данных вы можете просто открыть outputStream, написать на нем и сбросить:
OutputStream msgSender;
//Initialize and open you output stream
msgSender.write("Some cool message");
msgSender.flush();