Java sendet und empfängt Dateien (Byte []) über Sockets

Ich versuche zu entwickeln, die eine sehr einfache client /server, wo der client wandelt eine Datei in bytes, sendet es an den server, und dann wandelt die bytes in einer Datei.

Derzeit das Programm erzeugt nur eine leere Datei. Ich bin nicht eine fantastische Java-Entwickler, so dass jede Hilfe sehr geschätzt.

Dies ist der server-Teil, das empfängt, was der client sendet.

ServerSocket serverSocket = null;

    serverSocket = new ServerSocket(4444);


    Socket socket = null;
    socket = serverSocket.accept();

    DataOutputStream out = new DataOutputStream(new BufferedOutputStream(socket.getOutputStream()));
    DataInputStream in = new DataInputStream(new BufferedInputStream(socket.getInputStream()));
    byte[] bytes = new byte[1024];

    in.read(bytes);
    System.out.println(bytes);

    FileOutputStream fos = new FileOutputStream("C:\\test2.xml");
    fos.write(bytes);

Und hier ist der client-Teil

Socket socket = null;
    DataOutputStream out = null;
    DataInputStream in = null;
    String host = "127.0.0.1";     

    socket = new Socket(host, 4444);
    out = new DataOutputStream(new BufferedOutputStream(socket.getOutputStream()));
    in = new DataInputStream(new BufferedInputStream(socket.getInputStream()));

    File file = new File("C:\\test.xml");
    //InputStream is = new FileInputStream(file);
    //Get the size of the file
    long length = file.length();
    if (length > Integer.MAX_VALUE) {
        System.out.println("File is too large.");
    }
    byte[] bytes = new byte[(int) length];

    //out.write(bytes);
    System.out.println(bytes);

    out.close();
    in.close();
    socket.close();

InformationsquelleAutor der Frage Rookie | 2012-03-01

45

Ist die richtige Methode zum kopieren eines Streams in Java ist wie folgt:
```
int count;
byte[] buffer = new byte[8192]; //or 4096, or more
while ((count = in.read(buffer)) > 0)
{
  out.write(buffer, 0, count);
}
```
Wünschte, ich hätte einen dollar für jedes mal habe ich geschrieben, dass in einem forum.

InformationsquelleAutor der Antwort EJP

Danke für die Hilfe, ich habe es geschafft, es funktioniert jetzt, so dachte, ich würde post, damit die anderen verwenden können, um Ihnen zu helfen.

Server

public class Server {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = null;

        try {
            serverSocket = new ServerSocket(4444);
        } catch (IOException ex) {
            System.out.println("Can't setup server on this port number. ");
        }

        Socket socket = null;
        InputStream in = null;
        OutputStream out = null;

        try {
            socket = serverSocket.accept();
        } catch (IOException ex) {
            System.out.println("Can't accept client connection. ");
        }

        try {
            in = socket.getInputStream();
        } catch (IOException ex) {
            System.out.println("Can't get socket input stream. ");
        }

        try {
            out = new FileOutputStream("M:\\test2.xml");
        } catch (FileNotFoundException ex) {
            System.out.println("File not found. ");
        }

        byte[] bytes = new byte[16*1024];

        int count;
        while ((count = in.read(bytes)) > 0) {
            out.write(bytes, 0, count);
        }

        out.close();
        in.close();
        socket.close();
        serverSocket.close();
    }
}

und der Client

public class Client {
    public static void main(String[] args) throws IOException {
        Socket socket = null;
        String host = "127.0.0.1";

        socket = new Socket(host, 4444);

        File file = new File("M:\\test.xml");
        //Get the size of the file
        long length = file.length();
        byte[] bytes = new byte[16 * 1024];
        InputStream in = new FileInputStream(file);
        OutputStream out = socket.getOutputStream();

        int count;
        while ((count = in.read(bytes)) > 0) {
            out.write(bytes, 0, count);
        }

        out.close();
        in.close();
        socket.close();
    }
}

InformationsquelleAutor der Antwort Rookie

Hier ist der server
Öffnen Sie einen stream auf die Datei und senden Sie es overnetwork

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class SimpleFileServer {

  public final static int SOCKET_PORT = 5501;
  public final static String FILE_TO_SEND = "file.txt";

  public static void main (String [] args ) throws IOException {
    FileInputStream fis = null;
    BufferedInputStream bis = null;
    OutputStream os = null;
    ServerSocket servsock = null;
    Socket sock = null;
    try {
      servsock = new ServerSocket(SOCKET_PORT);
      while (true) {
        System.out.println("Waiting...");
        try {
          sock = servsock.accept();
          System.out.println("Accepted connection : " + sock);
          //send file
          File myFile = new File (FILE_TO_SEND);
          byte [] mybytearray  = new byte [(int)myFile.length()];
          fis = new FileInputStream(myFile);
          bis = new BufferedInputStream(fis);
          bis.read(mybytearray,0,mybytearray.length);
          os = sock.getOutputStream();
          System.out.println("Sending " + FILE_TO_SEND + "(" + mybytearray.length + " bytes)");
          os.write(mybytearray,0,mybytearray.length);
          os.flush();
          System.out.println("Done.");
        } catch (IOException ex) {
          System.out.println(ex.getMessage()+": An Inbound Connection Was Not Resolved");
        }
        }finally {
          if (bis != null) bis.close();
          if (os != null) os.close();
          if (sock!=null) sock.close();
        }
      }
    }
    finally {
      if (servsock != null)
        servsock.close();
    }
  }
}

