ReSQL.ru
     
powered by simpleCommunicator - 2.0.61     © 2026 Programmizd 02
Мобильная версия    Контакт    Правила    FAQ    Помощь
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр
Форумы / Java [игнор отключен] [закрыт для гостей] / Подскажите по сокетам
11 сообщений из 11, страница 1 из 1
Подскажите по сокетам
    #39136917
bobo96
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
bobo96
Гость
Всем привет!
Все копаюсь в сокетах и конкретно в передаче файлов через них)) В данном случае клиент передает файл на сервер.
Не понимаю в чем дело: хочется после приема файла отправлять в ответ сообщение, что файл получен, но дело в том, что файл передается нормально, а дальше все висит.
В режиме дебага на сервере я не дохожу до строки pw.println(1); а на клиенте все висит на System.out.println(br.readLine());
Самое интересное, если убрать на клиенте это самое System.out.println(br.readLine()); то все ок, сервер pw.println(1); проходит и завершает итерацию цикла.
В чем моя ошибка ? Спасибо!


Есть сервер:
 

Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
    public static void main(String[] args) {

        try(ServerSocket serverSocket = new ServerSocket(5555)) {

            while (true) {

                System.out.println("Waiting for connect ...");

                Socket socket = serverSocket.accept();

                System.out.println("Client connected: " + socket.getInetAddress());

                InputStream is = socket.getInputStream();
                OutputStream os = socket.getOutputStream();

                BufferedReader br = new BufferedReader(new InputStreamReader(is));
                PrintWriter pw = new PrintWriter(os, true);

                String msg;

                while(true) {

                    msg = br.readLine();

                    if(msg == null) {
                        break;
                    }

                    if(!msg.equals("sendFile")) {

                        System.out.println(msg);

                    }

                    else {

                        String fileName = br.readLine();
                        long fileSize = Long.parseLong(br.readLine());

                        System.out.println(fileSize);

                        File file = new File("download/" + fileName);
                        file.createNewFile();

                        BufferedInputStream bis = new BufferedInputStream(is, 1024);
                        OutputStream fos = new FileOutputStream(file);

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

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

                        pw.println(1);
                        System.out.println("File download");

                        pw.close();
                        bis.close();
                        fos.close();

                    }

                }

                br.close();
                is.close();
                os.close();
                socket.close();

            }

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

    }





И клиент:
 

Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
    public static void main(String[] args) throws IOException {

        Socket socket = null;

        try {
            socket = new Socket("127.0.0.1", 5555);
        } catch (IOException e) {
            e.printStackTrace();
        }

        if(socket != null) {

            InputStream is = null;
            OutputStream os = null;

            try {
                is = socket.getInputStream();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                os = socket.getOutputStream();
            } catch (IOException e) {
                e.printStackTrace();
            }

            if(is != null && os != null) {

                PrintWriter pw = new PrintWriter(os, true);
                BufferedReader br = new BufferedReader(new InputStreamReader(is));

                pw.println("Hello");

                InputStream fis = null;
                File file = new File("1.txt");

                try {
                    fis = new FileInputStream(file);
                } catch (FileNotFoundException e) {
                    e.printStackTrace();
                }

                if(fis != null) {

                    pw.println("sendFile");
                    pw.println(file.getName());
                    pw.println(String.valueOf(file.length()));

                    System.out.println(file.length());

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

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


//       ЕСЛИ РАССКОММЕНТИРОВАТЬ ЭТОТ БЛОК ТО ВСЕ ВИСИТ НА НЕМ
//                    try {
//                        System.out.println(br.readLine());
//                    } catch (IOException e) {
//                        e.printStackTrace();
//                    }


                    try {
                        fis.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }

                }

                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }

            }

        }

    }


