rik/mimis
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Delete obsolete code for testing TCP client/server model

Browse Source
This commit is contained in:
Rik Veenboer
2015-06-15 23:01:22 +01:00
parent 139bb64b0b
commit 6290eb98da
5 changed files with 0 additions and 99 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
java/base/src/main/java/test/server/TestTcpCommunication.java
View File

@@ -1,24 +0,0 @@
package test.server;
import test.server.dummy.DummyChannelTcpClient;
import test.server.dummy.DummySocketTcpClient;
import test.server.dummy.DummyTcpServerClient;
import test.server.dummy.DummyWriter;
import base.server.channel.TcpServer;
public class TestTcpCommunication {
public static void main(String[] args) {
try {
// Test client > server
new TcpServer(1234, DummyTcpServerClient.class).start();
DummySocketTcpClient client1 = new DummySocketTcpClient("localhost", 1234);
DummyChannelTcpClient client2 = new DummyChannelTcpClient("localhost", 1234);
client1.start();
client2.start();
Thread.sleep(1000);
client1.send("Succes!".getBytes());
new DummyWriter(client1).start();
} catch (Exception e) {}
}
}

13
java/base/src/main/java/test/server/dummy/DummyChannelTcpClient.java
View File

@@ -1,13 +0,0 @@
package test.server.dummy;
import base.server.socket.TcpClient;
public class DummyChannelTcpClient extends TcpClient {
public DummyChannelTcpClient(String host, int port) {
super(host, port);
}
public void input(byte[] buffer) {
System.out.println("Client: " + new String(buffer).trim());
}
}

13
java/base/src/main/java/test/server/dummy/DummySocketTcpClient.java
View File

@@ -1,13 +0,0 @@
package test.server.dummy;
import base.server.socket.TcpClient;
public class DummySocketTcpClient extends TcpClient {
public DummySocketTcpClient(String host, int port) {
super(host, port);
}
public void input(byte[] buffer) {
System.out.println("Client: " + new String(buffer).trim());
}
}

17
java/base/src/main/java/test/server/dummy/DummyTcpServerClient.java
View File

@@ -1,17 +0,0 @@
package test.server.dummy;
import java.io.IOException;
import java.nio.channels.SocketChannel;
import base.server.channel.TcpServer;
import base.server.channel.TcpServerClient;
public class DummyTcpServerClient extends TcpServerClient {
public DummyTcpServerClient(TcpServer server, SocketChannel socketChannel, Integer bufferSize) {
super(server, socketChannel, bufferSize);
}
public void input(byte[] buffer) {
server.input(this, buffer);
}
}

32
java/base/src/main/java/test/server/dummy/DummyWriter.java
View File

@@ -1,32 +0,0 @@
package test.server.dummy;
import java.io.IOException;
import base.sender.Sender;
import base.work.Work;
public class DummyWriter extends Work implements Sender {
private Sender sender;
public DummyWriter(Sender sender) {
this.sender = sender;
}
public void work() {
System.out.println("Client sending messages to server...");
String [] messages = new String[] {"Time goes fast.", "What now?", "Bye."};
try {
for (int i = 0; i < messages.length; i++) {
System.out.println(messages[i]);
send(new String(messages[i]).getBytes());
sleep(200);
}
stop();
} catch (Exception e) {}
}
public void send(byte[] buffer) throws IOException {
sender.send(buffer);
}
}