Сокетное соединение с использованием BufferedReader / BufferedWriter - PullRequest
Новая
       21

Сокетное соединение с использованием BufferedReader / BufferedWriter

0 голосов
/ 26 апреля 2018

Мой сервер не отправляет ответ с BufferedWriter клиенту. Кажется, что код останавливается на int amountOfNumbersToBeGenerated = Integer.parseInt(bufferedReader.readLine()); Я полагаю, что вызов bufferedreader.readline() на стороне клиента вызывает и в некотором смысле вызывает и блокирует соединение. 

import java.io.*;
import java.net.Socket;
import java.util.ArrayList;

public class ThreadedConnection implements Runnable {

    private Socket connection;
    private InputStream in;
    private OutputStream out;

    public ThreadedConnection(Socket connection) {
        this.connection = connection;
        try {
            this.in = this.connection.getInputStream();
            this.out = this.connection.getOutputStream();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(in));
        BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(out));
        try {

            String lotteryType = bufferedReader.readLine(); //reads first line of input stream

            int amountOfNumbersToBeGenerated = Integer.parseInt(bufferedReader.readLine());
            System.out.println("3"+amountOfNumbersToBeGenerated);
            switch (lotteryType) {
                case "LuckyForLife":

                        generateLotteryNumbers(amountOfNumbersToBeGenerated, 48, 18, bufferedWriter);
                    break;
                case "MegaMillions":
                    generateLotteryNumbers(amountOfNumbersToBeGenerated, 70, 25, bufferedWriter);
                    break;
                case "PowerBall":
                    generateLotteryNumbers(amountOfNumbersToBeGenerated, 69, 26, bufferedWriter);
                    break;
                default:
                    break;
            }
            bufferedWriter.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                connection.close();
                bufferedReader.close();
                bufferedWriter.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public void generateLotteryNumbers(int amountOfNumbersToBeGenerated, int upperLimitOfGeneratedNumbers, int upperLimitOfExtraNumber, BufferedWriter bufferedWriter){
        RandomNumberGenerator randomNumbers = new RandomNumberGenerator(amountOfNumbersToBeGenerated,upperLimitOfGeneratedNumbers);
        RandomNumberGenerator extraNumber = new RandomNumberGenerator(1,upperLimitOfExtraNumber);
        ArrayList randomNumbersArrayList = randomNumbers.NumberGenerator();
        ArrayList extraNumberArrayList = extraNumber.NumberGenerator();
        String randomNumbersString = randomNumbersArrayList.toString();
        randomNumbersString = randomNumbersString.substring(1, randomNumbersString.length()-1);
        String extraNumberString = extraNumberArrayList.toString();
        extraNumberString = extraNumberString.substring(1, extraNumberString.length()-1);

        try {
            bufferedWriter.write(randomNumbersString);
            bufferedWriter.newLine();
            bufferedWriter.write(extraNumberString);
            bufferedWriter.newLine();
            bufferedWriter.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }

//        System.out.println(randomNumbersString);
//        System.out.println(extraNumberString);
    }
}

Вот код для клиентской стороны. Я думаю, что первое String gerneretedNumber = bufferedReader.readLine(); вызывает проблему. Почти как если бы он вызывался для чтения, когда с сервера ничего не записывалось, а затем связывался с чтением на стороне сервера. Если я блокирую оба вызова readline() на сервере, код сработает, и я смогу распечатать что-нибудь на консоли. 

static void runClient(){
        OutputStream outputStream;
        InputStream inputStream;

        Socket client;
        BufferedWriter bufferedWriter;
        BufferedReader bufferedReader;

        try {
            System.out.println("Creating client socket ");
            client = new Socket("127.0.0.1", 5000);

            outputStream = client.getOutputStream();
            inputStream = client.getInputStream();
            bufferedWriter = new BufferedWriter(new 
OutputStreamWriter(outputStream));
            //bufferedReader = new BufferedReader(new 
InputStreamReader(System.in));
            bufferedReader = new BufferedReader(new 
InputStreamReader(inputStream));

            bufferedWriter.write("LuckyForLife");
            bufferedWriter.newLine();
            bufferedWriter.write("5");
            bufferedWriter.flush();

            String generetedNumber = bufferedReader.readLine();
            String extraNumber = bufferedReader.readLine();

                System.out.println(gerneretedNumber);
                System.out.println(extraNumber);


            System.out.println("Guess its null");
            bufferedReader.close();
            bufferedWriter.close();
            client.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

Если вам нужна дополнительная информация, я с радостью ее опубликую.

1 Ответ

0 голосов
/ 26 апреля 2018

ваш клиент никогда не отправляет 2-ую новую строку. С учетом вашего протокола клиент не наполовину закрывается (вывод закрывается), поэтому сервер не может обнаружить конец потока.

Кстати, попробуйте закрыть потоки (tcp FIN) перед закрытием сокета (tcp RST); это более "этично"! Шутка в сторону, tcp первый - это убийство, и ожидающие байты не могут быть сброшены (хотя у вас здесь много сбросов, это просто хорошая практика).

...