Mam proces, który nasłuchuje IP:port
- w rzeczywistości jest to streaming strumieniowy, który łączy się z gniazdem. Problem polega na tym, że chcę w jakiś sposób stworzyć serwer, który łączy się z iskrą na jednym porcie, a dane są przesyłane strumieniowo do tego serwera z innego portu.
Na przykład, przykład przesyłania strumieniowego Spark wykorzystuje narzędzie netcat (na przykład nc -lk 5005
). Mam jednak inną usługę, która nasłuchuje wiadomości przychodzących, a następnie wypluwa wiadomość. Potrzebuję więc jakiegoś serwera, który może słuchać wiadomości z usługi A i przekazywać je do iskry.
Moja usługa A polega na gniazdach. A mój iskrowy konsument polega na gniazdach.
Oto, co do tej pory zrobiłem, to przekierowanie z portu na port, ale wydaje się, że to nie działa:
nc -X 4 -x 127.0.0.1:5005 localhost 5006
Z pomysłem, że usługa A:5005
-> gniazdo -> 5006
-> Spark
Nie mogę znaleźć właściwego sposobu, aby to zadziałało.
Niektóre odpowiedzi sugerują, co następuje:
socat tcp-l:5005,fork,reuseaddr tcp:127.0.0.1:5006
Mój odbiornik gniazda zapłonowego nie łączy się lub nie może się połączyć. Dostaję błąd:Error connecting to 127.0.0.1:5006 - java.net.ConnectException: Connection refused