RabbitMQ to broker komunikatów typu open source, który pierwotnie implementował protokół AMQP z dodatkowymi protokołami obsługi komunikatów obsługiwanymi za pośrednictwem architektury wtyczek. Tego znacznika należy używać w przypadku pytań dotyczących produktu brokera komunikatów serwera RabbitMQ lub pytań dotyczących kodu źródłowego i implementacji produktu RabbitMQ. Odpowiedni może być również specjalny znacznik protokołu, taki jak amqp lub mqtt, a także używany system operacyjny i język programowania.
W obecnej formie to pytanie nie pasuje do naszego formatu pytań i odpowiedzi. Oczekujemy, że odpowiedzi poparte będą faktami, referencjami lub wiedzą fachową, ale to pytanie prawdopodobnie będzie wymagało debaty, argumentów, ankiet lub rozszerzonej dyskusji. Jeśli uważasz, że to...
Poproszono mnie o ocenę RabbitMQ zamiast Kafki, ale trudno mi było znaleźć powód, dla którego robi coś lepszego niż Kafka. Czy ktoś wie, czy naprawdę jest lepszy pod względem przepustowości, trwałości, opóźnień lub łatwości
Jestem nowym brokerem wiadomości, takim jak RabbitMQ, którego możemy używać do tworzenia zadań / kolejek wiadomości dla systemu planowania, takiego jak Celery . Oto pytanie: Mogę utworzyć tabelę w PostgreSQL, która może być dołączona do nowych zadań i wykorzystana przez program konsumencki, taki...
Zainstalowałem najnowszy serwer RabbitMQ (rabbitmq-server-3.3.0-1.noarch.rpm) na świeżej maszynie Wirtualnej Centos 5.10 zgodnie z instrukcjami na oficjalnej stronie. Robiłem to wiele razy wcześniej podczas programowania i nigdy nie miałem żadnych problemów. Jednak tym razem nie mogę zalogować się...
Jak mogę usunąć wszystkie oczekujące zadania, nie znając ich task_iddla każdego
Zainstalowałem rabbitmqadmini mogłem wyświetlić listę wszystkich wymian i kolejek. Jak mogę użyć rabbitmqadminlub rabbitmqctlusunąć wszystkie
Klient RabbitMQ Java ma następujące pojęcia: Connection - połączenie z instancją serwera RabbitMQ Channel - ??? Pula wątków konsumenta - pula wątków, które zużywają komunikaty z kolejek serwera RabbitMQ Kolejka - struktura przechowująca wiadomości w kolejności FIFO Próbuję zrozumieć związek, a...
Jak mogę sprawdzić, która wersja Rabbitmq działa na serwerze? Czy istnieje polecenie sprawdzające, czy Rabbitmq
Właśnie zaczynam ogólnie używać RabbitMQ i AMQP. Mam kolejkę wiadomości Mam wielu konsumentów, którym chciałbym robić różne rzeczy z tym samym przesłaniem . Wydaje się, że większość dokumentacji RabbitMQ koncentruje się na zasadzie działania okrężnego, tj. Gdy pojedyncza wiadomość jest...
Jak usunąć wszystkie wiadomości z jednej kolejki za pomocą CLI? Mam nazwę kolejki i chcę ją
Próbuję zrozumieć, co JMS i jak jest połączony z terminologią AMQP. Wiem, że JMS to API, a AMQP to protokół. Oto moje założenia (i pytania) RabbitMQ używa protokołu AMQP (raczej implementuje protokół AMQP) Klienci Java muszą używać bibliotek klienta protokołu AMQP, aby łączyć się / używać...
Jakie porty używa RabbitMQ Server lub musi być otwarte na zaporze dla klastra węzłów? Mój /usr/lib/rabbitmq/bin/rabbitmq-envjest ustawiony poniżej, który zakładam, że jest potrzebny (35197). SERVER_ERL_ARGS="+K true +A30 +P 1048576 \ -kernel inet_default_connect_options [{nodelay,true}] \...
Czy można wyświetlić zawartość wiadomości RabbitMQ bezpośrednio z wiersza poleceń? sudo rabbitmqctl list_queues wymienia kolejki. Czy jest jakieś polecenie sudo rabbitmqctl list_queue_messages
Jakie wiadomości mogą być przechowywane w kolejkach RabbitMQ? Tylko struny? Czy mogę wybrać typ, który chcę przechowywać: int, binary, string itp.? Jaki jest maksymalny rozmiar jednej wiadomości? Ile kolejek lub giełd można utworzyć? A może zależy to od mocy serwera?...
Jestem poniżej wyjątku org.springframework.amqp.AmqpAuthenticationException: com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - odmówiono logowania przy użyciu mechanizmu uwierzytelniania PLAIN. Aby uzyskać szczegółowe informacje, zobacz plik dziennika
Mam kilka kolejek uruchomionych z RabbitMQ. Kilka z nich jest teraz bezużytecznych, jak mogę je usunąć? Niestety nie ustawiłem tej auto_deleteopcji. Jeśli ustawię to teraz, czy zostanie usunięte? Czy jest sposób, aby teraz usunąć te kolejki?
Definiujemy architekturę do zbierania informacji z logów przez spedytorów Logstash, które są instalowane na różnych maszynach i indeksują dane centralnie na jednym serwerze Flexiblesearch i wykorzystują Kibana jako warstwę graficzną. Potrzebujemy niezawodnego systemu przesyłania wiadomości...
Muszę utworzyć kolejkę do przetwarzania. Sama kolejka jest stosunkowo niewielka. Może być około 1000 zapisów na godzinę. Wykonanie każdego zadania może zająć około minuty i jest przetwarzane niemal natychmiast po dodaniu elementu do kolejki. Czy jest jakiś powód, dla którego mógłbym chcieć...
Korzystając z rabbitmq, możemy zainstalować wtyczkę zarządzającą. Następnie uzyskujemy dostęp przez przeglądarkę za http://localhost:55672/pomocą gościa: gość. Problem w tym, że nie mogę się już zalogować, ponieważ zmieniłem hasło i wpisałem puste dla roli. Czy istnieje sposób na zresetowanie...