如何在Ubuntu上使用Node.js进行实时通讯

在Ubuntu上使用Node.js进行实时通讯，你可以选择多种技术和框架。以下是一些流行的选择：

1. WebSocket

WebSocket是一种协议，它提供了在单个TCP连接上进行全双工通信的能力。

安装Node.js和npm

首先，确保你已经安装了Node.js和npm。如果没有安装，可以通过以下命令安装：

sudo apt update
sudo apt install nodejs npm

创建WebSocket服务器

你可以使用ws库来创建WebSocket服务器。首先，安装ws库：

npm install ws

然后，创建一个简单的WebSocket服务器：

const WebSocket = require('ws');


const wss = new WebSocket.Server({
 port: 8080 }
    );


wss.on('connection', function connection(ws) {

  ws.on('message', function incoming(message) {
    
    console.log('received: %s', message);

  }
    );
    

  ws.send('Hello! Message From Server!!');

}
    );
    

创建WebSocket客户端

你可以使用相同的ws库来创建WebSocket客户端：

const WebSocket = require('ws');
    

const ws = new WebSocket('ws://localhost:8080');


ws.on('open', function open() {
    
  ws.send('Hello! Message From Client!!');

}
    );


ws.on('message', function incoming(data) {
    
  console.log(data);

}
    );
    

2. Socket.IO

Socket.IO是一个实时通讯库，它提供了WebSocket和其他传输方式的回退机制，确保在不同浏览器和网络环境下都能正常工作。

安装Node.js和npm

确保你已经安装了Node.js和npm。

创建Socket.IO服务器

首先，安装socket.io库：

npm install socket.io

然后，创建一个简单的Socket.IO服务器：

const http = require('http');
    
const socketIo = require('socket.io');
    

const server = http.createServer();
    
const io = socketIo(server);
    

io.on('connection', (socket) =>
 {
    
  console.log('a user connected');
    

  socket.on('disconnect', () =>
 {
    
    console.log('user disconnected');

  }
    );
    

  socket.on('chat message', (msg) =>
 {
    
    io.emit('chat message', msg);

  }
    );

}
    );
    

server.listen(3000, () =>
 {
    
  console.log('listening on *:3000');

}
    );
    

创建Socket.IO客户端

你可以使用相同的socket.io-client库来创建Socket.IO客户端：

npm install socket.io-client

然后，创建一个简单的Socket.IO客户端：

const io = require('socket.io-client');
    

const socket = io('http://localhost:3000');
    

socket.on('connect', () =>
 {
    
  console.log('connected to server');
    
  socket.emit('chat message', 'Hello Server!');

}
    );
    

socket.on('chat message', (msg) =>
 {
    
  console.log('message from server:', msg);

}
    );
    

3. Express + Socket.IO

如果你已经熟悉Express框架，可以将其与Socket.IO结合使用。

安装Node.js和npm

确保你已经安装了Node.js和npm。

创建Express + Socket.IO服务器

首先，安装express和socket.io库：

npm install express socket.io

然后，创建一个简单的Express + Socket.IO服务器：

const express = require('express');
    
const http = require('http');
    
const socketIo = require('socket.io');
    

const app = express();
    
const server = http.createServer(app);
    
const io = socketIo(server);
    

app.get('/', (req, res) =>
 {
    
  res.sendFile(__dirname + '/index.html');

}
    );
    

io.on('connection', (socket) =>
 {
    
  console.log('a user connected');
    

  socket.on('disconnect', () =>
 {
    
    console.log('user disconnected');

  }
    );
    

  socket.on('chat message', (msg) =>
 {
    
    io.emit('chat message', msg);

  }
    );

}
    );
    

server.listen(3000, () =>
 {
    
  console.log('listening on *:3000');

}
    );
    

创建HTML客户端

创建一个简单的HTML文件index.html：

<
    !DOCTYPE html>
    
<
    html>
    
<
    head>
    
  <
    title>
    Socket.IO Chat<
    /title>
    
<
    /head>
    
<
    body>
    
  <
    ul id="messages">
    <
    /ul>
    
  <
    form id="form" action="">
    
    <
    input id="input" autocomplete="off" />
    <
    button>
    Send<
    /button>
    
  <
    /form>
    
  <
    script src="/socket.io/socket.io.js">
    <
    /script>
    
  <
    script>
    
    const socket = io();
    

    const form = document.getElementById('form');
    
    const input = document.getElementById('input');
    
    const messages = document.getElementById('messages');


    form.addEventListener('submit', function(e) {
    
      e.preventDefault();

      if (input.value) {
    
        socket.emit('chat message', input.value);
    
        input.value = '';

      }

    }
    );


    socket.on('chat message', function(msg) {
    
      const item = document.createElement('li');
    
      item.textContent = msg;
    
      messages.appendChild(item);
    
      window.scrollTo(0, document.body.scrollHeight);

    }
    );
    
  <
    /script>
    
<
    /body>
    
<
    /html>
    

通过以上步骤，你可以在Ubuntu上使用Node.js进行实时通讯。选择适合你需求的技术和框架，并根据需要进行扩展和优化。

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！