이 글은 주로 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 중국어 웹사이트의 기타 관련 기사를 참조하세요!