Równoważenie obciążenia R żądania nadchodzi do RServe

Question

Mam 6 Linux box działa RServe i obsługujących ten sam zestaw R Scripts.

192.168.0.1 : 6311 
192.168.0.2 : 6311 
... 
... 
192.168.0.6 : 6311 

Łączę się z Java do tych Rserve za pomocą REngine (Rserve Java Client).

RConnection rServeConnection = new RConnection(R_SERVE_SERVER_ADDRESS, R_SERVE_SERVER_PORT); 

Jak mogę teraz załadować saldo? Najlepiej w Apache Mod Proxy?

Próbowałem już z ustawieniami równoważenia obciążenia httpd websocket i bez powodzenia.

Aktualizacja: Zawarty httpd nie ładuje salda ruchu TCP (Rserve używa TCP, podczas gdy istnieją opcje w Rserve, aby włączyć tryb websocket, mój przypadek użycia nie potrzebuje tej dodatkowej warstwy). Przeniesiono do HAProxy dla równoważenia obciążenia z konfiguracją jak w poniższym linku i można ładować żądania skryptu R przychodzące do Rserve z tolerancją błędu.

HAProxy Loadbalancing TCP traffic

Answer 1

wygląda więcej ludzi szuka rozwiązania w celu równoważenia obciążenia R skrypty. Oto działające rozwiązanie do loadbalance R dzięki mechanizmowi równoważenia obciążenia Rserve i HAproxy TCP.

Uderza, jeśli to pomaga.

https://stackoverflow.com/a/39052040/1057093

Answer 2

Jeżeli nie zostało to zrobione, a skoro już pracują w Javie, zacząć od podłączenia do serwerów RServe z Java i uruchomić prosty „Hello World” skrypt na nich, jak podano W przypadku, gdy instancje RServe działają poprawnie, musisz albo wyrównać balans z Javy, albo utworzyć jeden program Java na serwer i pozwolić serwerowi Apache na wyrównywanie obciążenia między nimi. Powrót na górę W obu przypadkach twoje programy Java będą musiały obsłużyć http, ponieważ nadal potrzebujesz łącza między html i RServe.

Answer 3

Nie jestem pewien, czy można to osiągnąć dzięki Apache mod_proxy. Myślę, że będzie działać tylko z protokołem HTTP. Być może możesz wypróbować konfigurację proof of concept z nginx. Obsługuje równoważenie obciążenia zwykłych połączeń TCP i UDP. Pozwala także na zdefiniowanie sposobu równoważenia obciążenia (np. Round-robin itp.).

Konfiguracja byłoby:

stream { 
    upstream myapp1 { 
     server 192.168.0.1:6311; 
     server 192.168.0.2:6311; 
     ... 
     server 192.168.0.6:6311; 
    } 

    server { 
     listen 80; 
     proxy_connect_timeout 1s; 
     proxy_timeout 3s; 
     proxy_pass backend; 
    } 
} 

można znaleźć więcej informacji w dokumentacji nginx: https://www.nginx.com/resources/admin-guide/tcp-load-balancing/ i tutaj: https://nginx.org/en/docs/stream/ngx_stream_core_module.html