問題タブ [reactor-netty]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - WS の代わりに WSS を使用するように Spring-Weflux WebSocket アプリケーションを構成する方法
Netty を実行する Spring-Webflux サーバーがあります。現在、クライアントは 経由で接続していますwsが、 経由で接続する必要がありますwss。
ONLY を受け入れるように設定する方法はwss?
spring - Spring WebClient を Unix ドメインソケットに接続するにはどうすればよいですか?
Spring の WebClient は、基本的に Unix ドメイン ソケットにアクセスする Netty を使用します。docker-java ライブラリでサポートされていない/var/run/docker.sock必要に応じて API を使用して操作を実行できるように、アクセスできるようにしようとしています。/services
私の現在の回避策は、Docker ソケットを内部ネットワーク内の TCP に公開する socat コンテナを作成することです。これにより、WebClient の HTTP 接続を使用できるようになります。
考えてみれば、この回避策があると、マネージャー ノードに大規模な Java アプリケーションを配置する必要がないという 1 つの利点があります。
ただし、UNIX ドメイン ドケットに接続する方法についてはまだ興味があります。
project-reactor - Reactor Netty - 遅延した Flux で送信する方法
Reactor Netty では、 経由out.send(publisher)で TCP チャネルにデータを送信する場合、任意のパブリッシャーが動作することが期待されます。ただし、単純な即時型の代わりに、Flux遅延要素を含むより複雑な即時型を使用すると、正しく機能しなくなります。たとえば、この hello world TCP エコー サーバーを使用すると、期待どおりに動作します。
ただし、次のように変更out.sendStringすると、
次に、受信したアイテムごとに、1 秒の遅延で出力が生成されることが期待されます。
ただし、サーバーが動作する方法は、間隔中に複数のアイテムを受信した場合、最初のアイテムに対してのみ出力を生成するというものです。たとえば、以下では最初の 1 秒間にaaandを入力しますが、(1 秒後) 出力としてのみ生成されます。bbAA
次に、後で追加の行を入力すると、(1 秒後に) 出力が得られますが、前の入力からのものです。
send()遅延で期待どおりに動作させる方法はありFluxますか?