Topological consensus system (TCS)

Автор: Александр Коробкин и команда разработчиков

Введение новой инновационной технологии распределенных систем: СТК

Сегодня мы рады представить вашему вниманию нашу новую инновационную технологию, основанную на протоколе Chord, но с рядом уникальных особенностей, которые увеличивают его функциональность и производительность. Мы назвали нашу технологию "СТК" (Система Топологического Консенсуса).

Предназначение СТК

СТК является распределенной хэш-таблицей (DHT), которая позволяет эффективно организовывать и управлять данными в распределенной системе. Она подходит для использования в различных приложениях, таких как:

Распределенные файловые системы: Обеспечение масштабируемого и надежного хранения данных.
Облачные решения: Организация данных и ресурсов в крупных облачных инфраструктурах.
Сетевые службы имен: Обеспечение эффективного и быстрого доступа к распределенным данным.
Интернет вещей (IoT): Управление огромными объемами данных от различных устройств в сети.
Системы контент-распределения (CDN): Оптимизация хранения и доступа к контенту для пользователей по всему миру.
Блокчейн приложения: Распределение и хранение транзакций и данных в сети блокчейн.

Особенности СТК

1. Автоматическое восстановление узлов:
Узлы в системе СТК способны автоматически восстанавливаться после сбоев, поддерживая целостность и доступность данных.

2. Вложенные кольца узлов (подсети):
СТК поддерживает создание подсетей внутри основной сети, что позволяет организовать более сложную иерархию данных и распределение нагрузок.

3. Расширяемая Finger Table:
Наше решение включает динамически обновляемые Finger Tables, которые обеспечивают более быстрый и эффективный поиск узлов.

4. Балансировка нагрузки:
СТК автоматически распределяет нагрузки по узлам, что предотвращает перегрузки и увеличивает общую производительность системы.

Примеры использования СТК

Для демонстрации возможностей СТК, предположим, что у нас есть облачная платформа для хранения и обработки больших объемов данных. Использование СТК для организации этой платформы дает следующие преимущества:

Распределенные файлы: Каждый файл хэшируется и распределяется по узлам сети. В случае выхода из строя любого узла, файл автоматически реплицируется на другие узлы.
Масштабируемость: Добавление новых узлов в сеть происходит без перебоев в работе системы. СТК автоматически обновляет таблицы маршрутизации.
Высокая доступность: Данные доступны 99.999% времени благодаря механизму автоматического восстановления и балансировки нагрузки.

Пример использования в облачных решениях

СТК может стать основой для разработки следующих облачных сервисов:

Облачное хранилище: Поддержка файловых систем, таких как Amazon S3 или Google Cloud Storage, с возможностью распределенного хранения и управления данными.
Облачные вычисления: Организация ресурсов для выполнения параллельных задач и распределенных вычислений.
Сетевые файерволы: Обеспечение безопасности и управления доступом в распределенных сетевом окружении.
Виртуальные частные сети (VPN): Создание масштабируемых и безопасных виртуальных частных сетей с распределенным управлением.

Пример кода на GoLang

Для иллюстрации основного механизма работы СТК представляем небольшой фрагмент кода на Go:

package main

import (
 "fmt"
 "log"
 "math/big"
 "sync"
 "time"
)

// Node структура, представляющая узел в СТК
type Node struct {
 ID        uint64
 Address   string
 Successors []Node
 Predecessor *Node
 FingerTable []Node

 mu sync.Mutex
}

// Создание нового узла и запуск в сети СТК
func (n *Node) Create() {
 n.Predecessor = nil
 n.Successors = append(n.Successors, *n)
}

// Присоединение к сети СТК через другой известный узел
func (n *Node) Join(knownNode *Node) {
 n.Predecessor = nil
 n.Successors = append(n.Successors, knownNode.FindSuccessor(n.ID))
}

