Форум программистов, компьютерный форум, киберфорум
Java: Сети
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.89/18: Рейтинг темы: голосов - 18, средняя оценка - 4.89
0 / 0 / 0
Регистрация: 10.12.2019
Сообщений: 5

Как работает Selector и DatagramChannel с множеством соединений?

11.12.2019, 02:30. Показов 3744. Ответов 3

Студворк — интернет-сервис помощи студентам
Кратко: Я изучал Nio, и то как работать с селекторами, но так и не нагуглил нормальный туториал по созданию сервера с множеством UDP подключений, единственное, что я нашёл, так это вот такой код эхо сервера на основе которого добавил подобный код:

Кликните здесь для просмотра всего текста

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
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.DatagramChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.util.Iterator;
 
public class Nsio {
    private static final int TIMEOUT = 3000; // Wait timeout (milliseconds)
    private static final int ECHOMAX = 255; // Maximum size of echo datagram
 
        private static Selector selector;
        private static int servPort;
        private static DatagramChannel channel;
 
        public static void onCreate(int port) throws IOException {
                selector = Selector.open();
                //создаём селектор для мультиплексорного соединения
                servPort = port;
                channel = DatagramChannel.open();
                channel.configureBlocking(false);
                channel.socket().bind(new InetSocketAddress(servPort));
                channel.register(selector, SelectionKey.OP_READ, new ClientRecord());
        }
 
        public static void onRun() throws IOException {
                while (true) {
                        // Ждём задание пока не пройдёт время ожидания
                        if (selector.select(TIMEOUT) == 0) {
                                System.out.print(".");
                                continue;
                        }
                        //Получить итератор для набора ключей с I/O для обработки
                        Iterator<SelectionKey> keyIter = selector.selectedKeys().iterator();
                        while (keyIter.hasNext()) {
                                SelectionKey key = keyIter.next(); // Key is bit mask
                                // Канал клиентского сокета имеет ожидающие данные?
                                if (key.isReadable())
                                        handleRead(key);
 
                                // Канал клиентского сокета доступен для записи и
                                // ключ действителен (т.е. канал не закрыт).
                                if (key.isValid() && key.isWritable())
                                        handleWrite(key);
 
                                keyIter.remove();
                        }
                }
        }
 
    public static void handleRead(SelectionKey key) throws IOException {
        DatagramChannel channel = (DatagramChannel) key.channel();
        ClientRecord clntRec = (ClientRecord) key.attachment();
        clntRec.buffer.clear();
                //готовим буфер для записи
        clntRec.clientAddress = channel.receive(clntRec.buffer);
        if (clntRec.clientAddress != null) {  // Получили что-то?
            // Register write with the selector
            key.interestOps(SelectionKey.OP_WRITE);
        }
    }
 
    public static void handleWrite(SelectionKey key) throws IOException {
        DatagramChannel channel = (DatagramChannel) key.channel();
        ClientRecord clntRec = (ClientRecord) key.attachment();
        clntRec.buffer.flip(); // подготавливаем для записи
        int bytesSent = channel.send(clntRec.buffer, clntRec.clientAddress);
        if (bytesSent != 0) { // Buffer completely written?
            // No longer interested in writes
            key.interestOps(SelectionKey.OP_READ);
        }
    }
 
//Ниже запись о клиенте
    static class ClientRecord {
        public SocketAddress clientAddress;
        public ByteBuffer buffer = ByteBuffer.allocate(ECHOMAX);
    }
}


Это конечно хорошо, но я не понимаю несколько вещей. Допустим у меня очень много клиентов, хотя бы 30 штук, и я сохранил их адреса подключения в массиве. Мне создавать 30 DatagramChannel для подключения? Или использовать один, но тогда я не понимаю, каким образом регистрируется новое подключение, ведь везде, где бы я ни читал, там регистрация идёт для ServerSokcetChannel, и нигле не написано, как создавать новое подключение с DatagramChannel. В общем, суть вопросов такова:

1) Новый клиент подключается и сразу передаёт некоторые данные. Как мне узнать об этом и сохранить подключение с записью используя DatagramChannel?
2) Что делать если второй клиент подключается с иного адреса, сощдавать новый DatagramChannel? Как вообще подключается и переподключается DatagramChannel?
3) Я хочу отправить клиенту сообщение по адресу. Мне использовать старый DatagramChannel клиента или создавать новый для каждого нового пакета? И как это впихнуть в Selector? Через очередь сообщений?

