tcpserver

0熱

2答えて

nodejsにnetモジュールを使用しています。 net.createServer(function(sock) { sock.on('data', function(data) { console.log(data); }); }); 次に、2000 tcpクライアントを使用して、サポートできるクライアント数をテストするためにサーバーにデータを送信しようとしました。最初の20

0熱

1答えて

KafkaとTCPの間のAkkaストリームゲートウェイ

私はAkkaストリームでいくつかのグラフを作成しようとしています。基本的には、カフカサーバーとTCPサーバーとの間でメッセージをルーティングする必要があります。難しい部分は、私が時々TCPサーバーに答えるために発生します。ケース1：TCP - >カフカ（OK）ケース2：カフカ - > TCP（OK）ケース3：TCP - > TCP ケース4：何 - > TCP カルシウム私はいくつかのメッセ

0熱

1答えて

TecStreamのVecを維持して、その中の1つが新しい入力を読み込むたびに、それらのスレッドに書き込むことはできますか？

私はメッセージブロードキャストをしたい：クライアントの1つがメッセージを送信すると、サーバーはそれを各ソケットに書き込みます。私の主な問題は、スレッドにVecを送る方法を知ることができないということです。 Mutexを使用することはできません。これは、他のスレッドのアクセスを読み取りのためにVecにロックするためです。 TcpStreamを複製して送信することができないため、クローン送信できません

-1熱

2答えて

QTcpSocket記述子エラー

私はTCPサーバーとソケットについていくつか学び、この状況で立ち往生しようとしていました。私はサーバーを作成してソケットをソケットに接続しています。しかし、私はこれらのソケットのための正しい記述子を得ることができません。しかし、私はnextPendingConnectionをチェックするとき、それは正しい記述子を持っています。ここでは簡単なコードです： QTcpServer server; s

0熱

1答えて

このコマンドで@記号はどのように機能していますか？

私はこれを使って昼間のサービスをセットアップしています。guideこのガイドの最後に、サービスを開始した後に、コマンドの一覧が表示されます。 [email protected] 127.0.0.1 これは現在の日時を返します。しかし、それはどのようにして行われますか？私は前にその構文を見たことがない。

0熱

1答えて

epollを使用しているtcpサーバはソケット以外のエラーを返します

私はepollを使ってcで単純なtcpエコーサーバを作成しています。コンパイル中にエラーが発生する： Socket operation on non-socket なぜnon-socketになるのですか？私はしようとしたが、私の頭の中でそれを得ることができなかった。以下が私のコードであり、ここでarticle that i am following が私のコードです：あなたは、この上であなたの時

0熱

2答えて

QTcpServer - クライアントが奇妙なデータサイズを受信しました

this postに基づいてQTcpServerを書きました。ソケットは、QByteArrayの合計バイトを最初の4バイト（qint32）に挿入します。 static inline QByteArray IntToArray(qint32 source); QByteArray IntToArray(qint32 source) { QByteArray temp; QDa

0熱

1答えて

handle_read関数に待ち行列を渡すasync tcp server

私はマルチプロセスを使って2つのタスクを作成しています。プロセス1は、コマンドを受け取り、これらのコマンドをプロセス2に渡す必要のある非同期tcpサーバーです（真のループです）。私はマルチプロセスを使用していますが、プロセスはグローバル変数を共有しないため、キューを使用する必要があります。しかし、proccess 1は単純なasynctcpサーバーです。キューオブジェクトをhandle_read