Cześć Mirki!
Tworze sobie apke klient - serwer która będzie się łączyć po websocketach i napotkałem na mały problem:
Stworzyłem ChannelInterceptor w którym sprawdzam login i hasło przesłane w headerze (preSend gdy Stomp Command == CONNECT) i nie wiem kompletnie w jaki sposób odesłać informację do klienta jeśli credentiale się nie zgadzają i jest on nieautoryzowany.
Tworze sobie apke klient - serwer która będzie się łączyć po websocketach i napotkałem na mały problem:
Stworzyłem ChannelInterceptor w którym sprawdzam login i hasło przesłane w headerze (preSend gdy Stomp Command == CONNECT) i nie wiem kompletnie w jaki sposób odesłać informację do klienta jeśli credentiale się nie zgadzają i jest on nieautoryzowany.
@Component
public class CustomChannelInterceptorAdapter implements ChannelInterceptor {
Mirkoserwis A:
- pobiera JSON'a z MongoDB który ma staus NEW
- tworzy jakiegoś joba w którym mamy x stepów (w zależności od tego jak musi zostać przetransformowany JSON) i go odpala
- dla przykładu step1 wrzuca id z bazy danych do kolejki rabbitowej i wtedy ten job nie blokuje mikroserwisu tylko czeka, aż mikroserwis B zrobi swoje, a w międzyczasie bierze następny rekord z bazy,
Co do rozwiązania, to moim zdaniem opcje są dwie:
a)
dwa mikroserwisy korzystają z tej samej bazy danych żeby nie rzucać do kolejki całego payload'u tylko ID i one będą sobie same pobierać payload do transformacji z bazy.
Na schemacie nie dodałem strzałki między DB a C. On też dostanie z kolejki tylko ID, pobierze payload i wyśle. Przynajmniej tak założyłem ;)
a) nie chciałbym scalać, żeby w paragrafie 'plany na przyszłość' móc napisać, że