JГруппы
 | Эта статья нуждается в дополнительных цитатах для проверки . ( февраль 2018 г. ) |
| Разработчик(и) | Бела Бан |
|---|---|
| Стабильный релиз(ы) | |
| Репозиторий | github |
| Написано в | Ява |
| Операционная система | Кросс-платформенный |
| Размер | 2,1 МБ |
| Тип | надежная многоадресная система |
| Лицензия | Лицензия Апач 2.0 |
| Веб-сайт | www |
JGroups — это библиотека для надежного взаимодействия «один к одному» или «один ко многим», написанная на языке Java .
Его можно использовать для создания групп процессов, участники которых отправляют друг другу сообщения. JGroups позволяет разработчикам создавать надежные многоточечные (многоадресные) приложения, где надежность является проблемой развертывания. JGroups также освобождает разработчика приложения от необходимости самостоятельно реализовывать эту логику. Это существенно экономит время разработки и позволяет развертывать приложение в различных средах без необходимости изменения кода.
Функции
[ редактировать ]- Создание и удаление группы. Члены группы могут быть распределены по локальным или глобальным сетям.
- Вступление и выход из групп
- Обнаружение членства и уведомление о присоединившихся/ушедших/выпавших участниках
- Обнаружение и удаление разбившихся участников
- Отправка и получение сообщений между членами группы (точка-многоточка)
- Отправка и получение сообщений между участниками (точка-точка)
Пример кода
[ редактировать ]Этот код ниже демонстрирует реализацию простого IRC - клиента командной строки с использованием JGroups:
public class Chat extends ReceiverAdapter {
private JChannel channel;
public Chat(String props, String name) {
channel = new JChannel(props)
.setName(name)
.setReceiver(this)
.connect("ChatCluster");
}
public void viewAccepted(View view) {
System.out.printf("** view: %s\n", view);
}
public void receive(Message msg) {
System.out.printf("from %s: %s\n", msg.getSource(), msg.getObject());
}
private void send(String line) {
try {
channel.send(new Message(null, line));
} catch (Exception e) {}
}
public void run() throws Exception {
BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
while (true) {
System.out.print("> ");
System.out.flush();
send(in.readLine().toLowerCase());
}
}
public void end() throws Exception {
channel.close();
}
public static void start(Chat client) throws Exception {
try {
client.run();
} catch (Exception e) {
} finally {
client.end();
}
}
public static void main(String[] args) throws Exception {
String props = "udp.xml";
String name;
for (int i = 0; i < args.length; i++) {
if (args[i].equals("-props")) {
props = args[++i];
continue;
}
if (args[i].equals("-name")) {
name = args[++i];
continue;
}
System.out.println("Chat [-props XML config] [-name name]");
return;
}
start(new Chat(props, name));
}
}
JChannel создается из конфигурации XML (например, udp.xml). Канал является конечной точкой присоединения к кластеру.
Далее устанавливается получатель, а это значит, что будут вызваны два обратных вызова:
viewAccepted(View view)когда к кластеру присоединяется новый участник или существующий участник покидает кластерreceive(Message msg)когда получено сообщение от какого-либо другого члена кластера
Затем канал присоединяется к кластеру «ChatCluster». С этого момента сообщения можно отправлять и получать, а новое представление (включая этого участника) будет установлено во всех членах кластера (включая вновь присоединившегося участника).
Все, что набирается в основном цикле, приводит к созданию сообщения, которое будет отправлено всем членам кластера, включая отправителя.
Экземпляры приложения чата можно запускать в одном процессе, на одном компьютере, на разных хостах в локальной сети, на хостах в разных сетях или в облаке. Код остается прежним; необходимо изменить только конфигурацию.
Например, в локальной сети может использоваться многоадресная IP-рассылка. Когда многоадресная рассылка IP отключена, в качестве транспорта можно использовать TCP. При запуске в облаке будет использоваться TCP плюс протокол обнаружения облака и так далее...
Гибкий стек протоколов
[ редактировать ]Самая мощная функция JGroups — это гибкий стек протоколов, который позволяет разработчикам адаптировать его в точном соответствии с требованиями своих приложений и характеристиками сети. Преимущество этого в том, что вы платите только за то, что используете. Путем смешивания и сопоставления протоколов можно удовлетворить различные требования приложений. JGroups поставляется с несколькими протоколами (но каждый может написать свой собственный), например
- Транспортные протоколы: UDP ( многоадресная IP-адресация ), TCP
- Фрагментация больших сообщений
- Протоколы обнаружения для определения первоначального членства присоединяющегося узла.
- Надежная одноадресная и многоадресная передача сообщений. Потерянные сообщения передаются повторно.
- Обнаружение сбоя: участники, потерпевшие сбой, исключаются из членства.
- Протоколы заказа: Fifo, Total Order (на основе секвенсора или токена)
- Членство и уведомление о присоединившихся или вышедших из строя участниках
- Обнаружение и объединение сетевых разделов (разделение мозга)
- Управление потоком
- Шифрование и аутентификация (включая поддержку SASL)
- Сжатие
Строительные блоки
[ редактировать ]Строительные блоки — это классы, расположенные над каналами JGroups, которые предоставляют абстракции более высокого уровня, такие как
- RPC к отдельным или всем узлам кластера
- Распределенные кэши
- Распределенные блокировки
- Распределенные атомные счетчики
- Распределенное выполнение задач
Ссылки
[ редактировать ]- ^ Перейти обратно: а б «Релизы · belaban/JGroups» . github.com . Проверено 31 июля 2024 г.