netty

    -4

    1答えて

    Java NIOはかなり複雑です。 Java NIOの目的を達成するJava IOからsthを作成できますか? 私は、Java指向の2つの主な機能であるバッファ指向のノンブロッキングIOを作るのは簡単だと思います。私たちはすぐにそれらを処理する代わりにストリームからバッファにデータを読み込むことができました。ノンブロッキングIOについては、Java IOのsetSoTimeoutメソッドを使用して

    1

    1答えて

    マイチャンネルのパイプラインにはいくつかのデコーダが含まれています。これらのデコーダはすべてTextWebSocketFrameメッセージで動作します。今私の問題は、私はメッセージのいくつかのコンテンツに適切なデコーダベースを選択する必要があるということです。 本質的に、メッセージの特定のフィールドを解析し、メッセージの処理を続行するか、メッセージを次のエンコーダ/ハンドラに渡す必要があるかどうか

    0

    1答えて

    サーバーアプリケーションがリッスンしている場合にうまく動作するNettyクライアントがあります。しかし、サーバーアプリケーションが実行されておらず、ポートでリッスンしていない場合でも、クライアントはサーバーが存在すると見なして実行します。 私は、サーバーがリッスンしていないときに、データを送信することさえしないで、代わりにユーザーに管理者などに連絡するように指示することもしません。これも可能ですか

    0

    1答えて

    私はnettyを使いすぎていません。ChannelPipelineのドキュメントについて質問があります。ここでは、それは正確に約あるものです: static final EventExecutorGroup group = new DefaultEventExecutorGroup(16); ... ChannelPipeline pipeline = ch.pipeline(); pi

    0

    1答えて

    現在、私はPacketSystemを開発しています。それを通して、私は、認証システムを作り、このようなクライアントからサーバーへの文字列として送信されていますキー作成: protected void channelRead0(ChannelHandlerContext ctx, Packet p) throws Exception { if(p instanceof PacketInSe

    0

    1答えて

    私はnettyフレームワークバージョン4.1.6でwebsocketサーバを開発しています。私はnetty example site からのサンプルコードを使用しています これは私のサーバーのソースコードです: public class WebSocketServer { static final int PORT = 4466; public static void mai

    0

    1答えて

    私は非常に重い計算を実行する予定のhttp-serverを書いています。私はビジネスロジックやIOのブロックに関連するエンコーダ/デコーダパイプラインをいくつか持っています。 public void initChannel(Channel ch) { ch.pipeline() //All actions in these handlers are very heavy an

    2

    1答えて

    私は以下の方法でnettyのctxにバイト配列を書き込もうとしていますが、私はできません。私はChannelInboundHandlerAdapterを使用しています。 2017年11月28日午前7時52分16秒PM io.netty.handler.logging.LoggingHandlerが INFO書く::[ID:0x391dced5、Lを:それは以下を示すログで ByteBuf mbuf

    0

    1答えて

    これにはいくつか前の質問がありますが、回答では問題解決のための十分な情報が得られないことがよくあります。 私はApache Sparkを使用して、Elasticsearchにデータを取り込みます。私たちは、X-Packセキュリティとそれに対応するトランスポートクライアントを使用しています。私は輸送クライアントを使用して特別な場合にインデックスを作成/削除し、次にSparkを使用して摂取を行っていま