Hier ist der client
Erhaltet die Datei gesendet overnetwork

import java.io.BufferedOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;

public class SimpleFileClient {

  public final static int SOCKET_PORT = 5501;
  public final static String SERVER = "127.0.0.1";
  public final static String
       FILE_TO_RECEIVED = "file-rec.txt";

  public final static int FILE_SIZE = Integer.MAX_VALUE;

  public static void main (String [] args ) throws IOException {
    int bytesRead;
    int current = 0;
    FileOutputStream fos = null;
    BufferedOutputStream bos = null;
    Socket sock = null;
    try {
      sock = new Socket(SERVER, SOCKET_PORT);
      System.out.println("Connecting...");

      //receive file
      byte [] mybytearray  = new byte [FILE_SIZE];
      InputStream is = sock.getInputStream();
      fos = new FileOutputStream(FILE_TO_RECEIVED);
      bos = new BufferedOutputStream(fos);
      bytesRead = is.read(mybytearray,0,mybytearray.length);
      current = bytesRead;

      do {
         bytesRead =
            is.read(mybytearray, current, (mybytearray.length-current));
         if(bytesRead >= 0) current += bytesRead;
      } while(bytesRead > -1);

      bos.write(mybytearray, 0 , current);
      bos.flush();
      System.out.println("File " + FILE_TO_RECEIVED
          + " downloaded (" + current + " bytes read)");
    }
    finally {
      if (fos != null) fos.close();
      if (bos != null) bos.close();
      if (sock != null) sock.close();
    }
  }    
}

InformationsquelleAutor der Antwort Jay Godara

Zu vermeiden, die Begrenzung der Größe der Datei , die kann dazu führen, die Ausnahme java.lang.OutOfMemoryError geworfen werden beim erstellen eines Arrays die Größe der Datei byte[] bytes = new byte[(int) length];stattdessen könnten wir tun

    byte[] bytearray = new byte[1024*16];
    FileInputStream fis = null;
    try {

        fis = new FileInputStream(file);
        OutputStream output= socket.getOututStream();
        BufferedInputStream bis = new BufferedInputStream(fis);

        int readLength = -1;
        while ((readLength = bis.read(bytearray)) > 0) {
            output.write(bytearray, 0, readLength);

        }
        bis.close();
        output.close();
    }
    catch(Exception ex ){

        ex.printStackTrace();
    } //Excuse the poor exception handling...

InformationsquelleAutor der Antwort QuakeCore

0

Rookie, wenn Sie möchten, um eine Datei schreiben zu server-socket -, wie über die Verwendung von fileoutputstream anstelle von dataoutputstream? dataoutputstream ist mehr fit für die Protokoll-level-Lesen-schreiben. es ist nicht sehr vernünftig, Ihren code in bytes Lesen und schreiben. Schleife zum Lesen und schreiben ist notwendig, in java io. und auch, verwenden Sie einen Puffer Weg. Spülen ist notwendig. hier ist ein code-Beispiel: http://www.rgagnon.com/javadetails/java-0542.html

InformationsquelleAutor der Antwort horaceman
-1

Hinzufügen bis auf EJP Antwort; verwenden Sie diese für mehr Flüssigkeit.
Stellen Sie sicher, dass Sie nicht legte seinen code in einer größeren try catch mit mehr code zwischen der .Lesen und der catch-block ist, wird möglicherweise eine Ausnahme und springen den ganzen Weg zu den äußeren catch-block, sicherste Wette ist, um Platz EJPS die while-Schleife wird innerhalb eines try-catch, und dann weiter den code nach, wie:
```
int count;
byte[] bytes = new byte[4096];
try {
    while ((count = is.read(bytes)) > 0) {
        System.out.println(count);
        bos.write(bytes, 0, count);
    }
} catch ( Exception e )
{
    //It will land here....
}
//Then continue from here
```
EDIT: ^Das passiert mir cuz ich nicht erkennen, die Sie benötigen, um socket.shutDownOutput() wenn Sie einen client-zu-server-stream!

Hoffe, dieser Beitrag löst alle Ihre Probleme

InformationsquelleAutor der Antwort Camil Latif

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.