1

Доброго времени суток. Java занимаюсь месяц.

Пишу клиент - серверное приложение. Похоже на обычный чат. Каждому новому соединению назначается id. Значение записывается в ArrayList. Каждый новый клиент открывается в отдельном потоке.

Никак не могу понять: как по id, отправить сообщение именно выбранному клиенту?

Каким образом вызвать метод writeUTF, связанный именно с этим id?

public class myLogic implements Runnable {
    Socket socket = null;
    public myLogic(Socket s){
        socket = s;
    }

    @Override
    public void run() {
        try{
        DataOutputStream dout = new DataOutputStream(new BufferedOutputStream(socket.getOutputStream()));
        DataInputStream dis = new DataInputStream(new BufferedInputStream(socket.getInputStream()));
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        while(true){
            String line = br.readLine();
            dout.writeUTF(line);
            String line1 = dis.readUTF();
            dout.flush();
            dis.close();
        }
        }catch(Exception e){}

    }

}

public class SelectorTest {
    public static void main(String args[]) throws IOException{
        int port = 9007;
        ServerSocket ss = new ServerSocket(port);
        while(true){
            int id = 0;
            Socket s = ss.accept();
            ArrayList AL = new ArrayList();
            AL.add(s);
            System.out.println(AL.toString());
            System.out.println(AL.containsAll(AL));
            AL.set(id, s);
            Runnable r = new myLogic(s);
            Thread thread = new Thread(r);
            thread.start();
        }
    }
};
4
  • покажите ваш код, можно будет ответить
    – Saidolim
    2 дек 2015 в 13:36
  • Один момент. Сейчас добавлю.
    – lemuur
    2 дек 2015 в 13:41
  • где здесь массив Socketов ?
    – Saidolim
    2 дек 2015 в 13:52
  • ArrayList AL = new ArrayList(); AL.add(s)
    – lemuur
    2 дек 2015 в 13:53

1 ответ 1

2

используйте Map

public class SelectorTest {
    public static void main(String args[]) throws IOException{
        int port = 9007;
        ServerSocket ss = new ServerSocket(port);

        Map<Integer, Socket> AL = new HashMap<>(); // тут будим хранит сокеты
        Integer id = 0;

        while(true){
            id++;
            Socket s = ss.accept();
            AL.put(id,s);
            ...
        }
    }
};

для получения

AL.get(id);
1
  • Спасибо Вам огромное) Теперь мне все стало понятно) Еще раз большое спасибо)
    – lemuur
    2 дек 2015 в 14:03

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.