// FindSuccessor внедрение для СТК
func (n *Node) FindSuccessor(id uint64) *Node {
// Логика поиска ближайшего узла-преемника
// Это псевдокод, фактическая логика должна быть заполнена
 return nil
}

func (n *Node) Stabilize() {
 // Логика для стабилизации узла: проверка предшественника, поиск новых преемников и т.д.
}

func (n *Node) FixFingers() {
 // Логика обновления пальцевых таблиц
}

// Периодические вызовы для стабилизации и фиксации пальцев
func (n *Node) Run() {
 for {
  time.Sleep(15 * time.Second) 
  n.Stabilize()
  n.FixFingers()
 }
}

// Пример создания ноды и ее запуска в фоновом режиме
func main() {
 bootstrapNode := Node{ID: 1, Address: "localhost:8000"}
 go bootstrapNode.Run()
 bootstrapNode.Create()
 fmt.Println("STK Ring created")

 node2 := Node{ID: 2, Address: "localhost:8001"}
 node2.Join(&bootstrapNode)
 go node2.Run()

 select {}
}

(ps: Логика FindSuccessor, Stabilize, FixFingers. будет рассмотрена, более подробно, в последующих сериях статей, для очерка концепции идеи это пока не важно.)

Система без центра: Децентрализованность и масштабируемость СТК

Одним из ключевых преимуществ СТК (Система Топологического Консенсуса) является его возможность обеспечивать децентрализованное управление данными и ресурсами, создавая "систему без центра". Это значит, что в сети СТК нет центрального источника контроля или узла, на который приходится большая часть нагрузки и ответственности. Вместо этого, все узлы сети равноправны и работают совместно для обеспечения надежности и производительности системы. Рассмотрим более подробно, как это работает и какие преимущества это дает.

Принципы децентрализованной архитектуры СТК

Распределенная хэш-таблица (DHT)

В СТК используется распределенная хэш-таблица (DHT), которая распределяет данные и задачи между всеми узлами сети. Каждый узел отвечает за определенный диапазон ключей, что делает возможным управление огромными объемами данных без централизованного контроля.
Механизмы самоорганизации

Узлы в СТК обладать способностью к самоорганизации и поддержанию своей структуры без централизованного контроля. Это включает в себя автоматическое восстановление после сбоев, обновление таблиц маршрутизации (Finger Tables) и балансировку нагрузки между узлами.
Взаимодействие равноправных узлов (P2P)

Узлы СТК общаются между собой напрямую, без необходимости обращения к какому-либо центральному серверу. Это обеспечивает равномерное распределение нагрузки и уменьшает риски, связанные с отказом одного узла.
Алгоритмы консенсуса

Для обеспечения согласованности и целостности данных узлы используют алгоритмы консенсуса, такие как PBFT или Raft. Эти алгоритмы позволяют узлам договариваться о состоянии системы и принимаемых изменениях, не полагаясь на центральный узел.

Примеры применения децентрализованной системы СТК

Блокчейн технологии

В блокчейн-сетях, таких как Bitcoin или Ethereum, важно поддерживать децентрализованную структуру для обеспечения безопасности и устойчивости к цензуре. СТК может использоваться для создания и управления распределенными реестрами транзакций без централизованного контроля.
Децентрализованные социальные сети

Модернные социальные платформы сталкиваются с проблемами цензуры и приватности данных. С использованием СТК можно создавать системы, где пользователи контролируют свои данные и взаимодействуют напрямую друг с другом.
Peer-to-Peer файлообменники

СТК может служить основой для P2P файлообменников, таких как BitTorrent. Это позволит обеспечить быстрый и надежный обмен файлами между пользователями без потребности в центральном сервере.
Децентрализованные облачные вычисления

В традиционных облачных платформах централизованные серверы являются точкой отказа и узким местом производительности. СТК позволяет распределять задачи вычислений по сети узлов, что увеличивает надежность и масштабируемость.

Преимущества системы без центра СТК

Устойчивость к сбоям

