Darkress/PixelFloodClient
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

some try catching

Browse Source
This commit is contained in:
Darkress
2023-06-10 04:35:09 +02:00
parent d1bbb97ebf
commit 3a66b22c93
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
de/darkress/pixelfood/Main.java
View File

@@ -9,9 +9,13 @@ import java.util.ArrayList;
class Worker extends Thread { class Worker extends Thread {
String HOSTNAME;
int PORT;
Socket socket; Socket socket;
String[] pixelArray; String[] pixelArray;
public Worker(String HOSTNAME, int PORT, String[] pixelArray) { public Worker(String HOSTNAME, int PORT, String[] pixelArray) {
this.HOSTNAME = HOSTNAME;
this.PORT = PORT;
try { try {
this.socket = new Socket(HOSTNAME, PORT); this.socket = new Socket(HOSTNAME, PORT);
} catch (IOException e) { } catch (IOException e) {
@@ -20,15 +24,21 @@ class Worker extends Thread {
this.pixelArray = pixelArray; this.pixelArray = pixelArray;
} }
@Override
public void run() { public void run() {
while(true) { while(true) {
try {
for(int i = 0; i < pixelArray.length; i++) { for(int i = 0; i < pixelArray.length; i++) {
byte[] payload = pixelArray[i].getBytes(); byte[] payload = pixelArray[i].getBytes();
try {
socket.getOutputStream().write(payload); socket.getOutputStream().write(payload);
} catch (IOException e) {
throw new RuntimeException(e);
} }
} catch (IOException e) {
try {
this.socket = new Socket(HOSTNAME, PORT);
} catch (IOException i) {
i.printStackTrace();
}
System.out.println(this.getId() + "just dies. Trying again...");
} }
} }
} }