/** *SocketConnection.java */package gameFrameWork.communicationcontrol;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.InetAddress;import java.net.ServerSocket;import java.net.Socket;public class SocketConnection implements Connection, Runnable{ //the port we gonna connect to //this port must be open //we should get this port from a config file/ as argument int inputport; int outputport; //inputstream InputStream is; //outputstream OutputStream os; //the inetaddress we are connected to InetAddress inetaddress; BufferedReader reader; MessageHandler handler; boolean run; //thread Thread t; /** * constructor * this constructor will wait till a client connection is made to this socket * @param inetaddress the inetaddress this connection should connecto to * @param handler the messagehanlder this connection should report to * @param inputport the port used for input * @param outputport the port used for output * @throws IOException */ public SocketConnection(MessageHandler handler, InetAddress ip,int inputport,int outputport) throws IOException { System.out.println("starting socketconnection"); this.handler = handler; this.inetaddress = inetaddress; inputport = inputport; outputport = outputport; run = true; t = new Thread(this); t.start(); System.out.println("thread started, sleeping 10 seconds"); try { Thread.sleep(1000); } catch (InterruptedException e) { System.out.println("sleep failed"); e.printStackTrace(); } System.out.println("done with sleeping, "); System.out.println("making new outputsocket"); os = new Socket(ip,outputport).getOutputStream(); System.out.println("done: socketconnection"); } /** * @return the inputstream of this connection */ public InputStream getInputStream( ){ return is; } /** * @return the outputstream of this connection */ public OutputStream getOutputStream( ){ return os; } public InetAddress getIp() { return inetaddress; } /** * is this really needed? */ public void setIp(InetAddress ip) { if(!this.inetaddress.equals(ip)){ throw new UnsupportedOperationException("not implemented yet"); } } public void run() { System.out.println("run started"); //open the serversocket ServerSocket serversocket = null; Socket socket = null; try { serversocket = new ServerSocket(inputport); System.out.println("serversocket made"); System.out.println("serversocket is boud:" + serversocket.isBound()); try { //getting a connectiong (this can take some time) socket = serversocket.accept(); System.out.println("serversocket caught something"); try { //get thie inputstream from the socket is = socket.getInputStream(); //make the bufferedreader reader = new BufferedReader(new InputStreamReader(is)); //listen to reader, and call handler.messageRecieved if something comes up while (run){ try { System.out.println("socket caught something, calling messagerecieved"); handler.messageReceived(reader.readLine()); } catch (IOException e) { System.out.println("IOError in readerlistener\nThis should be a feature, not a bug"); System.out.println("closing socket"); run = false; } } } catch (IOException e1) { System.out.println("IOError when getting inputstream from clientsocket"); System.out.println("closing socket"); e1.printStackTrace(); } } catch (IOException e1) { System.out.println("IOError when getting clientsocket from serversocket"); System.out.println("closing socket"); e1.printStackTrace(); } } catch (IOException e1) { // TODO wat doen we met erros? handler verwittigen? System.out.println("IOError when setting up serversocket; "); System.out.println("closing socket"); e1.printStackTrace(); }finally{ //try to close the sockets try { serversocket.close(); socket.close(); } catch (IOException e) { //do nothing } } System.out.println("run: done"); } /** * requests a stop * don't know if this will actually work * but we can always stop the runnable if we close the connection, * and we will get an IOExeption in the run */ public void requestStop(){ run = false; }}