андроид и сокеты

Question

Я пишу клиент-серверное приложение. Клиент на Android, сервер на простой Java. Я хочу, чтобы клиент установил соединение с сервером, затем отправил ему какой-то файл, затем сервер записал этот файл на сервер-диск и затем отправил клиенту другой файл. Сейчас клиент устанавливает соединение, затем отправляет файл на сервер, но здесь начинаются проблемы. Когда я хочу, чтобы сервер отправил файл клиенту, я получаю исключение «сокет близко».

Вот мой код:

Сервер:

public class ThreadHandler implements Runnable
{
public ThreadHandler(Socket i)
{ 
    sk = i; 
}

public void run()
{  
    try
    {
        File file = getFile();
        ParseData data = parseXML(file);

        if(data.getEvent().equals("registration"))
        {
            sendRegistrationResponse();
        }
    }
    catch(Exception e)
    {
        e.printStackTrace();
    }
}

public File getFile() throws Exception
{
    File file=null;

    InputStream input = sk.getInputStream();

    file = new File("C://protocolFile/" + "temp.xml");
    FileOutputStream out = new FileOutputStream(file);

    byte[] buffer = new byte[sk.getReceiveBufferSize()];

    int bytesReceived = 0;

    while((bytesReceived = input.read(buffer))>0) {
        out.write(buffer,0,bytesReceived);
    }

    input.close();
    input = null;
    out.flush();
    out.close();
    out = null;
    System.gc();

    return file;
}

public void sendRegistrationResponse() throws Exception
{
    String fileName = createRegistrationResponseXML();
    sendToApp(fileName);
}

public void sendToApp(String fileName) throws Exception
{
    OutputStream output = sk.getOutputStream();     

    FileInputStream fileInputStream = new FileInputStream(fileName);
    byte[] buffer = new byte[sk.getSendBufferSize()];
    int bytesRead = 0;

    while((bytesRead = fileInputStream.read(buffer))>0)
    {
        output.write(buffer,0,bytesRead);
    }

    output.close();
    fileInputStream.close();
}

}

клиент:

public class AndroidProtokolActivity extends Activity {

private File directory;

XmlSerializer serializer = Xml.newSerializer();
StringWriter writer=new StringWriter();;

Socket sk;

@Override
public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.main);
    directory = new File(Environment.getExternalStorageDirectory().getAbsolutePath() + File.separator + "protocol");
    directory.mkdirs();
}

public void fun(View view)
{
    Log.i("======", "fun==============");
    try
    {
        sk = new Socket("55.555.555.555", 5555);

        String registrationFile = createRegistrationXML(serializer);
        sendToServer(registrationFile,sk);
        getRegistrationXML();
    }
    catch(Exception e)
    {
        e.printStackTrace();
    }
}

public void sendToServer(String file, Socket sk) throws Exception
{
    Log.i("======", "sendToServer==============");
    OutputStream output = sk.getOutputStream();     

    String pathToOurFile = directory + File.separator + file;

    FileInputStream fileInputStream = new FileInputStream(pathToOurFile);
    byte[] buffer = new byte[sk.getSendBufferSize()];
    int bytesRead = 0;

    while((bytesRead = fileInputStream.read(buffer))>0)
    {
        output.write(buffer,0,bytesRead);
    }

    output.close();
    fileInputStream.close();
}

public File getRegistrationXML() throws Exception
{
    Log.i("======", "getRegistrationXML==============");
    File file=null;

    InputStream input = sk.getInputStream();

    file = new File(directory, "rejestracjaOdpowiedz.xml");
    FileOutputStream out = new FileOutputStream(file);

    byte[] buffer = new byte[sk.getReceiveBufferSize()];

    int bytesReceived = 0;

    while((bytesReceived = input.read(buffer))>0) {
        out.write(buffer,0,bytesReceived);
    }

    input.close();
    input = null;
    out.flush();
    out.close();
    out = null;
    System.gc();

    return file;
}
}

Я вырезал из этого кода создание функций XML-файлов. Я получаю "java.net.SocketException: сокет закрыт" в строке "OutputStream output = sk.getOutputStream ();" в функции «sendToApp» на стороне сервера и «java.net.SocketException: сокет закрыт» в строке «InputStream input = sk.getInputStream ();»; в строке «getRegistrationXML» в функции «getRegistrationXML» на стороне клиента. Я пытаюсь выяснить, что не так, но понятия не имею. Кто-нибудь из вас знает, что стоит за этим кодом? Спасибо за любую помощь.

EDIT:

Этот код показывает, как я создаю файл XML:

public String createRegistrationXML(XmlSerializer serializer) throws Exception
{
    Log.i("======", "createRegistrationXML==============");
    XmlSerializer serializer = Xml.newSerializer();
    writer = new StringWriter();
    serializer.setOutput(writer);

    serializer.startDocument("UTF-8", true);
        serializer.startTag("", XMLTag);
            serializer.startTag("", eventTag);
                serializer.text(REGISTRATIONEVENT);
            serializer.endTag("", eventTag);
        serializer.endTag("", XMLTag);
    serializer.endDocument();

    File outputFile = new File(directory, "file.xml");
    FileOutputStream fos = new FileOutputStream(outputFile);
    OutputStreamWriter osw = new OutputStreamWriter(fos); 
    osw.write(writer.toString());
    osw.flush();
    osw.close();

    return "file.xml";
}

Answer 1

Старайтесь не закрывать входной и выходной поток сокета по отдельности. Просто закройте сокет , когда все будет сделано.