Аватар для nnnikotinnn995
7 / 7 / 4
Регистрация: 07.07.2011
Сообщений: 583

Nio идентификация клиента по каналу SocketChannel

12.04.2016, 22:50. Показов 1638. Ответов 6
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Здравствуйте. Голову сломал окончательно, но так и не удалось выяснить как по каналу сервер может определить номер подключенного клиента (по счету). Как вы думаете, это возможно? Проблема в том, что сервер в nio слушает не сокеты клиентов, а каналы по которым сокеты с ним общаются
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
   Set<SelectionKey> readyKeys = selector.selectedKeys();
           Iterator<SelectionKey> iterator = readyKeys.iterator();
            while (iterator.hasNext()) {
             SelectionKey key = (SelectionKey) iterator.next();
                iterator.remove();
                try {
                    if (key.isAcceptable()) {
                        ServerSocketChannel server = (ServerSocketChannel) key.channel();
                        SocketChannel clientn = server.accept();countclient++;
                        clientn.configureBlocking(false);
     clientn.register(selector, SelectionKey.OP_READ); 
                    } 
 else if (key.isWritable()) {
   SocketChannel clientn = (SocketChannel) key.channel();
   buffer.clear();
                            buffer.putDouble(25,Atan_joystickn);buffer.putDouble(25+8,j_Atan_joystickn);
                            buffer.putInt(0,boolmoven);
 
                        clientn.write(buffer);
                        System.out.println(n2 + " bytes written.");// Thread.sleep(155);
                        buffer.clear();
                       clientn.register(selector, SelectionKey.OP_READ); key.attachment();//key.interestOps(SelectionKey.OP_READ);
 }else if (key.isReadable()) {
 SocketChannel clientn = (SocketChannel) key.channel();
    buffer.clear();
    clientn.read(buffer);
Atan_joystickn=buffer.getDouble(25);j_Atan_joystickn=buffer.getDouble(25+8);
boolmoven=buffer.getInt(0);
buffer.flip();
    clientn.register(selector, SelectionKey.OP_WRITE);
                    }
.
.
.
Общение получается, но как определить с кем именно? Получать данные о себе от клиента похоже бесполезно, потому что доступным для записи (if (key.isWritable())) через канал может стать любой клиент и данные предназначенные Пете могут прийти Васе. Не подскажите, как можно идентифицировать клиента в NIO?
0
Programming
Эксперт
39485 / 9562 / 3019
Регистрация: 12.04.2006
Сообщений: 41,671
Блог
12.04.2016, 22:50
Ответы с готовыми решениями:

NIO последовательное чтение и запись в SocketChannel
Добрый день. Возникла небольшая проблема при работе с NIO. Ситуация такая: Есть сервер и клиент. Работает все через NIO. Клиент...

идентификация клиента
Здравствуте! вот мне тут нужно решить задачку, прошу помощи. Суть задачки следующая имеется вэб-сервер, к нему имеется десктопный...

Идентификация клиента в twisted
Всем привет! Я пишу сервер с использованием twisted. К серверу могут подключаться несколько клиентов, сервер может принимать от них...

6
 Аватар для nnnikotinnn995
7 / 7 / 4
Регистрация: 07.07.2011
Сообщений: 583
14.04.2016, 08:11  [ТС]
Похоже догнал, это через attach() делается.
0
 Аватар для zz555
0 / 0 / 0
Регистрация: 06.06.2017
Сообщений: 6
30.01.2020, 01:02
Цитата Сообщение от nnnikotinnn995
через канал может стать любой клиент и данные предназначенные Пете могут прийти Васе
Цитата Сообщение от nnnikotinnn995
Похоже догнал, это через attach() делается.
nnnikotinnn995, ели вам это получилось, поделитесь пожалуйста кодом. Пытаюсь решить ту же проблему. Странно, но никто в интернете об этом не пишет. Уже по-разному искал, ничего найти не могу.

Добавлено через 11 минут
https://www.codeflow.site/ru/a... o-selector
Там написано, что можно добавить пользовательские данные как объект третьим параметром:

Java
1
SelectionKey key = channel.register(selector, SelectionKey.OP__ACCEPT, object);
Но как, не понятно.

Добавлено через 15 минут
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
private void handleAccept(SelectionKey key) throws IOException {
    Id ncl = new Id();
    SocketChannel sc = ((ServerSocketChannel) key.channel()).accept();
    String address = (new StringBuilder(sc.socket().getInetAddress().toString()))
                .append(":").append(sc.socket().getPort()).toString();
    ncl.addr = address;
    sc.configureBlocking(false);
    sc.register(selector, SelectionKey.OP_READ, ncl);
    clients++;
    broadcast(address+" Connected ("+clients+")\n");
}
 
private void broadcast(String msg) throws IOException {
    ByteBuffer msgBuf = ByteBuffer.wrap(msg.getBytes());
    int i = 0;
    for (SelectionKey key : selector.keys()) {
        if (key.isValid() && key.channel() instanceof SocketChannel) {
            SocketChannel sch = (SocketChannel) key.channel();
            //System.out.println(ncl.addr);
            System.out.println(sch);
            //Object object = key.attachment();
            //System.out.println(object);
            sch.write(msgBuf);
            msgBuf.rewind();
            i++;
        }
    }
}
 
class Id {
    public Object addr;
    public int user_id;
}
Печатает "Id@4b469bea => test" вместо адреса "/192.168.0.8:50956 => test".
0
 Аватар для nnnikotinnn995
7 / 7 / 4
Регистрация: 07.07.2011
Сообщений: 583
20.02.2020, 16:59  [ТС]
Давно я это делал, вот код Тест NIO (simple code)
По моему
Java
1
2
SelectionKey Skey=serverChannel.register(socketSelector, SelectionKey.OP_ACCEPT);
Skey.attach(0);
Не помню...
0
 Аватар для zz555
0 / 0 / 0
Регистрация: 06.06.2017
Сообщений: 6
25.02.2020, 15:19
Спасибо за ответ, но про "Skey.attach(0);" описано в приведенной мною статье: https://www.codeflow.site/ru/a... o-selector

А в коде по приведенной вами ссылке Тест NIO (simple code) вообще attach() не используется.

Добавлено через 11 минут
У меня простой вопрос, через attach() добавить то я добавил (и брать можно), но есть ли возможность потом изменить содержимое этого поля?
Или только удалить socketChannel и создать новый з измененным содержимым в attach()?

На этом форуме вообще-то есть специалисты, разбирающиеся в этой теме? А вообще здесь есть программисты на Java?
0
 Аватар для snajper_ro
116 / 101 / 52
Регистрация: 14.09.2011
Сообщений: 696
Записей в блоге: 1
15.03.2020, 19:56
смотрите вы пишите низко уровне, я использовал apache mina для получение строк по tcp ip
Java
1
2
3
4
5
6
7
8
9
10
11
cceptor = new NioSocketAcceptor();
        acceptor.setReuseAddress(true);
//        acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
        TextLineCodecFactory t = new TextLineCodecFactory();
        t.setDecoderMaxLineLength(maxLength);
        t.setEncoderMaxLineLength(maxLength);
        acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(t));
        acceptor.setHandler(proxyHandler);
        acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, timeout);
        acceptor.bind(new InetSocketAddress(port));
        logger.info("Proxy acceptor has started on port " + port);
