VPF::upload - Форум программистов

Gugle

Дата 20.3.2008, 19:07 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 117
Регистрация: 9.12.2005

Репутация: нет
Всего: нет

Плохо. Значит из того что я прочитал я не сделал ни одного верного вывода. smile

Добавлено через 12 минут и 9 секунд
Значит. Сделав следующий запрос к сервеу:

Код


 PostMethod filePost = new PostMethod("http://localhost:8084/servlets-examples/fileReader");

Я не могу получить от него ответа пока он не завершиться. Т.е. обязан дождаться передачи всего файлн и только после этого я получу подтверждение принял я его или нет.

Тогда как я могу получить подстверждение принятого байта?

З.Ы.
Сорь. Ламер в этих вопросах.

LSD

Дата 20.3.2008, 19:38 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 9
Всего: 538

Тебе надо или реализовать еще один сервлет, который по запросу будет возвращать количество байт загруженных в текущей сессии (т.е. тебе надо будет или хранить в сессии это число или сделать механизм который позволит его получить по ID сессии).

Либо вообще забить на POST, и реализовать свой сервлет (не HTTP!), который бы принимал данные по собственному протоколу и переодически слал бы данные о принятом количестве байт.

--------------------

Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.

Gugle

Дата 25.3.2008, 10:21 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 117
Регистрация: 9.12.2005

Репутация: нет
Всего: нет

Почему то не обновляется диалоговое окно прогресса в аплете. При этом если появление диалогового окна положить в метод init() аплета то все нормально, а если в обработчик нажатия на кнопку, то диалог появляется, но не обновляется.
Использую стандартное окно ProgressMonitor. В чем может быть проблема?

Gugle

Дата 25.3.2008, 10:55 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 117
Регистрация: 9.12.2005

Репутация: нет
Всего: нет

Да, кстати, все расчеты происходят в отдельном потоке. (В данном случае отправка файла)

LSD

Дата 25.3.2008, 12:27 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 9
Всего: 538

Покажи код.

--------------------

Gugle

Дата 25.3.2008, 12:42 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 117
Регистрация: 9.12.2005

Репутация: нет
Всего: нет

Applet:

Код


public class Main extends javax.swing.JApplet {

    public void init() {
        initComponents();
//        FileLoadToServer upload = new FileLoadToServer();
//        upload.upload(this, "D:/test.txt", utilPack.Util._path + "load/fileReader");
    }

    public void start() {
    }

    public void stop() {
    }

    public void destroy() {
    } 

    private void initComponents() {
        _panel = new ru.niir.gui.panel.BasesPanel();
        _fileChooser = new javax.swing.JFileChooser();

        _panel.add(_button);
        _button.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                _buttonActionPerformed(evt);
            }
        });
        add(_panel);
    }

    private void _buttonActionPerformed(java.awt.event.ActionEvent evt) {
        // TODO add your handling code here:
        int result = _fileChooser.showOpenDialog(this);
        switch (result) {
            case 0:
                String name = _fileChooser.getSelectedFile().getPath();
                FileLoadToServer upload = new FileLoadToServer();
                upload.upload(this, name, utilPack.Util._path + "load/fileReader");
                break;
            case 1:
            default:
        }
    }  

    // Variables declaration
    private javax.swing.JPanel _panel;
    private javax.swing.JButton _button;
    private javax.swing.JFileChooser _fileChooser;
    // End of variables declaration
}

Код загрузчика:

Код


public class FileLoadToServer {

    public FileLoadToServer () {
    }

    /**
     * Метод FilePart() переписан.
     * @param parent родительский класс
     * @param aFile путь к файлу
     * @param aServer путь к серверу
     * @return статус передачи по ее истечении.
     */
    public String upload(java.awt.Component parent, String aFile, String aServer) {
       String status = null;
        try {
            File f = new File(aFile);
            FilePart filePart = new FilePart("filename", f);
            PostMethod filePost = new PostMethod(aServer);
            Part[] parts = {
                new StringPart("action", "uploadfile"),
                filePart
            };
            MultipartRequestEntity entiti = new MultipartRequestEntity(parts, filePost.getParams());
            filePost.setRequestEntity(entiti);
            
            int i = (int)entiti.getContentLength();

            // Обнаружение фрейма владельца.
            Applet owner = null;
            if (parent instanceof Applet) owner = (Applet) parent;
            else owner = (Applet)SwingUtilities.getAncestorOfClass(Applet.class, parent);
            javax.swing.ProgressMonitor pm = new javax.swing.ProgressMonitor(
                   owner , "Загрузка - " + f.getName(), "", 0, i);
            pm.setProgress(0);
            pm.setMillisToPopup(100);

            //Запускаем поток передачи файла
            quiryfile qf = new quiryfile(filePost);
            qf.start();

            // Пока поток работает делаем обновление
            while (!qf.getShutDown()) {
                int progress = filePart.getTotalRead();
                String message = String.format("Передано %,d байт из %,d ", progress, i);
                pm.setNote(message);
                pm.setProgress(progress);
            }
            qf.setShutDown();
            java.awt.Toolkit.getDefaultToolkit().beep();
            pm.close();
            status = qf.getStatus();

            filePost.releaseConnection();
        } catch (IOException e) {
          System.err.println("Fatal transport error: " + e.getMessage());
          e.printStackTrace();
        }
        return status;
    }
}

Это сообщение отредактировал(а) Gugle - 25.3.2008, 12:43

LSD

Дата 25.3.2008, 13:19 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 9
Всего: 538

Ну и где тут у тебя отправка происходит в отдельно потоке? Все работает в AWT потоке, потому ничего и не перерисовывается. Вынеси загрузку файла на сервер в отдельный поток.

--------------------

Gugle

Дата 25.3.2008, 14:50 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 117
Регистрация: 9.12.2005

Репутация: нет
Всего: нет

Вынес все в отдельный поток.

Код


public class FileLoadToServer {

    public FileLoadToServer () {
    }

    public String upload(java.awt.Component parent, String aFile, String aServer) {
        String status = null;
            // Обнаружение фрейма владельца.
            Applet owner = null;
            if (parent instanceof Applet) owner = (Applet) parent;
            else owner = (Applet)SwingUtilities.getAncestorOfClass(Applet.class, parent);

            quiryfile qf = new quiryfile(aFile, aServer);
            qf.start();
            
            while (!qf.getExecute()) {
                // Тупое ожидание начала передачи
            }
            Код



            int i = (int)qf.getContentLength();
            javax.swing.ProgressMonitor pm = new javax.swing.ProgressMonitor(
                   owner , "Загрузка - " + f.getName(), "", 0, i);
            pm.setProgress(0);
            
            while (!qf.getShutDown()) {
                int progress = qf.getTotalRead();
                String message = String.format("Передано %,d байт из %,d ", progress, i);
                pm.setNote(message);
                pm.setProgress(progress);
                System.out.println(message);
            }
            status = qf.getStatus();
            qf.setShutDown();
            java.awt.Toolkit.getDefaultToolkit().beep();
            pm.close();
        return status;
    }
}


class quiryfile extends Thread {

    public quiryfile(String aFile, String aServer) {
        _file = aFile;
        _server = aServer;
    }


    public void run() {
        while (!done) {
            try {
                File f = new File(_file);
                _filePart = new FilePart("filename", f);
                PostMethod filePost = new PostMethod(_server);
                Part[] parts = {
                    new StringPart("action", "uploadfile"),
                    _filePart
                };
                _entiti = new MultipartRequestEntity(parts, filePost.getParams());
                filePost.setRequestEntity(_entiti);
                _execute = true;
                HttpClient client = new HttpClient();
                int status = client.executeMethod(filePost);
                if (status != HttpStatus.SC_OK) _status = "Method failed: " + filePost.getStatusLine();
                else _status = "OK";
                
                filePost.releaseConnection();
            } catch (IOException ex) {
                Logger.getLogger(quiryfile.class.getName()).log(Level.SEVERE, null, ex);
            }
            setShutDown();
        }
    }

    public void setShutDown() {
        done = true;
    }

    public boolean getShutDown() {
        return done;
    }

    public long getContentLength() {
        return _entiti.getContentLength();
    }

    public int getTotalRead() {
        return _filePart.getTotalRead();
    }

    public boolean getExecute() {
        return _execute;
    }

    private MultipartRequestEntity _entiti;
    private String _status = null;
    private FilePart _filePart;
    protected boolean done = false;
    protected String _file;
    protected String _server;
    protected boolean _execute = false;
}

Ничего не изменилось.
Или я не верно делаю?

LSD

Дата 25.3.2008, 15:25 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 9
Всего: 538

