I'm writing a program that requires an image to be fetched from a remote server every 10 milliseconds or so, as that's how often the image is updated. My current method calls a timer to grab the image, but it encounters Socket Closed errors all the time, and sometimes does not work at all.
How can I fix my methods to keep the socket open the whole time, so no reconnecting is needed?
Here is the full class:
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.Timer;
public class Connection {
public static void createServer() throws IOException {
Capture.getScreen();
ServerSocket socket = null;
try {
socket = new ServerSocket(12345, 0,
InetAddress.getByName("127.0.0.1"));
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
System.out.println("Server started on "
+ socket.getInetAddress().getHostAddress() + ":"
+ socket.getLocalPort() + ",\nWaiting for client to connect.");
final Socket clientConnection = socket.accept();
System.out.println("Client accepted from "
+ clientConnection.getInetAddress().getHostAddress()
+ ", sending file");
ActionListener taskPerformer = new ActionListener() {
public void actionPerformed(ActionEvent evt) {
System.out.println("Sending File");
try {
pipeStreams(new FileInputStream(new File(
"captures/sCap.png")),
clientConnection.getOutputStream(), 1024);
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
};
System.out.println("closing out connection");
try {
clientConnection.close();
} catch (IOException e) {
e.printStackTrace();
}
try {
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
Timer timer = new Timer(10, taskPerformer);
timer.setRepeats(true);
timer.start();
}
public static void createClient() throws IOException {
System.out.println("Connecting to server.");
final Socket socket = new Socket();
try {
socket.connect(new InetSocketAddress(InetAddress
.getByName("127.0.0.1"), 12345));
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
}
ActionListener taskPerformer = new ActionListener() {
public void actionPerformed(ActionEvent evt) {
System.out.println("Success, retreiving file.");
try {
pipeStreams(socket.getInputStream(), new FileOutputStream(
new File("captures/rCap.png")), 1024);
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
}
}
};
System.out.println("Closing connection");
try {
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
Timer timer = new Timer(10, taskPerformer);
timer.setRepeats(true);
timer.start();
}
public static void pipeStreams(java.io.InputStream source,
java.io.OutputStream destination, int bufferSize)
throws IOException {
byte[] buffer = new byte[bufferSize];
int read = 0;
while ((read = source.read(buffer)) != -1) {
destination.write(buffer, 0, read);
}
destination.flush();
destination.close();
source.close();
}
}