В децентрализованной системе отсутствие центрального узла делает её более устойчивой к различным сбоям и атакам. Выход из строя одного из узлов не приведет к краху всей системы.
Масштабируемость

Добавление новых узлов в децентрализованную сеть СТК увеличивает её мощность и возможности без необходимости кардинальных изменений в архитектуре. Это позволяет системе легко масштабироваться в зависимости от потребностей.
Приватность и безопасность

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

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

Как работает сеть СТК и её рабочая единица — узел

В контексте Системы Топологического Консенсуса (СТК), узел является основным строительным элементом сети. Понимание того, как работают узлы в этой системе, помогает лучше оценить возможности и преимущества СТК. В этой статье мы рассмотрим основные принципы работы сети СТК и конкретные функции узлов в ней.

Основные принципы работы сети СТК

1. Децентрализованная структура

Сеть СТК построена на основе децентрализованной архитектуры, где отсутствует центральный управляющий узел. Каждый узел несет одинаковую ответственность за выполнение задач и поддержание целостности сети.

2. Распределенное хранилище данных

Данные в сети СТК хранятся распределенно с использованием таких структур, как распределенные хэш-таблицы (DHT). Это позволяет надежно хранить и быстро находить данные, делая систему устойчивой к сбоям и атакам.

3. Алгоритмы консенсуса

Алгоритмы консенсуса, такие как PBFT (Practical Byzantine Fault Tolerance) или Raft, обеспечивают согласованность данных и правильное исполнение операций в децентрализованной сети. Узлы договариваются о действиях и изменениях, исходя из большинства голосов.

Как работает узел в сети СТК

1. Регистрация и подключение узла

При добавлении нового узла в сеть, он проходит процесс регистрации, в ходе которого другие узлы проверяют его и включают в распределенные хэш-таблицы. Узлы обменяются информацией о своих соседях и формируют таблицы маршрутизации (Finger Tables).

2. Хранение данных

Каждый узел отвечает за определенный диапазон ключей. Когда данные добавляются в сеть, они хэшируются, и узел, соответствующий хэш-значению, становится ответственным за их хранение. Например, в DHT-системах данных с хэш-ключами от 100 до 199 будет храниться на узле, который отвечает за эти ключи.

3. Поиск и передача данных

Когда пользователь сети запрашивает данные, его узел хэширует запрос и обращается к своей таблице маршрутизации, чтобы найти ближайший узел, хранящий запрашиваемые данные. Узлы передают запрос по цепочке, пока нужные данные не будут найдены и переданы обратно.

4. Обеспечение согласованности и безопасности

Узлы участвуют в алгоритмах консенсуса, чтобы обеспечить согласованность данных. Например, в PBFT узлы обмениваются сообщениями и подтверждают корректность операций, прежде чем изменения считаются валидными.

Пример работы узлов:

Обмен файлами:
В сети, подобной BitTorrent, файлы разбиваются на части и распределяются среди узлов. Когда узел А хочет загрузить файл, он ищет узлы B, C, и D, хранящие различные части этого файла. Узел А загружает части параллельно у разных узлов, объединяет их и предоставляет доступ к файлу также другим узлам, если потребуется.
Блокчейн Транзакции:
В децентрализованной блокчейн-системе каждый узел хранит копию всей цепочки блоков. Когда новая транзакция создается узлом А, она транслируется по всей сети. Узлы B, C и D проверяют транзакцию, используют консенсусный алгоритм для ее валидации и добавляют в новый блок.

Преимущества работы узлов в СТК

Устойчивость и отказоустойчивость

Взаимозаменяемость узлов и децентрализация делают сеть СТК устойчивой к отдельным сбоям.
Гибкость и масштабируемость

Новые узлы могут легко подключаться к сети, расширяя её возможности и мощность.
Прозрачность и безопасность

Алгоритмы консенсуса и распределенное хранение данных препятствуют несанкционированному доступу и манипулированию данными.