Блин!
Ну нафига надо ожидать пока тот поток завершиться? В чем тогда вообще смысл выносить выполнение это операции в отдельный поток, если основной поток все равно будет ждать пока вспомогательный завершиться?

Ты должен запустить поток и выйти з метода. Когда поток завершит загрузку пусть вызовет некий метод который сделает необходимые действия (покажет сообщение и т.п.). В этом же потоке обновляй значение прогресбара по мере продвижения загрузки. Только не забывай, что все изменения GUI из других потоков надо делать через SwingUtilities.invokeLater().

--------------------

Gugle

Дата 25.3.2008, 15:59 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 117
Регистрация: 9.12.2005

Репутация: нет
Всего: нет

Цитата

Ну нафига надо ожидать пока тот поток завершиться? В чем тогда вообще смысл выносить выполнение это операции в отдельный поток, если основной поток все равно будет ждать пока вспомогательный завершиться?

Так основной поток рождает диалоговое окно которое говорит пользователю, что он должен ожидать окончания загрузки файла. При этом я должен как то заполнять progressBar, вот я и создаю доп. поток который передает файл и при этом из которого я вытаскиваю количество переданной информации. Основной поток при этом должен так же ожидать загрузки файла на сервер.
Разве при этом обновление progressBar рожденного в основном потоке не должно происходить?

Цитата

Ты должен запустить поток и выйти з метода. Когда поток завершит загрузку пусть вызовет некий метод который сделает необходимые действия (покажет сообщение и т.п.). В этом же потоке обновляй значение прогресбара по мере продвижения загрузки. Только не забывай, что все изменения GUI из других потоков надо делать через SwingUtilities.invokeLater().

А зачем мне ждать когда поток завершит загрузку? Веть мне надо показать progressBar именно во время загрузки файла.

Добавлено через 1 минуту и 14 секунд
А так же показывать сколько % загружено.

LSD

Дата 25.3.2008, 17:45 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 9
Всего: 538

Ты вызываешь загрузку из обработчика события AWT. Пока ты не выйдешь из этого обработчика не будет происходить никакая обработка событий GUI, ничего не будет перерисовываться, окошки не будут открываться/закрываться и т.д. Именно для этого и нужен отдельный поток, чтобы сразу после его запуска вернуть управление AWT.

--------------------

Gugle

Дата 26.3.2008, 12:27 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 117
Регистрация: 9.12.2005

Репутация: нет
Всего: нет

Спасибки.

Это сообщение отредактировал(а) Gugle - 26.3.2008, 12:28

emelanov

Дата 8.4.2008, 22:38 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 2
Регистрация: 1.4.2008

Репутация: нет
Всего: нет

LSD,
День добрый,
у меня такая же проблема, только вместо апплета вебстарт
(т.е. вебстарт-эдитор для определённого вида xml-файлов,
должен уметь сохранять готовые на родном сервере),
думаю воспользоваться этим же решением.
Вопрос: это тоже будет :"

Цитата

только это как микроскопом гвозди забивать.

"
т.е. существует ли более красивое решение?

LSD

Дата 9.4.2008, 11:19 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 9
Всего: 538

Цитата(emelanov @ 8.4.2008, 23:38

)

Вопрос: это тоже будет: "только это как микроскопом гвозди забивать." т.е. существует ли более красивое решение?

В твоем случае - нет не будет. Дело в том, что Gugle, делал апплет предназначенный только для загрузки файлов на сервер, хотя подобный функционал можно реализовать и без применения апплета.

У тебя же есть готовое приложение и ты просто добавляешь в него некий функционал. Что лучше использовать HTTP POST или свой собственный протокол - вопрос открытый. С одной стороны HTTP POST проще реализовывать серверную часть и нет привязки к языку программирования, очень нетребователен к соединению (если клиент сидит за firewall, proxy, NAT). Свой протоколо - более гибкий (например позволяет реализовать докачку, сжатие передаваемых данных и т.п.), позволяет обойтись одним соединением для получения прогресса загрузки (в случае с HTTP POST, нужно одно для загрузки, и еще куча запросов на выяснение сколько было уже загружено).

--------------------

emelanov

Дата 9.4.2008, 11:38 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 2
Регистрация: 1.4.2008

Репутация: нет
Всего: нет

ок, спасибо.

Думаю, мне HTTP POST подойдёт, так как мне не нужны проценты, файлы будут довольно мелкие, по любому меньше Mb.

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Апплеты \| Следующая тема »