...
Рейтинг: 0 / 0
24.12.2015, 11:51
| Ответить | Цитировать | Написать  
Подскажите по сокетам
    #39136925
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
Ошибка в протоколе.
readLine() вычитывает всё до переноса строки или конца стрима. Конец стрима это -1.
Севрер отправляет файл, затем дописывает к нему единицу. Откуда клиенту знать что это единица конец файла, а не сам файл?
Шли -1.
Почему для сокетов try with resource используется, а для IO - нет?
...
Рейтинг: 0 / 0
24.12.2015, 11:57
| Ответить | Цитировать | Написать  
Подскажите по сокетам
    #39136929
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
bobo96,

И нужно ещё понимать что java.io это блокирующее IO. Если клиент читает данные, а сервер их не шлет, то поток блокируется.
В вашей терминологии " на клиенте все висит". Нет не всё, "висит" только поток, который использует блокирующее IO.
...
Рейтинг: 0 / 0
24.12.2015, 11:59
| Ответить | Цитировать | Написать  
Подскажите по сокетам
    #39136953
bobo96
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
bobo96
Гость
BlazkowiczСеврер отправляет файл, затем дописывает к нему единицу. Откуда клиенту знать что это единица конец файла, а не сам файл?
Немного не так: Клиент отправляет файл, сервер его принимает и шлет обратно на клиент единицу. OutputStream на сервере при этом же ничем не занят или я что-то путаю ?

BlazkowiczПочему для сокетов try with resource используется, а для IO - нет?
На скорую руку все накидал, мне важно в механизме работы сокетов разобраться :)

BlazkowiczИ нужно ещё понимать что java.io это блокирующее IO. Если клиент читает данные, а сервер их не шлет, то поток блокируется.
В вашей терминологии " на клиенте все висит". Нет не всё, "висит" только поток, который использует блокирующее IO.
Я это понимаю, криво просто выразился.
Клиент стоит на br.readLine() и ждет, пока туда что-то прилетит.

В общем я, видимо, совсем дремучий, но мне до сих пор не понятно, где ошибка.
...
Рейтинг: 0 / 0
24.12.2015, 12:09
| Ответить | Цитировать | Написать  
Подскажите по сокетам
    #39136979
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
bobo96Немного не так: Клиент отправляет файл, сервер его принимает и шлет обратно на клиент единицу. OutputStream на сервере при этом же ничем не занят или я что-то путаю ?

Ок. Сервер шлет 1. А клиент через readLine ждет конца стрима или строки. Как вы думаете, 1 это конец стрима или строки?
Ну, шлите "1\n", чтобы не висело. Только учтите что readLine(), возможно, хочет перенос строки локальной системы, что под виндой \r\n.

bobo96На скорую руку все накидал, мне важно в механизме работы сокетов разобраться :)

Ну, да, а другим в этом говнокоде разбираться теперь?

bobo96В общем я, видимо, совсем дремучий, но мне до сих пор не понятно, где ошибка.
Ошибка в том что клиент читает до тех пор пока не получит то чего хочет. А сервер этого не шлет. Если вы во время "зависания" остановите приложение и посмотрите в дебаге, то, возможно во фрейме readLine() увидите в буфере свою единицу.
...
Рейтинг: 0 / 0
24.12.2015, 12:25
| Ответить | Цитировать | Написать  
Подскажите по сокетам
    #39137023
bobo96
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
bobo96
Гость
Дошло.
Даже заработало :) Спасибо :)
...
Рейтинг: 0 / 0
24.12.2015, 12:55
| Ответить | Цитировать | Написать  
Подскажите по сокетам
    #39137766
bobo96
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
bobo96
Гость
Дорогие программисты :) Продолжу, с вашего позволения.
Еще пара вопросов:
1. При приеме файла функция read(byte b); не возвращает -1, следовательно из цикла while ((count = socket.getInputStream().read(bytes)) != -1) { ... } выйти невозможно. Почему не возвращается -1 ?
2. Чутка облагородил писанину. Это все еще говнокод ? :)
Еще раз заранее благодарю!