Взаимодействие узлов в контексте кольцевой сети (СТК)

В кольцевой сети каждый узел соединен логически с двумя другими узлами - своим преемником (successor) и предшественником (predecessor), таким образом формируя кольцо. Передача данных и сообщений осуществляется по этому кольцу, и каждый узел играет роль ретранслятора для сообщений, которые не предназначены ему прямо.

Алгоритм взаимодействия

Инициализация сети:
- Один узел запускается первым и начинает слушать входящие соединения.
- Следующие узлы подключаются к сети через уже существующие узлы.
Присоединение нового узла:
- Новый узел связывается с одним из текущих узлов в сети.
- Текущий узел анализирует идентификатор (ID) нового узла и его положение в кольце, чтобы вставить в правильное место.
- Настройка ссылок на преемника и предшественника обновляется как для нового узла, так и для узлов, которые теперь находятся перед ним и после него.
Поиск и маршрутизация:
- Чтобы найти информацию или ресурс, узел инициирует запрос, который передается по кольцу.
- Каждый узел проверяет запрос и либо отвечает на него, либо перенаправляет его на свой следующий узел. Так продолжается, пока цель не достигнута.
Обработка отказов:
- СТК должен мониторить состояние узлов.
- Если узел не отвечает, его соседние узлы обновляют свои ссылки на нового преемника или предшественника, тем самым обеспечивая отказоустойчивость.

Подробное взаимодействие между узлами

Рассмотрим примеры взаимодействия в кольце при добавлении нового узла и передачи сообщений:

Пример присоединения нового узла:

Давайте представим, что в уже существующем кольце с узлами A (ID=1), B (ID=2), и C (ID=3) добавляется новый узел D с ID=4.
Узел D подключается к узлу A.
Узел A анализирует позицию D и передает его дальше B или C, в зависимости от их ID.
В итоге D определяется как предшественник узла A и преемник узла C.
Узлы C и A обновляют свои ссылки на новый узел, интегрируя его в кольцо.

Пример передачи и маршрутизации сообщений:

Узел A хочет передать сообщение узлу C.
A проверяет, является ли C его преемником. Если нет, то передает сообщение своему преемнику - узлу B.
Узел B выполняет аналогичную проверку и передает сообщение дальше, пока оно не достигает узла C.
Узел C получает сообщение и отвечает обратно по кольцу, проходя через B к A.

func (n *Node) SendMessage(targetID int, message string) {
 if n.id == targetID {
  fmt.Println("Message received:", message)
  return
 }
 
 n.mu.Lock()
 defer n.mu.Unlock()
 
 // Forward the message to successor
 if n.successor != nil {
  // Assuming we have a way to send a message to a successor node here
  n.successor.SendMessage(targetID, message)
 }
}

Таким образом, структура кольцевой сети обеспечивает надежную маршрутизацию и передачу данных, минимизируя задержки и увеличивая надежность системы.

Этот пример показывает, как простота конструкции кольцевой сети позволяет осуществлять основу для масштабируемых и отказоустойчивых распределённых систем.

Примеры запуска и работы узлов СТК на Go

В контексте систем с топологией кольца (СТК), задачи запуска узлов, добавления новых узлов к уже существующей кольцевой сети и взаимодействия с этими узлами играют ключевую роль. В этом разделе мы рассмотрим, как можно реализовать эти механизмы на языке программирования Go (Golang). Мы создадим простую версию распределенной хэш-таблицы (DHT) с использованием кольцевой топологии, показывая как запускать узлы и добавлять новые узлы к сети, а также как отправлять значения в узел с обновлением в остальных узлах.

Шаг 1: Создание узла

Создадим базовую структуру Node, которая будет представлять узел в нашей сети:

package main

import (
 "fmt"
 "hash/fnv"
 "sync"
)

type Node struct {
 id         int
 data       map[string]string
 successor  *Node
 predecessor *Node
 mu         sync.Mutex
}

