Потоковое видео на сервер - PullRequest
Новая
       11

Потоковое видео на сервер

2 голосов
/ 10 сентября 2009

Я пытаюсь транслировать видео на сервер с другого компьютера, использующего Java, и для начала я просто пытаюсь передать файл, используя необработанное сокетное соединение и поток байтов. Тем не менее, вещи не проявляются так же. Если я перенесу файл таким образом, файл размером 3 МБ на моей машине окажется 5 МБ на сервере. Я пытаюсь сделать это с видеофайлом, и результирующий файл фактически «проигрывает», когда я его скачиваю, и имеет правильную длину, но изображение отсутствует. Код ниже:

Клиент (стример): 

public static void main(String[] args){
    Socket sock = null;

    try{
        System.out.println("Connecting...");
        sock = new Socket("server.com", 8080);
        InputStream is = new FileInputStream(new File("Bear.wmv"));
        byte[] bytes = new byte[1024];

        OutputStream stream = sock.getOutputStream();

        int count = is.read(bytes, 0, 1024);
        while (count != -1){
            stream.write(bytes, 0, 1024);
            count = is.read(bytes, 0, 1024);
        }

        is.close();
        stream.close();
        sock.close();

    }catch (Exception e){
        e.printStackTrace();
    }
}

Сервер (получатель): 

public static void main(String[] args){
    ServerSocket sock = null;
    try {
        sock = new ServerSocket(8080);
    } catch (IOException e) {
        System.out.println("Could not instantiate socket:");
        e.printStackTrace();
        return;
    }

    Socket clientSock = null;
    while(true){

        try{

            System.out.println("Waiting for connection...");
            clientSock = sock.accept();
            final Socket fin = clientSock;
            System.out.println("Connection accepted");
            System.out.println("Spawning thread...");
            Thread trd = new Thread(new Runnable(){
                public void run(){
                    try {
                        try {
                            Thread.sleep(5000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }

                        System.out.println("Receiving video...");
                        File video = new File("test.wmv");
                        FileOutputStream fos = new FileOutputStream(video);
                        byte[] data = new byte[1024];
                        int count = fin.getInputStream().read(data, 0, 1024);
                        while (count != -1){
                            fos.write(data, 0, 1024);
                            count = fin.getInputStream().read(data, 0, 1024);
                        }
                        fos.close();
                        fin.close();
                        System.out.println("Done receiving");
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }}
            });
            trd.start();

        }catch(IOException e){
            System.out.println("Could not accept");
            e.printStackTrace();
        }


    }



}

Есть мысли? Заранее спасибо!

Chris

1 Ответ

4 голосов
/ 10 сентября 2009

Итак, я разобрался с проблемой.

Я изменил сервер, чтобы записывать только байты "count" 

while (count != -1){
       fos.write(data, 0, count);
       count = fin.getInputStream().read(data, 0, 1024);
}

А теперь работает :) 1006 *

Спасибо!

...