Описание тега nats.io

Описание тега Вопросы с тегом
NATS - это простая, высокопроизводительная система обмена сообщениями с открытым исходным кодом для облачных приложений, обмена сообщениями Интернета вещей и микросервисных архитектур. С клиентами, написанными на Python, Ruby, Node.js, Elixir, Java, NGINX, C, C# и др.
2 ответа

Клиент NATS в GoLang не будет подписываться

У меня есть очень общий сценарий подключения для подключения к серверу nats и просто слепо выводить сообщение в командную строку. package main import ( "github.com/nats-io/go-nats" "fmt" ) func main(){ servers := "nats://URL:30401, nats://URL:30402,…
09 май '18 в 18:16
1 ответ

PHP NATS отправляет результат из функции

У меня возникли проблемы с PHP NATS. Я получаю и распечатываю значения сообщений MSG. Все работает нормально. Просто возвращение результата - проблема. Вот код function connect(){ require_once __DIR__ . "/../../vendor/autoload.php"; $connectionOptio…
05 фев '19 в 11:10
1 ответ

Поведение Nats.io QueueSubscribe по таймауту

Я оцениваю NATS для миграции существующего программного обеспечения на основе MSG. Я не нашел документации об исключении и перегрузке MSG. Например: После выбора подписчика известно ли о настройках тайм-аута, опубликованных издателем? Можно ли уведо…
24 сен '17 в 08:40
1 ответ

Nats.io очередь, синхронное поведение

Согласно https://nats.io/documentation/concepts/nats-queueing/ Synchronous queue subscribers must build in logic to process the message. Означает ли это, что если в очереди 10 сообщений, только 1 подписчик получает 1-е сообщение, а после ответа что-…
05 сен '18 в 11:05
1 ответ

Настройка производительности NATS IO

Я написал издатель, подписчик на Java. Делал кластеризацию также на уровне сервера. Умеет публиковать и подписывать сообщения объемом 30 КБ со скоростью 500 TPS (транзакция в секунду). Но я хочу улучшить нашу производительность до более чем 2000 TPS…
01 авг '17 в 13:15
1 ответ

NATS - только один подписчик для принятия мер в отношении опубликованного события в микросервисной архитектуре

Я новичок в NATS и прочитал все примеры для: https://nats.io/documentation/concepts/nats-messaging/ Я нахожусь в Microservciearchitecture, где в microservice-Y (MSY) нужно хранить некоторую информацию, опубликованную из других microservice-X (MSX), …
05 май '18 в 09:36
0 ответов

Привет, я пытался подключить натс от Ionic по нажатию кнопки отправки, но он не подключается

У меня есть фрагмент кода Nats, который я могу запустить в терминале, следуя по команде узла, но то же самое я могу запустить в ionic2? Мне нужно запустить этот код нац в IONIC2 после нажатия кнопки Натс код: submitBtn() { var natnc = nc.connect({'u…
31 май '18 в 06:29
1 ответ

Доходность сопрограмм продолжать основной

Я пытаюсь использовать сопрограмму для отправки данных в NATS (система обмена сообщениями nats.io). Когда я пытаюсь вызвать этот код без аргументов и для цикла, он работает отлично. Но когда я добавляю аргументы, функция yield nc.connect ничего не в…
30 июл '17 в 13:18
2 ответа

Может ли издатель NATS отправить одно сообщение в несколько очередей?

Я строю систему, в которой двум разным сущностям нужно обрабатывать сообщения из одного и того же источника (по-разному - например, один будет регистрировать все сообщения, в то время как другой может захотеть объединить данные). В идеале каждый объ…
06 июл '17 в 11:48
1 ответ

NATS масштабируется горизонтально (пропускная способность)

Мы используем NATS и используем кластеризацию из 3+ узлов. У нас есть несколько производителей и много потребителей. Размеры сообщений небольшие ( ~100 байт), однако наша пропускная способность несколько высока. ~40k/ сек. Весь трафик проходит по вн…
04 апр '17 в 22:00
0 ответов

Отладка сообщений NATS от события Kubernetes

У меня есть простой сценарий, который отслеживает события Kubernetes и затем публикует сообщение на сервер NATS: #!/usr/bin/env python import asyncio import argparse import json import logging import os from kubernetes import client, config, watch f…
19 ноя '18 в 20:12
1 ответ

NATS-Streaming-Server с задержкой 1 мс

Можно ли настроить кластер nats-streaming-server с задержкой put-get < 1 мс? Я создал кластер из 3 узлов (все они находятся на одном сервере), используя хранилище файлов. например, # NATS specific configuration port: 4222 cluster { listen: 127.0.0.1…
22 авг '18 в 22:14
1 ответ

Понимание кластеризации NATS

В разделе NATS Server Clustering говорится, что: Обратите внимание, что кластерные серверы NATS имеют ограничение пересылки в один переход. Это означает, что каждый экземпляр gnatsd будет пересылать только те сообщения, которые он получил от клиента…
17 янв '18 в 04:43
1 ответ

NATS не вызывает исключение при отключении

Я использую почти стандартный пример использования NATS на Python Asyncio. Я хочу получить сообщение, обработать его и отправить результат обратно в очередь, но когда NATS отключен (например, перезагрузка комаров), исключение не возникает. Я даже жд…
05 мар '18 в 12:37
2 ответа

Nats.io: Будут ли подписчики обрабатывать сообщения параллельно с разными субъектами, но с одинаковыми именами?

Давайте представим, что у нас есть сервер A с издателем и серверы B и C с потребителями. Также у нас есть 5 различных предметов; foo1, foo2,... foo5. Мы всегда хотим отправить сообщение только одному потребителю и получить только один ответ. Поэтому…
06 сен '18 в 21:17
1 ответ

Использование потокового сервера NATS в качестве основного хранилища данных для данных о местоположении IoT?

У меня есть брокер Mosquitto, который получает информацию о местоположении с удаленных устройств. Мне нужно хранить эти данные где-то для обработки другими микро-сервисами. В настоящее время существует процесс Node.js, который подписывается на броке…
28 ноя '17 в 11:54
0 ответов

PHP NATS Client отключается через некоторое время простоя

Я использовал эту библиотеку Repejota / phpnats для разработки клиента NATS, который может подписаться на определенный канал. Но после подключения, получения нескольких сообщений и простоя в течение 30 секунд, он отключается без перерыва. Однако мой…
12 фев '18 в 11:00
0 ответов

Node.js, ws-tcp-relay с nats: ошибка соединения

Пожалуйста, помогите решить проблему: Когда я запускаю сервер nats, слушающий порт 4222:./gnatsd --addr localhost --port 4222, затем ./ws-tcp-relay localhost:4222 -p 4223 и попробуйте подключиться через веб-сокеты, используя websocket-nats, например…
14 янв '18 в 19:45
1 ответ

Python: блокировка Asyncio NATS.io

У меня проблемы с тем, чтобы Python Asyncio NATS.io работал последовательно. У меня есть два класса: Account а также BridgeУчетная запись содержит логику приложения и передает мысли Bridge с внешним сервисом через NATS.io. Main файл: loop = asyncio.…
04 апр '17 в 15:11
0 ответов

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

У меня есть 8 серверов по всему миру и 1 API для балансировки нагрузки. Наш сервер - это небольшой VPS под управлением Ubuntu. На каждом сервере у нас есть небольшой сервис, написанный на C# для публикации информации об использовании сети в Мбит / с…
14 мар '18 в 12:51