func NewNode(id int) *Node {
 return &Node{
  id:   id,
  data: make(map[string]string),
 }
}

Шаг 2: Запуск узла

Реализуем функцию для запуска нового узла и добавления его в кольцовую топологию:

func (n *Node) Join(existingNode *Node) {
 if existingNode == nil {
  n.successor = n
  n.predecessor = n
 } else {
  // Найти правильное место для нового узла
  n.findSuccessor(existingNode)
 }
}

func (n *Node) findSuccessor(existingNode *Node) {
 if n.id > existingNode.id && n.id <= existingNode.successor.id {
  // Вставить узел между existingNode и его преемником
  n.successor = existingNode.successor
  n.predecessor = existingNode
  existingNode.successor.predecessor = n
  existingNode.successor = n
 } else if existingNode.id > existingNode.successor.id && (n.id > existingNode.id || n.id < existingNode.successor.id) {
  // Специальный случай для замыкания кольца
  n.successor = existingNode.successor
  n.predecessor = existingNode
  existingNode.successor.predecessor = n
  existingNode.successor = n
 } else {
  n.findSuccessor(existingNode.successor)
 }
}

Шаг 3: Добавление новых узлов

Теперь добавим функцию, чтобы новые узлы могли добавляться к уже существующей сети:

func addNode(existingNode *Node, newNodeID int) *Node {
 newNode := NewNode(newNodeID)
 newNode.Join(existingNode)
 return newNode
}

Шаг 4: Отправка значений и их обновление в сети

Реализуем функции для хранения и получения значений. При отправке значения будет обновляться соответствующий узел:

func (n *Node) Store(key, value string) {
 hashedKey := hashString(key)
 targetNode := n.findNodeForKey(hashedKey)
 targetNode.mu.Lock()
 targetNode.data[key] = value
 targetNode.mu.Unlock()
}

func (n *Node) Retrieve(key string) (string, bool) {
 hashedKey := hashString(key)
 targetNode := n.findNodeForKey(hashedKey)
 targetNode.mu.Lock()
 defer targetNode.mu.Unlock()
 value, ok := targetNode.data[key]
 return value, ok
}

func (n *Node) findNodeForKey(hashKey int) *Node {
 if hashKey > n.id && hashKey <= n.successor.id {
  return n.successor
 } else if n.id > n.successor.id && (hashKey > n.id || hashKey < n.successor.id) {
  return n.successor
 } else {
  return n.successor.findNodeForKey(hashKey)
 }
}

func hashString(s string) int {
 h := fnv.New32a()
 h.Write([]byte(s))
 return int(h.Sum32())
}

Пример использования и команды запуска

Теперь рассмотрим, как запустить один узел и добавить к нему остальные для создания кольцевой структуры сети:

func main() {
 // Создание и запуск первого узла
 node1 := NewNode(1)
 node1.Join(nil)

 // Добавление новых узлов к уже существующему узлу
 node2 := addNode(node1, 2)
 node3 := addNode(node1, 3)
 node4 := addNode(node1, 4)

 // Пример хранения значений в узлах
 node1.Store("key1", "value1")
 node2.Store("key2", "value2")

 // Пример получения значений из узлов
 val, ok := node3.Retrieve("key1")
 if ok {
  fmt.Printf("Node3 retrieved key1: %s\n", val)
 } else {
  fmt.Println("Key not found")
 }

 val, ok = node4.Retrieve("key2")
 if ok {
  fmt.Printf("Node4 retrieved key2: %s\n", val)
 } else {
  fmt.Println("Key not found")
  }
}

Команды для запуска:

Создайте файл main.go и поместите в него вышеуказанный код.
Откройте терминал и перейдите в директорию, содержащую файл main.go.
Скомпилируйте и запустите программу:
```
go run main.go
```

Этот пример демонстрирует базовую модель сети с кольцевой топологией: создаём узлы, соединяем их в сеть, отправляем и получаем данные. Этот подход можно расширять и модифицировать для более сложных и масштабируемых систем.

Примеры запуска узлов в СТК на Go: Организация кольцевой сети с независимыми процессами

Шаг 1: Создание структуры узла

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

package main

import (
 "fmt"
 "net"
 "sync"
)

type Node struct {
 id          int
 address     string
 successor   *Node
 predecessor *Node
 mu          sync.Mutex
}

func NewNode(id int, address string) *Node {
 return &Node{
  id:      id,
  address: address,
 }
}

func (n *Node) String() string {
 return fmt.Sprintf("Node{id: %d, address: %s}", n.id, n.address)
}

Шаг 2: Запуск узла с ожиданием присоединения

Создадим функцию для запуска узла, который будет прослушивать указанный адрес и порт для подключения других узлов:

func (n *Node) StartListening() {
 ln, err := net.Listen("tcp", n.address)
 if err != nil {
  fmt.Println("Error starting node:", err)
  return
 }
 defer ln.Close()
 fmt.Println(n, "is listening")

 for {
  conn, err := ln.Accept()
  if err != nil {
   fmt.Println("Error accepting connection:", err)
   continue
  }
  go n.handleConnection(conn)
 }
}

func (n *Node) handleConnection(conn net.Conn) {
 defer conn.Close()
 var remoteID int
 fmt.Fprintln(conn, "Enter node ID:")
 fmt.Fscanln(conn, &remoteID)
 newNode := NewNode(remoteID, conn.RemoteAddr().String())
 n.Join(newNode)
 fmt.Println(newNode, "joined the ring")
}

Шаг 3: Присоединение нового узла к существующему

Реализуем механизм добавления нового узла к уже существующему кольцу:

func (n *Node) Join(newNode *Node) {
 n.mu.Lock()
 defer n.mu.Unlock()

 if n.successor == nil || n == n.successor {
  // Первый узел в сети
  n.successor = newNode
  n.predecessor = newNode
  newNode.successor = n
  newNode.predecessor = n
 } else {
  // Найти подходящее место для нового узла
  n.findPositionForNewNode(newNode)
 }
}

func (n *Node) findPositionForNewNode(newNode *Node) {
 if newNode.id > n.id && newNode.id < n.successor.id {
  // Вставить новый узел между текущим узлом и его последователем
  newNode.successor = n.successor
  newNode.predecessor = n
  n.successor.predecessor = newNode
  n.successor = newNode
 } else if n.id > n.successor.id && (newNode.id > n.id || newNode.id < n.successor.id) {
  // Специальный случай для замыкания кольца
  newNode.successor = n.successor
  newNode.predecessor = n
  n.successor.predecessor = newNode
  n.successor = newNode
 } else {
  // Пройти дальше по кольцу
  n.successor.findPositionForNewNode(newNode)
 }
}

Файл node.go со всеми вспомогательными функциями

// node.go

package main

import (
 "fmt"
 "net"
 "sync"
)

type Node struct {
 id          int
 address     string
 successor   *Node
 predecessor *Node
 mu          sync.Mutex
}

func NewNode(id int, address string) *Node {
 return &Node{
  id:      id,
  address: address,
 }
}

func (n *Node) String() string {
 return fmt.Sprintf("Node{id: %d, address: %s}", n.id, n.address)
}

func (n *Node) StartListening() {
 ln, err := net.Listen("tcp", n.address)
 if err != nil {
  fmt.Println("Error starting node:", err)
  return
 }
 defer ln.Close()
 fmt.Println(n, "is listening")

 for {
  conn, err := ln.Accept()
  if err != nil {
   fmt.Println("Error accepting connection:", err)
   continue
  }
  go n.handleConnection(conn)
 }
}

func (n *Node) handleConnection(conn net.Conn) {
 defer conn.Close()
 var remoteID int
 fmt.Fprintln(conn, "Enter node ID:")
 fmt.Fscanln(conn, &remoteID)
 newNode := NewNode(remoteID, conn.RemoteAddr().String())
 n.Join(newNode)
 fmt.Println(newNode, "joined the ring")
}

