Катя Смирнова

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

Если текущий лидер отваливается, почему вы думаете, что все остальные узлы узнают об этом по очереди?
Узнают одновременно. И одновременно пошлют всем узлам, что они новые лидеры, и получится бардак.
Именно поэтому и проводится выбор - либо генерируется случайное число каждым узлом, и выбирается среди всех тот, у кого число самое большое. Либо есть заранее заданные приоритеты выбора лидеров, основанные или на конфигах, или на мощностях, как уж создателю программы показалось нужным.
Опять же, в алгоритм можно добавить настройки, чтобы администратор мог указать какие машины не должны участвовать в выборе.

Однозначно либо "Прикладная математика и информатика", либо "Программная инженерия".
Только не забывай, что помимо этого все равно придётся очень много развиваться самостоятельно, если хочешь стать программистом.

Добрый день!
Возможно, информация по ссылке будет полезна для вас. Тут ответ на аналогичный вопрос:
(обратите внимание на оба ответа)
https://stackoverflow.com/questions/21181551/read-...

Также по теме:
https://stackoverflow.com/questions/51017694/apach...

Настроить ингресс.
Выделить отдельный порт.

Вы можете изменить путь до ендпоинта с метриками, включить авторизациию или ограничить получение данных по IP сервера с Prometheus

Для смены пути или авторизации, смотрите документацию к конфигам Prometheus
https://prometheus.io/docs/prometheus/latest/confi...

У GET запроса не должно быть тела.

Из-за особенностей работы сборщика мусора в Go у вас скорее всего возникнут проблемы, если ключи в map'е содержат указатели (включая структуры их содержащие).

Вот накидал способ хранения сокетов немного в другом виде без указателей в ключах:

const n = 4 // длина идентификатора комнаты в байтах
type (
	noop struct{}
	WebSocket struct{} // сокет

	Sockets []WebSocket
	RoomKey [n]byte
	
	Index uint32

	Room map[Index] struct{}
	Rooms map[RoomKey] Room
)

var sockets = make(Sockets, 0, 2000000)
var rooms = make(Rooms, 1000)
var lastSocketRoomKey RoomKey

func insert(ws WebSocket, rk RoomKey){
	room, _ := rooms[rk]
	// тут создание комнаты, если ее нет
	// ...
	
	sockets = append(sockets, ws)
	
	last := len(sockets) - 1
	room[Index(last)] = noop{}
  
        // сохраним ключ комнаты последнего сокета
        // чтобы можно было исправить индекс при удалении
        copy(lastSocketRoomKey[:], rk[:])
}

func remove(i Index, rk RoomKey){
	// удаляем сокет,
	// переместив последний в массиве на место удаляемого

	last := len(sockets) - 1
	sockets[i] = sockets[last]
	sockets = sockets[:last]

	// удаляем сокет из комнаты
	room, _ := rooms[rk]
	delete(room, Index(i))

	// чиним индекс перемещенного сокета
	roomOfLast := rooms[lastSocketRoomKey]
	delete(roomOfLast, Index(last))
	roomOfLast[Index(i)] = noop{}
}

Когда вам нужно разослать сообщения, в моем примере доступ к сокету будет происходить примерно так:

for _, index := range rooms[roomkey]{
     // sockets[index] -- сокет в комнате с roomkey
     
    // т.к. из-за особенности структуры искать сокет в комнате получается невыгодно долго, 
    // придется удалять закрытые сокеты "ленивым" способом во время рассылки, 
    // либо заполнять массив индексов и после уже удалять эти сокеты из общего хранилища
    // функцией remove(index, roomkey)
}

Очевидно, что в данном примере доступ к sockets и rooms не должен происходить из разных горутин.

Решение оказалось простым), нужно заменить log.Fatal(err) на log.Println(err) или на что нить другое. Каждый раз когда перезагружается страница соединение по websocket закрывается, поэтому websocket: close 1001 (going away). это норма ).

https://golang.org/pkg/encoding/json/#example_Unmarshal
https://golang.org/pkg/encoding/json/#example_RawM...

Вполне себе любая развитая современная РСУБД годится для этой задачи.
MySQL, PostgreSQL...

А по мере роста нагрузки - тут не выбором СУБД нужно заморачиваться, а MQ-сервер ставить. Он гораздо легче сравиться с бешенными нагрузками.

Как вариант - Queue на базе Tarantool, например. Я даже не знаю что вы там должны такое сделать, чтобы заткнуть его производительность. При условии того, что на сервере достаточно много оперативной памяти.

Из самого критично подозрительного - полнотекстовый поиск.
Впрочем, полагаю, что полнотекстового поиска средствами MySQL или PostgreSQL вплоне хватит.

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

Но, для начала, возможностей PostgreSQL или MySQL будет вполне достаточно.

Что до Mongo... Если вам не нужна репликация без консистентности. Зато быстрая...
Так вот если вам не нужна такая репликация, то Монга вам не нужна.

РСУБД будут существенно быстрее.

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

Вывод:

Начните с обычной РСУБД.
Как начнутся затыки - рассмотрите MQ
Как начнется рост до масштаба планеты - рассматрите Монгу.

Вся система работает с бд MySQL - InnoDB, сообщения пишутся в бд при каждой отправке (INSERT), пока сервис еще не запущен, сообщений мало (только мои тестовые) все работает шустро, но вот когда запущу и количество сообщений перевалит за несколько миллионов, что будет тогда с моей бд? Начнутся жесткие тормоза при select и insert?

Вам никто не мешает это проверить.
Сгенерируйте миллион случайных сообщений.

При грамотном использовании индексов - ровным счетом никаких проблем ни на миллионах ни на миллиардах записей.

SELECT * FROM `ips` WHERE INET_NTOA(`ip`) LIKE '127.0%';

SELECT * FROM `ips` WHERE INET_NTOA(ip) LIKE '127.0%'

ну тут и понаписывали...
это решается одной функцией https://secure.php.net/manual/ru/function.array-co...

$za = new ZipArchive(); 
$za->open('/path/to/your.zip'); 

for( $i = 0; $i < $za->numFiles; $i++ ){ 
	$stat = $za->statIndex( $i ); 
	echo $stat['name'], PHP_EOL; 
}

как раскидать файлы по папкам в массиве предлагаю подумать самому.