java Server and Client
Demo Server:
public class DemoServer {
public static void main(String[] args) throws IOException{
Server<Person> server = new Server<>(Person.class,null,null);
server.addPacketListener(10, new PacketListener<Person>() {
@Override
public void readPacket(Person client, Packet packet) {
client.print(packet.readString());
client.sendPacket(packet.clear().writeString("Received message Time: "+Long.toString(Calendar.getInstance().getTimeInMillis())).flip());
}
});
server.open(new InetSocketAddress(9090));
}
public static class Person extends AbstractClient<Person>{
public Person(Server<Person> server, SelectionKey selectionKey) {
super(server, selectionKey);
}
public void print(String str){
System.out.println(str);
}
}
}Demo Client:
public class DemoClient {
public static void main(String[] args) throws IOException, InterruptedException {
Server<Client> server = new Server<>(Client.class, null, null);
Client client = server.connect(new InetSocketAddress(9090));
while (true){
String str = client.sendPacket(new Packet(10).writeString("Hello java server").flip(), new CallablePacketListener<Client, String>() {
@Override
public String readPacket(Client client, Packet packet) {
return packet.readString();
}
},4000);
System.out.println(str);
Thread.sleep(1000);
}
}
}