func (n *Node) Join(newNode *Node) {
 n.mu.Lock()
 defer n.mu.Unlock()

 if n.successor == nil || n == n.successor {
  // Первый узел в сети
  n.successor = newNode
  n.predecessor = newNode
  newNode.successor = n
  newNode.predecessor = n
 } else {
  // Найти подходящее место для нового узла
  n.findPositionForNewNode(newNode)
 }
}

func (n *Node) findPositionForNewNode(newNode *Node) {
 if newNode.id > n.id && newNode.id < n.successor.id {
  // Вставить новый узел между текущим узлом и его последователем
  newNode.successor = n.successor
  newNode.predecessor = n
  n.successor.predecessor = newNode
  n.successor = newNode
 } else if n.id > n.successor.id && (newNode.id > n.id || newNode.id < n.successor.id) {
  // Специальный случай для замыкания кольца
  newNode.successor = n.successor
  newNode.predecessor = n
  n.successor.predecessor = newNode
  n.successor = newNode
 } else {
  // Пройти дальше по кольцу
  n.successor.findPositionForNewNode(newNode)
 }
}

Шаг 4: Примеры запуска узлов и создания кольца

Теперь рассмотрим, как запустить узлы как отдельные процессы и как они будут соединяться друг с другом, чтобы создать кольцевую сеть:

Создайте отдельные файлы для каждого узла: node1.go, node2.go, и node3.go, которые будут импортировать и использовать определения из node.go.

node1.go:

package main

import (
 "fmt"
 "net"
 "time"
)

func main() {
 node1 := NewNode(1, "localhost:8000")
 go node1.StartListening()

 // Ждем присоединения других узлов
 time.Sleep(60 * time.Second)
 fmt.Println("Node 1 done")
}

node2.go:

package main

import (
 "fmt"
 "net"
 "time"
)

func main() {
 node2 := NewNode(2, "localhost:8001")
 go node2.StartListening()

 time.Sleep(1 * time.Second) // Ждем, пока второй узел начнет слушать

 conn, err := net.Dial("tcp", "localhost:8000")
 if err != nil {
  fmt.Println("Error connecting to node1:", err)
  return
 }
 defer conn.Close()

 fmt.Fprintln(conn, node2.id)

 time.Sleep(60 * time.Second)
 fmt.Println("Node 2 done")
}

node3.go:

package main

import (
 "fmt"
 "net"
 "time"
)

func main() {
 node3 := NewNode(3, "localhost:8002")
 go node3.StartListening()

 time.Sleep(1 * time.Second) // Ждем, пока третий узел начнет слушать

 conn, err := net.Dial("tcp", "localhost:8000")
 if err != nil {
  fmt.Println("Error connecting to node1:", err)
  return
 }
 defer conn.Close()

 fmt.Fprintln(conn, node3.id)

 time.Sleep(60 * time.Second)
 fmt.Println("Node 3 done")
}

Шаг 5: Запуск узлов как отдельные процессы

Теперь необходимо скомпилировать и запустить все три узла как отдельные процессы:

Откройте три разных терминала или консольные окна и выполните следующие команды:

В первом терминале выполните:
```
go run node1.go
```
Во втором терминале выполните:
```
go run node2.go
```
В третьем терминале выполните:
```
go run node3.go
```

В этом примере:

Каждый узел запускается как отдельный процесс и начинает прослушивать заданный адрес и порт.
Последующие узлы подключаются к первому узлу и добавляются в кольцо.
Все узлы работают автономно и управляют соединениями независимо, обмениваясь данными через TCP.

Таким образом, мы можем организовать кольцевую сеть, где каждый узел является самостоятельной рабочей единицей и работает в отдельном процессе, обеспечивая надежное взаимодействие и гибкость системы.

Распространение значений по узлам в контексте СТК

