Пусть ваша программа быстро подключается к Zookeeper для обеспечения высокой доступности

Введение

• Используйте curator для подключения к zookeeper, чтобы обеспечить качество соединения.
• Обновляйте данные узлов в zookeeper в реальном времени, чтобы гарантировать согласованность потребления и производства.
• Реализовали управление сервисами, в настоящее время доступны два метода: случайный и циклический опрос. В будущем будут добавлены методы потребления на основе веса и прерывания.
• Sample — это пример программы, которую можно скачать и использовать.

Описание

Использование

//TODO Три шага

//Производитель, инициализация регистрации узла
ZookeeperRegistry zr = new ZookeeperRegistry ();
Zdata zdata = new Zdata();
zr.regist(zdata);


//Потребитель, наследует ZookeeperDiscovery, ожидает обратного вызова
discover (поставщик Zdata);//Доступные узлы
destory();//Как только zookeeper отключается, потребитель также должен отключиться, чтобы поддерживать согласованность


//Если потребитель успешно потребляет, он должен уведомить zookeeper
consume (поставщик Zdata, строка хоста, int порт)//Указать, кто является потребителем, а также собственный IP-адрес и порт

После выполнения этих трёх шагов программа будет работать нормально.

Тестирование

Мониторинг

Скачать http://7xi2xp.com1.z0.glb.clouddn.com/guardian-web-1.0.1.tar.gz

Взаимодействие

• Этот проект будет постоянно обновляться, и мы приглашаем всех продолжать его поддерживать.
• Возможно, на основе этого проекта будут разработаны другие сопутствующие продукты, такие как RPC-фреймворк, IM, распределённая база данных и т. д.
• Присоединяйтесь к группе для общения
  • Присоединитесь через групповой номер: 128909778
  • Или с помощью QR-кода:

Maven адрес

	<dependency>
		<groupId>online.datanode.guardian</groupId>
		<artifactId>guardian-registry</artifactId>
		<version>1.0.1</version>
	</dependency>

	<dependency>
		<groupId>online.datanode.guardian</groupId>
		<artifactId>guardian-discovery</artifactId>
		<version>1.0.1</version>
	</dependency>

	<dependency>
		<groupId>online.datanode.guardian</groupId>
		<artifactId>guardian-common</artifactId>
		<version>1.0.1</version>
	</dependency>