Java Networking
I have been having trouble with my file transfer program that I have
been writing over the past few weeks. It makes p2p to transfer files
and the two sides update each over based upon string being sent over
one port (5013) and the actual data being sent over another (5012).
This works great except for when the user on the receiving side
accepts the download the update only makes it to the user on the other
side 20% of the time. Bellow I have provided the class that manages
the socket.
//This manages the connection for the receiving side
package com.cpsoft.filetransfer.net;
import java.net.*;
import java.io.*;
import java.util.*;
import com.cpsoft.filetransfer.*;
import java.util.*;
public class SocketIO
{
private Socket s;
private Writer out;
private Scanner in;
private InListener listener;
public SocketIO(Socket s) throws Exception
{
this.s = s;
try
{
s.setTcpNoDelay(true);
s.setSendBufferSize(5);
out = new OutputStreamWriter(s.getOutputStream(),
"UTF-8");
in = new Scanner(this.s.getInputStream());
}
catch(Exception ex)
{
throw ex;
}
listener = new InListener();
listener.start();
}
public void SendUpdate(Update u)
{
try
{
out.write(u.toString());
out.flush();
}
catch (IOException ex)
{
ex.printStackTrace();
}
}
private ArrayList updateEvents = new ArrayList();
public void addUpdateListener(UpdateListener l)
{
updateEvents.add(l);
}
private class InListener extends Thread
{
public InListener()
{
super();
setPriority(Thread.MAX_PRIORITY);
}
public void run()
{
while(!interrupted())
{
if(in.hasNext())
{
try
{
Update u = Update.parseString(in.nextLine());
if(u.getStatus().equals(Update.ACCEPT))
{
for(int i = 0; i < updateEvents.size(); i+
+)
((UpdateListener)updateEvents.get(i)).AcceptUpdateReceieved(u);
}
else if(u.getStatus().equals(Update.CANCEL))
{
for(int i = 0; i < updateEvents.size(); i+
+)
((UpdateListener)updateEvents.get(i)).CancelUpdateReceieved(u);
}
else if(u.getStatus().equals(Update.DONE))
{
for(int i = 0; i < updateEvents.size(); i+
+)
((UpdateListener)updateEvents.get(i)).DoneUpdateReceieved(u);
}
else if(u.getStatus().equals(Update.REQUEST))
{
for(int i = 0; i < updateEvents.size(); i+
+)
((UpdateListener)updateEvents.get(i)).RequestUpdateReceieved(u);
}
else if(u.getStatus().equals(Update.DECLINE))
{
for(int i = 0; i < updateEvents.size(); i+
+)
((UpdateListener)updateEvents.get(i)).DeclineUpdateReceieved(u);
}
for(int i = 0; i < updateEvents.size(); i++)
((UpdateListener)updateEvents.get(i)).UpdateReceieved(u);
}
catch(Exception ex)
{
continue;
}
}
}
}
}
public void close()
{
try
{
listener.interrupt();
if(!s.isClosed())
s.close();
}
catch(Exception ex)
{
}
}
}
//Socket used on send side
package com.cpsoft.filetransfer.net;
import com.cpsoft.filetransfer.*;
import java.awt.event.*;
import java.net.*;
import java.io.*;
import java.util.*;
public class SendUpdateSocket extends Socket
{
public PrintWriter out;
public Scanner in;
private Thread inbound;
public SendUpdateSocket(InetAddress host, int port) throws
IOException
{
super(host, port);
}
public SendUpdateSocket()
{
super();
}
private ArrayList updateListeners = new ArrayList();
public void connect(SocketAddress endpoint) throws IOException
{
super.connect(endpoint);
inbound = new InboundManager();
out = new PrintWriter(getOutputStream());
in = new Scanner(getInputStream());
inbound.start();
setTcpNoDelay(true);
}
public void addUpdateListener(UpdateListener u)
{
updateListeners.add(u);
}
public void SendUpdate(Update u)
{
out.println(u.toString());
out.flush();
}
public void close() throws IOException
{
super.close();
inbound.interrupt();
}
private class InboundManager extends Thread
{
public InboundManager()
{
super();
setPriority(Thread.MAX_PRIORITY);
}
public void run()
{
System.out.println("RUNNING");
while(!interrupted())
{
if(in.hasNext())
{
try
{
Update u = Update.parseString(in.nextLine());
if(u.getStatus().equals(Update.ACCEPT))
{
for(int i = 0; i < updateListeners.size();
i++)
((UpdateListener)updateListeners.get(i)).AcceptUpdateReceieved(u);
}
else if(u.getStatus().equals(Update.CANCEL))
{
for(int i = 0; i < updateListeners.size();
i++)
((UpdateListener)updateListeners.get(i)).CancelUpdateReceieved(u);
}
else if(u.getStatus().equals(Update.DONE))
{
for(int i = 0; i < updateListeners.size();
i++)
((UpdateListener)updateListeners.get(i)).DoneUpdateReceieved(u);
}
else if(u.getStatus().equals(Update.REQUEST))
{
for(int i = 0; i < updateListeners.size();
i++)
((UpdateListener)updateListeners.get(i)).RequestUpdateReceieved(u);
}
else if(u.getStatus().equals(Update.DECLINE))
{
for(int i = 0; i < updateListeners.size();
i++)
((UpdateListener)updateListeners.get(i)).DeclineUpdateReceieved(u);
}
for(int i = 0; i < updateListeners.size(); i+
+)
((UpdateListener)updateListeners.get(i)).UpdateReceieved(u);
}
catch(Exception ex)
{
ex.printStackTrace();
}
}
}
}
}
}