Описание тега rocketmq
RocketMQ is a low latency, reliable, scalable, easy to use message oriented middleware born from alibaba massive messaging business.
1
ответ
Очередь сообщений для передачи файлов
Мой вопрос довольно прост. Я ищу решение MQ, способное к надежной передаче файлов EDI вместе с некоторыми прикрепленными к нему метаданными. Я недавно попробовал RocketMQ, и я столкнулся с жестко заданными ограничениями размера сообщений. Мне понрав…
08 фев '18 в 07:57
1
ответ
MessageSelector не может быть разрешен
Я учусь делать rocketMQ "Пример фильтра", но в затмении я не нахожу MessageSelector. Кто может мне помочь? Документация для примера rocketMQ Filter.
28 май '18 в 01:46
2
ответа
Брокер apache rockerMQ не запускается
Я пытаюсь пометить брокера RockerMQ, но я получил сообщение об ошибке: Недостаточно памяти для продолжения среды выполнения Java. При выделении собственной памяти (mmap) не удалось сопоставить 8589934592 байта для фиксации зарезервированной памяти. …
10 сен '17 в 02:32
1
ответ
Смещение CONSUME_FROM_LAST неэффективно
Я изменил свою группу потребления и начал потреблять, она потребляется из последнего смещения по умолчанию, это правильно. Но когда я перезапускаю этого потребителя, он использует сообщение истории, почему он не использует сообщение истории при пер…
01 июн '17 в 13:38
1
ответ
Как настроить канал сообщений между двумя брокерами в RocketMQ
Мы использовали ActiveMQ для настройки сетевого коннектора для реализации канала сообщений между двумя брокерами, теперь мы хотим использовать RocketMQ. Но я читал много статей, и в RocketMQ, похоже, нет понятия о "канале", как WebSphere MQ или "сет…
13 мар '17 в 11:21
1
ответ
Как поменять порт ракеты
Я знаю, что порт сервера имен rocketmq - 9876 (по умолчанию), здесь я могу изменить порт на 9877 (пример) следующим образом echo "listenPort = 9877"> port.properties nohup sh mqnamesrv -c port.properties & тогда netstat -tunlp |grep 9877 # » netstat…
18 май '18 в 06:47
0
ответов
Очередь может быть использована более чем одним потребительским потоком в RocketMQ?
Я изучаю rocketmq сейчас, тема создаст 4 очереди по умолчанию. Если у потребителя 5 потоков, я хочу, чтобы одна очередь могла использоваться 2 потоками одновременно? Если это так, как rocketmq может избежать использования сообщения более одного раза?
10 дек '18 в 12:26
0
ответов
Почему ProducerManager.getGroupChannelTable() просто не возвращает groupChannelTable в rocketmq?
Ниже приведена реализация getGroupChannelTable(), что мне интересно, почему не просто возвращает groupChannelTable: https://github.com/apache/rocketmq/blob/master/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java private fi…
10 дек '18 в 02:33
0
ответов
Демонстрационный пример RocketMQ в.NET SDK, вызывающий исключение System.TypeInitializationException
Я запускаю демонстрационный пример, приведенный для.NET SDK RocketMQ. https://help.aliyun.com/document_detail/29561.html?spm=5176.doc29561.3.3.nIAzgT Но это бросает следующее исключение. An unhandled exception of type 'System.TypeInitializationExcep…
20 июл '17 в 14:14
2
ответа
Поддерживает ли RocketMQ автоматический переключатель "ведущий-ведомый"?
Поддерживает ли RocketMQ автоматический переключатель "ведущий-ведомый"? Я попробовал это в v3.5.8, но это не работает. Итак, я просто хочу спросить кого-то, кто может дать точный ответ
14 фев '17 в 02:07
1
ответ
Как я могу подключить брокер RocketMQ к консоли RocketMQ, чтобы получить подробную информацию?
Я новичок в Apache RocketMQ. Я обнаружил, что мы можем использовать консоль RocketMQ для получения подробной информации о транзакции сообщения RocketMQ. посмотреть здесь Как мне связать (синхронизировать) эту консоль с моим локально работающим броке…
09 мар '18 в 04:23
1
ответ
Ошибка запуска сервера имен RocketMQ - не удалось найти или загрузить основной класс
Я пытался установить RocketMQ с нуля, следуя официальному руководству, я использовал jdk 1.8.0_121 и maven 3.5.0. Однако после шага mvn -Prelease-all -DskipTests clean install -U, не было никакого каталога distribution генерируется, поэтому cd distr…
30 апр '17 в 17:37
1
ответ
Как установить имя пользователя и пароль при использовании кластера в rocketmq?
Как установить имя пользователя и пароль при использовании кластера? Поддерживает ли rocketmq имя пользователя и пароль?
22 авг '18 в 10:04
1
ответ
Фатальная ошибка rocketmq-cpp LNK1112: тип компьютера модуля 'x64' конфликтует с типом машины назначения 'X86'
Я генерирую rocketmq dll из проекта github rocketmq-cpp с открытым исходным кодом. Я использовал фоллинг Prequisite boost 1.56.0,-> имею сборку с использованием этой архитектуры jam.exe msvc =x86 address-model=64 link=static runtime-link=static этап…
07 авг '18 в 11:15
1
ответ
Как узнать, какая очередь выделена для какого потребителя-RocketMQ?
Потребительские очереди размещаются на стороне клиента, брокер ничего не знает об этом. Так как же мы можем отслеживать, какая очередь выделена какому клиентскому клиенту?
08 фев '17 в 10:06
0
ответов
Параллельная отправка сообщения брокеру RocketMQ, вызывающему исключение
Мой производитель Rocket MQ отправляет 500 сообщений параллельно 500 темам. Но время отправки сообщения для некоторых тем вызывает исключение: "Нет информации о маршруте для этой темы". Но тема уже создана. Я проверил это в файле themes.json, а такж…
27 мар '18 в 05:22
1
ответ
Как напрямую связать rocketmq и rocketmq?
У меня есть две сети (такие как NETWORK -A а также NETWORK -B). Теперь я развернул rocketmq-a в NETWORK-A и развернул ракету MQ-B в NETWORK-B, как напрямую связать rocketmq-a и rocketmq-b?
17 апр '17 в 08:12
0
ответов
rocketmq-console занимает минуты времени, чтобы показать созданные темы из клиента rocketMQ
Я установил rocketMQ-4.1 на сервере Ubuntu ( 18 ГБ ОЗУ и 6 Core), а также rocketMQ-консоль для панели инструментов. https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console Затем я создал клиент dotNet для создания тем для 100 500 0…
04 янв '18 в 08:32
0
ответов
rocketMQ [TIMEOUT_CLEAN_QUEUE] посредник занят, некоторое время запускает управление потоком
Когда я отправляю сообщение брокеру, иногда возникает это исключение. MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE] посредник занят, некоторое время запускает управление потоком Как я могу это исправить?
07 июн '18 в 07:30
1
ответ
RocketMQ: как очереди темы сопоставляются с мастер-брокерами?
Как я знаю, в RocketMq "очередь" похожа на "раздел" в Кафке. Одна тема имеет несколько очередей, также есть несколько брокеров (главный и подчиненный). Но как очереди отображаются на мастеров? Например, если у меня есть тема с 3 очередями и 3 мастер…
05 янв '17 в 05:30