В кольцевой сети алгоритмы распространения значений, такие как поиск ресурса или передача сообщений, базируются на прохождении сообщений от узла к узлу по кольцу. Ниже приведены несколько примеров алгоритмов.

1. Пример алгоритма поиска ресурса

Рассмотрим ситуацию, когда узел A ищет ресурс, который находится у узла C.

 A -> B -> C -> D
 |    |    |    |
 v    v    v    v
Node Node Node Node
 1    2    3    4

Алгоритм:

Узел A отправляет запрос на поиск ресурса к своему преемнику B.
Узел B проверяет наличие ресурса. Если отсутствует, он перенаправляет запрос дальше к C.
Узел C находит ресурс и отвечает A.

(A)---->(B)---->(C)---->(D)
 |       |       |       |
 v       v       v       v
Req     Req      Res     Wait
        |       /        ^
        v      /         |
       Req    /___________|

2. Пример алгоритма добавления нового узла

Рассмотрим добавление нового узла E с ID 5 в уже существующую сеть.

 A -> B -> C -> D
 |    |    |    |
 v    v    v    v
Node Node Node Node
 1    2    3    4

Алгоритм:

Узел E подсоединяется к A и отправляет запрос на включение в кольцо.
Узел A определяет подходящую позицию для E. Запрос перенаправляется к D.
Узел D обновляет свои ссылки на новый узел E.

(A)---->(B)---->(C)---->(D)
 |       |       |       |
 v       v       v       v
 New     ->      ->      ->
(E)---->(A)---->(B)---->(C)---->(D)

3. Пример обработки отказа узла

Рассмотрим ситуацию, когда узел B выходит из строя.

 A -> B (fail) -> C -> D
 |     |       |    |
 v     v       v    v
Node (Fail)   Node Node
 1     2       3     4

Алгоритм:

Узел A обнаруживает отказ B, когда не может его достичь.
Узел A перенаправляет свои ссылки на преемника C.

(A)---->(B)---->(C)---->(D)
 |       |      ^       |
 v       x     /        v
       (Fail) /         |
              /_________|

В обновленной сети:

(A)---->(C)---->(D)
 |       |       |
 v       v       v
Node    Node    Node
 1       3       4

В каждом из этих примеров можно наглядно продемонстрировать, как узлы взаимодействуют при различных операциях в кольцевой сети. Эти схемы помогут визуализировать внутренние процессы и упростят понимание работы распределенных систем.

Заключение

Система Топологического Консенсуса (СТК) представляет собой мощное средство для создания децентрализованных распределенных систем. Использование таких систем без центра открывает новые возможности для построения надежных, масштабируемых и безопасных приложений в различных областях, от блокчейна до социальных сетей и облачных вычислений. СТК обеспечивает высокую степень самоорганизации, масштабируемости и устойчивости, что делает её привлекательным решением для современного мира распределенных технологий.

Мы уверены, что СТК станет важным шагом вперед в мире распределенных систем благодаря своей уникальности, надежности и масштабируемости. В нашей команде мы активно применяем СТК для проектирования и реализации облачных решений, что позволяет нам создавать высоконадежные и производительные системы для наших клиентов.

Если эта статья вызовет интерес и положительные отзывы у наших читателей, мы с радостью продолжим развивать данное направление и представим более глубокие и детализированные материалы. В будущем мы планируем рассмотреть такие темы, как:

Оптимизация распределённых алгоритмов.
Использование различных топологий сетей (не только кольцевых).
Поддержка отказоустойчивости и балансировки нагрузки в распределённых системах.
Инструменты и фреймворки для построения распределённых систем.

Мы будем рады делиться нашими знаниями и опытом, чтобы вы могли создавать ещё более эффективные распределённые системы и улучшать свои вычислительные процессы. Ваши комментарии и отзывы будут для нас важным источником вдохновения для будущих статей.

С уважением,
Александр Коробкин и команда разработчиков