Java
1
2
3
4
5
public static sendMessage(ClientRecord cr, ByteBuffer bb){
    //Добавить в очередь сообщений, чтобы записать
    // когда канал был открыт для записи,
    addQueue(new Message(cr,bb));
}
Java
1
2
3
4
5
6
7
8
public static sendMessage(ClientRecord cr, ByteBuffer bb){
    //сразу отправлять
    cr.buffer=bb;
    DatagramChannel channel = DatagramChannel.open();
    channel.configureBlocking(false);
    channel.socket().bind(cr.clienAdress);
    //TODO
}
Лично я так и ничего не понял.
0
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
11.12.2019, 02:30
Ответы с готовыми решениями:

Не работает селектор $(selector:not(selector)
Добрый день, уважаемые программисты!!! У меня не работает селектор :not в $(selector:not(selector)): при нажатии на ссылку $('#link')...

Не работает selector, установленный на кнопку
Однако, здравствуйте) Порой мне кажется, что я Homo Sapiens Rukozhopus, но проблемы от этого не решаются... В общем, в соответствии со...

Построить биекцию между множеством N и множеством чётных чисел
Друзья, нужна помощь в построении биекции, как это сделать? :scratch:

3
0 / 0 / 0
Регистрация: 10.12.2019
Сообщений: 5
20.12.2019, 10:03  [ТС]
Было бы неплохо хотя бы указать в Netty или Apache MINA, места, где создаются новые сессии DatagramChannel при прослушивании селектора.
0
0 / 0 / 0
Регистрация: 10.12.2019
Сообщений: 5
20.12.2019, 21:56  [ТС]
Нечто похожее я на свой вопрос я нашёл тут:

https://stackoverflow.com/ques... management

https://stackoverflow.com/ques... le-servers
0
0 / 0 / 0
Регистрация: 10.12.2019
Сообщений: 5
24.12.2019, 23:02  [ТС]
Вот, нашёл в apache mina:

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
    public void ready(final boolean accept, boolean connect, final boolean read, final ByteBuffer readBuffer,
            final boolean write) {
        try {
            final SocketAddress source = datagramChannel.receive(readBuffer);
            NioUdpSession session = null;
            if (source != null) {
                session = sessions.get(source);
                if (session == null) {
                    session = createSession(source, datagramChannel);
                }
                if (read) {
                    readBuffer.flip();
                    session.receivedDatagram(readBuffer);
                }
                // Now, process the writes
                if (write) {
                    session.processWrite(readSelectorLoop);
                }
            }
        } catch (final IOException ex) {
            LOG.error("IOException while reading the socket", ex);
        }
    }
В netty также?
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
24.12.2019, 23:02
Помогаю со студенческими работами здесь

Калькулятор с множеством функции. Неправильно работает факториал
В обще есть такое задание сделать простейший калькулятор, а к нему добавить 10 своих функции. Я сделал следующее: Память,...

Как удалить acronis os selector
У меня 2 системы: Windows7 и Ubuntu Gnome. После установки os selector при старте он запускается, но видит только Линукс! Удалить его не...

Как убрать пароль в Acronis OS Selector?
Народ подсажите плз как взломать лии убрать пароль на операционную систему

как оживить Bios. Acronis OS Selector
В Windows XP установила Acronis OS Selector. Потом решила переустановить XP. Acronis стерла старую XP. A устанавливать новую не захотела....

Acronis OS Selector как его вырубить !!!
Доброго всем времени суток . Поставил на свою шею Acronis OS Selector Теперь при загрузке винды всё время вываливается таблица...


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

Или воспользуйтесь поиском по форуму:
4
Ответ Создать тему
Новые блоги и статьи
SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами
8Observer8 20.02.2026
Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .
Конвертировать закладки radiotray-ng в m3u-плейлист
damix 19.02.2026
Это можно сделать скриптом для PowerShell. Использование . \СonvertRadiotrayToM3U. ps1 <path_to_bookmarks. json> Рядом с файлом bookmarks. json появится файл bookmarks. m3u с результатом. # Check if. . .
Семь CDC на одном интерфейсе: 5 U[S]ARTов, 1 CAN и 1 SSI
Eddy_Em 18.02.2026
Постепенно допиливаю свою "многоинтерфейсную плату". Выглядит вот так: https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11617&stc=1&d=1771445347 Основана на STM32F303RBT6. На борту пять. . .
Камера Toupcam IUA500KMA
Eddy_Em 12.02.2026
Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .
И ясному Солнцу
zbw 12.02.2026
И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.
«Знание-Сила»
zbw 12.02.2026
«Знание-Сила» «Время-Деньги» «Деньги -Пуля»
SDL3 для Web (WebAssembly): Подключение Box2D v3, физика и отрисовка коллайдеров
8Observer8 12.02.2026
Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами и вызывать обработчики событий столкновения. . . .
SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL_LoadPNG (без SDL3_image)
8Observer8 11.02.2026
Содержание блога Библиотека SDL3 содержит встроенные инструменты для базовой работы с изображениями - без использования библиотеки SDL3_image. Пошагово создадим проект для загрузки изображения. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru