Nodejs TCPサーバーとクライアントチャットプログラムの詳細な説明

この記事では主に Nodejs の TCP サーバーとクライアントのチャット プログラムを詳しく紹介します。興味のある方は参考にしてください。

TCP はコンピューター間の通信に使用されます。サーバーとクライアントの動作手順を深く理解しました。ここでは、素晴らしい Node.js 本に基づいてそれを要約します。

TCP チャット プログラムは Nodejs の net モジュールを使用する必要があります。 net モジュールは TCP のカプセル化であり、TCP サーバーとクライアントの作成に使用されます。

サーバー側

count: 接続されているクライアントの数;
users: クライアントユーザーのニックネームを保存するために使用されるオブジェクトの値はすべてクライアントのソケットです。サーバーがクライアント通信と通信するためのインターフェイス。
net.createServer: TCP サーバーを作成するために使用されます。渡される関数は connectionevent のリスナーです。クライアントがサーバーに接続した後に接続イベントがトリガーされます。つまり、conn パラメーターはソケットです。 , net.Socket インスタンスは読み取りと書き込みの両方が可能です。
conn: コールバック関数のパラメータです。各クライアントに対応するconnは異なり、サーバーが自動的に識別します。
conn.write: データをクライアントに送信します。
ニックネーム: ニックネームが未定義の場合は、クライアントがニックネームを入力していないことを意味し、空でない場合は、ニックネームが保存されていることを意味します。入力データは会話であり、他のクライアントに表示する必要があります。
conn.on('data',function (data){...}): クライアントからデータを受信するために使用されます。

  /*server.js*/
  var net=require('net');
  var count=0;
  var users={};
  
  var server=net.createServer(function (conn) {
    conn.setEncoding('utf8');
    conn.write(count+' people are connected'
      +'\nplease write your nickname:');
    count++;
    var nickname;
    conn.on('data',function (data) {
      data=data.replace(/\r\n/,'');
      if(!nickname){
        if(users[data]){
          conn.write('\n nickname already used,try again:');
          return;
        }else {
          nickname=data;
          users[nickname]=conn;//每个客户端对应的conn是不一样的
          for(var i in users){
            users[i].write(nickname+' join the romm\n');
          }
        }
      }else {
        conn.write('发送者nickname: '+nickname+'\n');
        for(var i in users){
          if(i!=nickname){
            users[i].write(nickname+': '+data+'\n');
          }
        }
      }
    });
    conn.on('close',function () {//这里防止连接出错，使用close而非end
      console.log(nickname+' client disconnected\n');
      count--;
      delete users[nickname];
    });
    conn.on('error',function (err) {
      console.log('Error in connection:'+ err+'\n');
    });
  }).listen(3000,function () {
    console.log('server is listenning on 3000');
  });

Client

process.stdin.resume(): この読み取り可能なストリームは、初期化時に一時停止状態になります。 . 流れを元に戻します。
process.stdin.on('data', function(data){…}): キーボード入力を取得し、client.write() を使用してサーバーに送信するために使用されます。
stop: クライアントが正常に切断されたかどうかを判断するために使用されます。
net.createConnection: サーバー側で接続を作成し、リスナーを接続イベントに自動的に追加するために使用されます。リスナーはパラメーターを受け取りません。返されるのは「net.Socket」です。

  /*client.js*/
  var net=require('net');
  var stop = false;
  process.stdin.resume(); 
  
  process.stdin.on('data', function(data){
    if(data.toString().trim().toLowerCase()==='stop'){
      stop=true;
      console.log('connection stop\n');
      client.end();
    }else{
      client.write(data);
    }
  });
  
  var client=net.createConnection(3000,function () {
    console.log('connected to server!\n');
  });
  client.on('data', function(data) {
    console.log(data.toString());//打印服务器发送的数据
  });
  client.on('error', function(err) {
    console.log('Error in connection:'+ err+'\n');
  });
  client.on('close', function() {
    if(! stop) {
      console.log('connection got closed');
    }
  });

TCPチャットプログラム

これは、gitで実行し、3つのクライアントを接続したテスト結果です:

以上がNodejs TCPサーバーとクライアントチャットプログラムの詳細な説明の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。