0
51 / 36 / 16
Регистрация: 24.01.2020
Сообщений: 94
Записей в блоге: 5
15.03.2020, 21:28
Через SelectionKey.attach(...) цепляется значение типа Object. То есть, объект любого Вашего типа (скажем, class MyData) будет приведен к типу Object.
Потом, когда вы его возьмете методом SelectionKey.attachment() - просто приведите к своему типу:
MyData socketData=(MyData)Skey.attachment();
Дальше уже работайте с полученным значением своего типа обычным порядком.
Никто не запрещает и новые данные вписать в прицепленное к SelectionKey значение. Или полностью заменить объект через повторный вызов attach(...), или менять поля прицепленного объекта, не заменяя его.
Вообще, поставленный Вами вопрос не к java.nio имеет отношение - а, скорее, к основам Java. Ну, и документацию стоило бы повнимательнее читать.
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
inter-admin
Эксперт
29715 / 6470 / 2152
Регистрация: 06.03.2009
Сообщений: 28,500
Блог
15.03.2020, 21:28
Помогаю со студенческими работами здесь

Идентификация клиента сервером
Как сервер точно может отличить разных клиентов с одним IP,чтобы переслать ему ответ(т.е. какой еще параметр идет кроме IP и порта для...

Как использовать java.nio.channels.Selector на стороне клиента?
Подскажите пожалуйста (вот уже 3 день бъюсь и не могу решить проблему): напишите кто знает как использовать java.nio.channels.Selector на...

Идентификация клиента при связке INDY + SSL в событии IdHTTPServerCommandGet
Итак, имеем проект для взаимодействия по SSL протоколу с ключевыми компонентами IdHTTP: TIdHTTP; IdServerIOHandlerSSLOpenSSL:...

Передача файла через SocketChannel
Всем привет. Наверняка кто-нибудь сталкивался с такой задачей: нужно передать файл через сокетное соединение (nio). Перерыл кучу...

По отправке текста через SocketChannel
В данном примере строка текста проецируется в ByteBuffer с целью дальнейшей отправки клиенту. А проблема в том, что при такой реализации...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
7
Ответ Создать тему
Опции темы

Новые блоги и статьи
Отчёт о затраченных материалах за определенный период с макетом печатной формы
Maks 21.04.2026
Отчёт из решения ниже размещён в конфигурации КА2. Задача: разработка отчёта по затраченным материалам за определённый период, с возможностью вывода печатной формы отчёта с шапкой и подвалом. В. . .
Отчёт о спецтехнике находящейся в ремонте
Maks 20.04.2026
Отчёт из решения ниже размещен в конфигурации КА2. Задача: отобразить спецтехнику, которая на данный момент находится в ремонте. Есть нетиповой документ "Заявка на ремонт спецтехники" который. . .
Памятка для бота и "визитка" для читателей "Semantic Universe Layer (Слой семантической вселенной)"
Hrethgir 19.04.2026
Сгенерировано для краткого описания по случаю сборки и компиляции скелета серверного приложения. И пусть после этого скажут, что статьи сгенерированные AI - туфта и не интересно. И это не реклама -. . .
Запрет удаления строк ТЧ документа при определённом условии
Maks 19.04.2026
Алгоритм из решения ниже реализован на примере нетипового документа "Аккумуляторы", разработанного в конфигурации КА2. У данного документа есть ТЧ, в которой в зависимости от прав доступа. . .
Модель заражения группы наркоманов
alhaos 17.04.2026
Условия задачи сформулированы тут Суть: - Группа наркоманов из 10 человек. - Только один инфицирован ВИЧ. - Колются одной иглой. - Колются раз в день. - Колются последовательно через. . .
Мысли в слух. Про "навсегда".
kumehtar 16.04.2026
Подумалось тут, что наверное очень глупо использовать во всяких своих установках понятие "навсегда". Это очень сильное понятие, и я только начинаю понимать край его смысла, не смотря на то что давно. . .
My Business CRM
MaGz GoLd 16.04.2026
Всем привет, недавно возникла потребность создать CRM, для личных нужд. Собственно программа предоставляет из себя базу данных клиентов, в которой можно фиксировать звонки, стадии сделки, а также. . .
Знаешь почему 90% людей редко бывают счастливыми?
kumehtar 14.04.2026
Потому что они ждут. Ждут выходных, ждут отпуска, ждут удачного момента. . . а удачный момент так и не приходит.
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru