Nodejs TCP 서버와 클라이언트 채팅 프로그램에 대한 자세한 설명

이 글은 주로 Nodejs의 TCP 서버와 클라이언트 채팅 프로그램을 자세하게 소개하고 있습니다. 관심있는 친구들이 참고해 보세요.

TCP는 클라이언트와 서버 채팅을 위한 코드를 작성하는 데 사용됩니다. 서버와 클라이언트의 작업 단계에 대한 깊은 이해 여기서는 훌륭한 Node.js 책을 바탕으로 요약하겠습니다.

TCP 채팅 프로그램은 Nodejs의 net 모듈을 사용해야 합니다. net 모듈은 TCP를 캡슐화한 것이며 TCP 서버와 클라이언트를 만드는 데 사용됩니다.

서버 측

count: 연결된 클라이언트 수
users: 클라이언트 사용자의 닉네임을 저장하는 데 사용되는 객체입니다. 객체 값은 클라이언트의 소켓입니다. 클라이언트 통신으로 통신하는 서버입니다.
net.createServer: 전달된 함수는 연결event의 리스너입니다. 전달된 conn 매개변수는 소켓입니다. , net.Socket 인스턴스는 읽기 및 쓰기가 모두 가능합니다.
conn: 콜백 함수의 매개변수입니다. 각 클라이언트에 해당하는 conn은 다르며 서버가 자동으로 식별합니다.
conn.write: 클라이언트에 데이터를 보냅니다.
nickname: 클라이언트의 닉네임입니다. 닉네임이 정의되지 않은 경우 클라이언트가 닉네임을 입력하지 않았음을 의미하며, 비어 있지 않으면 저장되었음을 의미합니다. 입력 데이터는 대화이며 다른 클라이언트에게 표시되어야 합니다.
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 스트림은 초기화될 때 일시 중지된 상태입니다. . 흐름을 복원합니다.
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 중국어 웹사이트의 기타 관련 기사를 참조하세요!