6
Chcę prędkość wiadomości asynchronicznych, ale nadal mam kontrolę przepływu. Jak mogę to zrobić w Erlangu?Jak utworzyć kolejkę wiadomości związanych z pamięcią w programie Erlang?
A
Odpowiedz
7
Obecnie nie ma limitu pamięci procesowej - jest on omawiany na liście mailingowej itp. Możesz przeglądać te wątki.
Po stronie odwrotnej, gdy używasz implementacji wzorców OTP, takich jak gen_server, masz dużą swobodę w pobieraniu wiadomości z kolejki procesów i mierzeniu długości kolejki.
gen_server2 używany w rabbitmq używany do optymalizacji poprzez przenoszenie wiadomości do wewnętrznej struktury danych. Po tym można odrzucić każdą nową wiadomość przychodzącą, gdy wewnętrzna kolejka jest zbyt długa. Możesz to zrobić po cichu lub powiadomić nadawcę, że wiadomość została odrzucona.
Wszystko to jest na bardzo niskim poziomie.
RabbitMQ zapewni tę funkcjonalność na poziomie AMQP.
6
Powszechnym i dość dobrym sposobem wymuszania kontroli przepływu jest wybranie dobrze wybranych wiadomości w połączenia, które ograniczają obciążenie każdego klienta, który może załadować serwer do jednego, skutecznie dostarczając siłę w niezwykle prosty sposób. Sztuką jest oczywiście wybór, które komunikaty używają wywołań synchronicznych :-)
+0
To też byłoby moje rozwiązanie. Zasadniczo zbuduj kontrolę przepływu na linii. Są również bardziej zaawansowane rozwiązania. –
+1
Nie jestem pewien, czy rozumiem. Proponujesz synchronizację połączeń za pomocą asynchronizacji, która gwarantuje, że wiadomości są umieszczane w kolejce po stronie klienta? Myślę, że to zależy od przypadku użycia. Jeśli klient jest przejściowy, nie możemy sobie pozwolić na takie rozwiązanie. – user425720
+0
Trzon problemu polega na tym, że aby mieć jakąkolwiek formę kontroli przepływu, w końcu będziesz miał jakąś formę synchronizacji. Jeśli klient dostarczający przepływ po prostu przesunie wiadomość, nie możemy jej w żaden sposób ograniczyć. Odpowiedź na to pytanie często polega na ograniczeniu liczby klientów, ale wymaga to scentralizowanej wiedzy o liczbie klientów wymagających synchronizacji. Ostatecznie sprowadza się to do miejsca, w którym dokonujemy synchronizacji. Powszechne rozwiązanie w aplikacjach telcom jest zbyt proste w interfejsie, ale trzeba wiedzieć, kiedy rzucić :-) –
Powiązane problemy
- 1. Jak utworzyć kolejkę z wieloma pracownikami?
- 2. Czy można łatwo subskrybować domyślną kolejkę błędów w programie EasyNetQ?
- 3. Jak korzystać z nagłówków wiadomości w kliencie RabbitMQ firmy Erlang?
- 4. Czy można utworzyć kolejkę do zestawu HashMap?
- 5. Laravel: Jak ustawić kolejkę wiadomości do wysłania później
- 6. Śledzenie akcji pobierania wiadomości ze skrzynki pocztowej w Erlang
- 7. utworzyć niestandardowy sekwencyjną globalnej wysyłki kolejkę
- 8. Jak utworzyć wykres logu w programie Matlab
- 9. Jak utworzyć macierz komórek z podobnych obiektów w programie Matlab?
- 10. Jakie polecenia wyjściowe konsoli są dostępne w programie Erlang?
- 11. jak robić aktorów (erlang) w java?
- 12. Jak poprawnie wykonać kolejkę priorytetową?
- 13. Jak wyświetlić wspólną kolejkę Runnera
- 14. Jak zaimplementować autoregulację dla zadań związanych z selerem
- 15. Problem z pamięcią w ARC
- 16. powrocie kolejkę z funkcji w SystemVerilog
- 17. Problemy z pamięcią sterty
- 18. Selektywne odbieranie w Erlang
- 19. Połączenie z pamięcią (R)
- 20. Jak uruchomić aplikację Erlang wewnątrz powłoki Erlang
- 21. Jak sformatować liczbę z wyściółką w Erlang
- 22. Jak zapętlić kolejkę dźwięków w AVQueuePlayer?
- 23. Jak wyczyścić kolejkę wieloprocesową w pythonie
- 24. Problem z pamięcią UIAutomation
- 25. Problemy z pamięcią JVM
- 26. Problem z pamięcią PHPExcel
- 27. Jak utworzyć losową liczbę po logormalnej dystrybucji w programie excel?
- 28. Jak utworzyć wyzwalacz przed usunięciem w programie SQL Server?
- 29. Jak mogę usunąć wiadomości z kolejki?
- 30. Jak wrócić wiele obiektów związanych z ForeignKey w Django
gen_server2 wygląda ładnie –
Czy gen_server2 implementuje okienkowanie? –
Nie jestem pewien, jaki jest obecny stan implementacji gen_server2. Może być w jakiś sposób połączony z głównym, po wprowadzeniu nieliniowego dopasowywania komunikatów w kolejkach komunikatów w OTP serwer_grupy. – user425720