Сервер:
 

Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
    public static void main(String[] args) {

        try(ServerSocket serverSocket = new ServerSocket(5555)) {

            while (true) {

                System.out.println("Waiting for connect ...");

                try(Socket socket = serverSocket.accept();
                    BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {

                    System.out.println("Client connected: " + socket.getInetAddress());

                    String msg;

                    while ((msg = br.readLine()) != null || !(msg = br.readLine()).equals("dscn")) {

                        if (!msg.equals("sendFile")) {

                            System.out.println(msg);

                        }

                        else {

                            String fileName = br.readLine();
                            long fileSize = Long.parseLong(br.readLine());

                            System.out.println(fileSize);

                            File file = new File("download/" + fileName);
                            boolean b = file.exists() || file.createNewFile();

                            if(!b) {
                                break;
                            }

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

                            int count, total = 0;

                            try (OutputStream fos = new FileOutputStream(file)) {

                                while ((count = socket.getInputStream().read(bytes)) != -1) {
                                    fos.write(bytes, 0, count);

                                    total += count;

                                    if (total == fileSize) {
                                        PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);
                                        pw.println(1);
                                        System.out.println("File download");
                                        break;
                                    }
                                }

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

                        }

                    }

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

            }

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

    }





Клиент:
 

Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
    public static void main(String[] args) {

//        File file = new File("1.txt");
//        File file = new File("kot.jpeg");
        File file = new File("20130603_222957.mp4");

        try(Socket socket = new Socket("127.0.0.1", 5555);
            InputStream is = socket.getInputStream();
            OutputStream os = socket.getOutputStream();
            PrintWriter pw = new PrintWriter(os, true);
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            InputStream fis = new FileInputStream(file)) {

            pw.println("HELLO!");
            pw.println("LOCAL CLIENT");

            pw.println("sendFile");
            pw.println(file.getName());
            pw.println(String.valueOf(file.length()));

            System.out.println(file.length());

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

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

            String answer = br.readLine();

            if(answer.equals("1")) {
                System.out.println("File send");
                pw.println("dscn");
            }

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

    }


...
Рейтинг: 0 / 0
25.12.2015, 07:34
| Ответить | Цитировать | Написать  
Подскажите по сокетам
    #39137786
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
bobo961. При приеме файла функция read(byte b); не возвращает -1, следовательно из цикла while ((count = socket.getInputStream().read(bytes)) != -1) { ... } выйти невозможно. Почему не возвращается -1 ?

-1 это конец InputStream, а не файла. Для того чтобы на одной стороне получить -1, на второй стороне нужно закрыть OutputStream.

bobo962. Чутка облагородил писанину. Это все еще говнокод ? :)

Зачем перенос после каждой строки?
b - не читаемое имя переменной.
Зачем самому писать\читать через буфер, когда давно уже существуют BufferedInput/OutputStream и Apache Commons IOUtils?
Логика сервера кривая. Мы вычитывает строку. Проверяем, на соответствие какому-то сообщению и если не соответствует, вычитываем новую строку. А что с данными который были в той строке?? Мы их выкидываем?
else пишется в той же строке что и закрывающая скорбка, а не через 2 строки после неё.
if (total == fileSize) - в таких условиях принято писать >=, чтобы в случае привышения размера из-за какой-либо баги мы не ушли в бесконечный цикл.
Зачем серверу 3 одинаковых catch (IOException e) {e.printStackTrace();}, если можно обойтись одним?
Код: java
1.
2.
3.
//        File file = new File("1.txt");
//        File file = new File("kot.jpeg");
        File file = new File("20130603_222957.mp4");


Просто берите имя файла из args[0].
PrintWriter и BufferedReader используют платформо зависимый перенос строки. Если запустить клиент и сервер на разных платформах, то протокол может сломаться.
Комбинировать чтение\запись из Buffered потока и его внутреннего потока - пагубно. Часть данных может осесть в буфере, в запись\чтение потом идут напрямую мимо этого буфера и ломают протокол. В целом, Reader/Writer для работы с сокетами используется редко. Потому что для текста уже давно изобретён HTTP.
Сообщения "sendFile", "1", "dscn" надо из магических констант вынести в общие поля для сервера и клиента. Чтобы нигде никакая опечатка не проскочила. Да, и код понятнее будет, если у тебя все сообщения протокола в виде Enum или его аналога.

К прочтению настоятельно рекомендуется Robert C Martin - Clean Code
...
Рейтинг: 0 / 0
25.12.2015, 09:09
| Ответить | Цитировать | Написать  
Подскажите по сокетам
    #39137965
bobo96
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
bobo96
Гость
Спасибо! Узнал МНОГО нового :)
Но остались непонятные моменты
BlazkowiczЗачем самому писать\читать через буфер, когда давно уже существуют BufferedInput/OutputStream
Тут вот не понял, что имеется в виду.
Все примеры, которые находил в интернетах, так же точно и выглядят, как мой.
Например:
https://www-01.ibm.com/support/knowledgecenter/ssw_i5_54/rzaha/sslcex04.htm
Часть кода:
Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
Socket s = serverSocket.accept();
    BufferedInputStream is = new BufferedInputStream(s.getInputStream());
    BufferedOutputStream os = new BufferedOutputStream(s.getOutputStream());

    // This server just echoes back what you send it.

    byte buffer[] = new byte[4096];

    int bytesRead;

    while ((bytesRead = is.read(buffer)) > 0) {
      os.write(buffer, 0, bytesRead);
      os.flush();
    }


Чем это принципиально отличается от того, как сделано у меня ?
...
Рейтинг: 0 / 0
25.12.2015, 12:02
| Ответить | Цитировать | Написать  
Подскажите по сокетам
    #39138007
Фотография Blazkowicz
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Blazkowicz
Участник
bobo96Тут вот не понял, что имеется в виду.


Код: java
1.
2.
3.
4.
    BufferedInputStream is = new BufferedInputStream(s.getInputStream());
    byte buffer[] = new byte[4096];
    int bytesRead;
    while ((bytesRead = is.read(buffer)) > 0) {


Внутри BufferedInputStream уже есть буфер, который работает аналогичным образом. Поэтому код копирования можно существенно упростить копируя данный по 1 байту в виде int, вместо byte[]. Да, это будет немного медленее, но не на столько медленнее чтобы на вашем примере это было заметно. Вот если буферизации не будет вообще, тогда разница будет видна невооруженным глазом.

Опять, же, если мы копируем на диск или читаем из него, у нас есть вот такой класс
http://docs.oracle.com/javase/7/docs/api/java/nio/file/Files.html


bobo96Все примеры, которые находил в интернетах, так же точно и выглядят, как мой.

Этим грешат многие примеры.

bobo96Чем это принципиально отличается от того, как сделано у меня ?
Есть такое понятие Boilerplate code
Многие вещи можно и нужно делать проще. Но при этом, конечно же, следить чтобы не упала читаемость.
...
Рейтинг: 0 / 0
25.12.2015, 12:37
| Ответить | Цитировать | Написать  
Подскажите по сокетам
    #39138318
bobo96
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
bobo96
Гость
Вопросов больше не осталось, еще раз спасибо :)
...
Рейтинг: 0 / 0
25.12.2015, 16:39
| Ответить | Цитировать | Написать  
11 сообщений из 11, страница 1 из 1
Форумы / Java [игнор отключен] [закрыт для гостей] / Подскажите по сокетам
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение   Полит. конфиден.  
NoSQL.ru       Кролег: Проекты, Новости, Чат       РЕД ФОРУМ       Фотоальбом: Участники, Встречи
Закрыть
start [/forum/topic.php?fid=59&tid=2124515]:
 0ms
get settings:
 9ms
get forum list:
 15ms
check forum access:
 3ms
check topic access:
 3ms
track hit:
 151ms
get topic data:
 12ms
get forum data:
 3ms
get page messages:
 63ms
get tp. blocked users:
 2ms
others: 220ms
total:  481ms
созд. / загр.: 481ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]