Описание тега nats-streaming-server

Описание тега Вопросы с тегом
NATS Streaming Server - это система постоянного обмена сообщениями, работающая поверх системы обмена сообщениями NATS, написанной на языке Go. NATS - это система обмена сообщениями с открытым исходным кодом (иногда называемая промежуточным программным обеспечением, ориентированным на сообщения). Сервер NATS написан на языке программирования Go. Apcera разрабатывает и обеспечивает поддержку NATS.
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 ответов

Протобуф соединение с NATS и CNATS

У меня есть проект, который должен соединить Protobuf с CNATS и NATS. Тем не менее, я не могу найти какую-либо документацию (за исключением golang., Но не показал никакой конфигурации, которая будет изменена) или пример использования / этих 3 програ…
16 янв '19 в 06:36
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
0 ответов

Обнаружение данных go race при настройке обработчиков для потоковой передачи nats

Для потоковой подписки nats обработчик должен выглядеть следующим образом handler := func(ms *stan.Msg){} Я создал следующую функцию, пытаясь взять их обработчик и затем вызвать свою собственную, чтобы обработать возвращенное сообщение. func (t *T) …
29 дек '17 в 12:13
0 ответов

Можно ли увидеть, получал ли подписчик "последнее" сообщение при использовании nats-streaming?

У меня есть клиентское приложение публикации (Java), которое в случае сбоя клиента я хотел бы добавить к существующим опубликованным сообщениям. Например, он должен видеть, что отправил 1000 сообщений, и продолжить с номера 1001. В настоящее время я…
20 ноя '17 в 14:58
0 ответов

java-nats-streaming: публикация сообщений после переподключения сервера

У меня есть потоковый кластер NATS с 3 узлами. Кажется, что сообщения NATS, публикуемые моим java-приложением во время простоя сервера, теряются (то есть не публикуются повторно, когда мои серверы снова работают и работают). Более подробное описание…
07 ноя '18 в 13:39
1 ответ

Натс какой образец использовать

Я задал вопрос в: Зависимость архитектуры микросервиса, какой шаблон использовать при использовании кластерной архитектуры микросервиса. Я получил ответ, что точка-точка должна работать, но при чтении: https://nats.io/documentation/concepts/nats-req…
11 июн '17 в 18:46
1 ответ

Что если полезная нагрузка сообщения NATS содержит \n\r?

Я пытаюсь написать клиентскую библиотеку для NATS.io. Согласно протоколу здесь, \n\r используется для разграничения команд, полезной нагрузки и т. д. INFO {"server_id":"1ec445b504f4edfb4cf7927c707dd717","version":"0.6.6","go":"go1.4.2","host":"0.0.0…
17 авг '18 в 08:16
1 ответ

Как ограничить размер raft.log на потоковом сервере nats?

Я настроил потоковый сервер nats в режиме кластера (в соответствии с инструкциями, приведенными здесь) и заметил, что raft.log очень быстро растет, когда я тестирую его с нагрузкой около 200 мсг / с, где размер сообщения составляет ~1 МБ. Я использу…
25 фев '19 в 10:37
1 ответ

Существует ли инструмент веб-интерфейса NATS для мониторинга сообщений?

Есть ли какой-либо инструмент для мониторинга фактических сообщений, опубликованных через очередь NATS? Для презентации мне нужно отобразить сообщения, отображаемые с помощью микросервисной архитектуры, и было бы неплохо сделать это с помощью сущест…
04 дек '18 в 16:48
0 ответов

nats-streaming на aws ecs с командами

В моей локальной системе я запускаю следующую команду: docker run --name nats-streaming --restart, если-остановлено -p 4222:4222 -p 8222:8222 -v ~/nats/bo:/datastore -d nats-streaming --cluster_id bo --max_channels 0 --max_subs 0 --max_msgs 0 --max_…
09 мар '18 в 17:24
1 ответ

Redis Streams против Kafka Streams/NATS

Команда Redis представляет новый тип данных Streams для Redis 5.0. Поскольку Streams с первого взгляда выглядит как темы Kafka, странно находить реальные примеры его использования. В представлении потоков у нас есть сравнение с потоками Кафки: Обраб…
25 окт '18 в 17:48
0 ответов

Как подписаться на файл большого размера? NATS Streaming подписка проблема

Я новый NATS. Я просто попытался отправить и получить текстовый файл, используя примеры NATS-потокового сервера. Когда я отправляю текстовый файл (~10 МБ), я могу получить файл. Но когда я отправляю текстовый файл (~80 МБ), подписка не работает. Я н…
02 дек '18 в 02:18
1 ответ

NATS публикует / подписывает подтверждения

Я делал несколько POC с NATS и потоковыми серверами NATS в течение последних нескольких дней. Я начал с сервера потоковой передачи NATS, написав Java-клиент для него и опубликовав / подписав сообщения на / от сервера потоковой передачи NATS, кластер…
05 янв '18 в 11:11
0 ответов

Spring Boot настраиваемая внешняя конфигурация без http

Мы использовали spring-cloud-consul-config, но теперь требовалось загрузить конфигурацию из nats-streaming 'last-value-queue' Найден какой-то хакерский способ сделать это, ниже пример @SpringBootApplication public class CfgApplication { public stati…
29 окт '18 в 10:13
1 ответ

Ограничение скорости абонента сервера потоковой передачи NATS и ровно один раз доставки

Я немного играю с трансляцией NATS, и у меня проблема с ограничением абонентской скорости. Когда я устанавливаю максимальное значение в полете на 1, а тайм-аут на 1 секунду, и у меня есть потребитель, который по сути является Thread.sleep(1000), тог…
28 июл '17 в 05:40
1 ответ

NATS Request Ответить - Как это работает?

Я новый NATS. Не уверен, как работает ответ на запрос NATS. Насколько я понимаю, этот шаблон можно использовать для двунаправленной связи, но возникает вопрос, работает ли он между одним и тем же идентификатором сообщения / потоком? Если нет, не мож…
28 ноя '17 в 11:16
1 ответ

NATS постоянное сообщение Java Client

У кого-нибудь есть опыт использования потокового сервера NATS в сочетании с клиентом Java? В частности, я не могу понять, как получать сообщения с помощью Java-клиента, которые отправляются, когда подписчик находится в автономном режиме. С помощью к…
09 сен '16 в 22:47
0 ответов

Проблемы потоковой передачи Nats с C# stan.client

Я использую потоковый сервер nats и stan.client в качестве клиентской библиотеки. Мой подписчик может выполнять долгую работу. Иногда они превышают время ожидания подтверждения по умолчанию (30 секунд). Поэтому я пытаюсь вручную подтвердить свое соо…
28 фев '19 в 11:09