利用Node.js實現即時通訊功能的Web項目-js教程-PHP中文網

利用Node.js實現即時通訊功能的Web項目

隨著網路的快速發展，即時通訊功能變得越來越普遍。無論是社群網路、電子商務、線上遊戲等，都需要實現即時通訊功能，以提高使用者體驗和效率。 Node.js作為一個高效且適用於並發請求的JavaScript運行環境，為快速建立即時通訊功能的網路應用程式提供了很好的支援。

本文將詳細介紹如何利用Node.js實作一個基於Web的即時通訊功能。本專案基於WebSocket協議，不使用傳統的輪詢或長輪詢技術。 WebSocket技術的優點是可以實現服務端和客戶端之間的即時雙向通訊，而且對於跨域請求也有良好的支援。

技術選型

我們將使用以下這些技巧來開發這個即時通訊功能：

Node.js：我們將使用Node.js作為伺服器端的運作環境。
Express：我們將使用Express框架來開發網路應用程式。
Socket.IO：Socket.IO是一個基於WebSocket和輪詢的跨平台即時通訊引擎，它相容於不同的瀏覽器和行動裝置。
MongoDB：我們將使用MongoDB作為資料儲存。
Bootstrap：我們將使用Bootstrap框架來建立使用者介面。

建立專案框架

先建立一個專案資料夾，進入該目錄，然後執行下面這些指令：

npm init
npm install express socket.io mongodb --save

登入後複製

上面這些指令將建立一個新的Node.js項目，然後安裝需要的依賴函式庫。

第一步是在專案根目錄下建立一個新的JavaScript檔案。在本案例中，我們將該檔案命名為server.js。然後將下面的程式碼複製到server.js檔案中。

const express = require('express');
const app = express();
const http = require('http').Server(app);

// TODO：编写代码来启动Socket.IO服务

app.use(express.static('public'));

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

登入後複製

上面這段程式碼引入了Express框架，創建了一個HTTP伺服器對象，並監聽3000連接埠。這裡牽涉到Socket.IO的初始化和啟動，後面將會講到。同時，express.static()被用於程式靜態資料夾的存取設定。

設定MongoDB

執行下面的指令來安裝MongoDB：

npm install mongodb --save

登入後複製

在專案根目錄下建立一個新的名為mongo.js的JS文件，然後加入下面的程式碼來設定和執行MongoDB。

const MongoClient = require('mongodb').MongoClient;

// Connection URL
const url = 'mongodb://localhost:27017';
// Database Name
const dbName = 'chatDB';
// Use connect method to connect to the server
MongoClient.connect(url, function (err, client) {
  console.log('Connected successfully to mongodb server');

  const db = client.db(dbName);
  client.close();
});

登入後複製

在該檔案中，我們使用MongoDB官方提供的MongoClient物件連接到MongoDB伺服器。 MongoClient使用URL連接到mongod實例，並且它將dbName作為參數執行操作。執行mongo.js後，如果您看到類似「Successfully connected to MongoDB server」這樣的訊息，則表示您已經成功連線到MongoDB。

啟動Socket.IO服務

為了啟動Socket.IO服務，我們會在剛才的server.js檔案中加入以下程式碼：

const express = require('express');
const app = express();
const http = require('http').Server(app);

const io = require('socket.io')(http);
io.on('connection', function (socket) {
  console.log('a user connected');
  socket.on('disconnect', function () {
    console.log('user disconnected');
  });
});

app.use(express.static('public'));

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

登入後複製

上面程式碼從socket.io模組匯入並建立了一個實例，然後設定了連線事件。連線事件在客戶端連線到Socket.IO伺服器時觸發。我們已經在連接事件中添加了一些日誌輸出，以便我們在伺服器控制台上能夠知道有多少用戶連接到了我們的Socket.IO伺服器。

建立客戶端

現在我們將開始建立客戶端。在public資料夾中，建立一個名為index.html的文件，然後加入下面的程式碼：

<!DOCTYPE html>
<html>
  <head>
    <title>Node.js Chat App</title>
  </head>
  <body>
    <h1>Welcome to the Chat Room!</h1>
    <div id="messages"></div>
    <form id="chat-form" action="#">
      <input id="message" type="text" placeholder="Type message" />
      <button type="submit">Send</button>
    </form>
    <script src="/socket.io/socket.io.js"></script>
    <script src="/client.js"></script>
  </body>
</html>

登入後複製

在上面的程式碼中，我們建立了一個簡單的user interface（使用者介面）來傳送和接收即時訊息。使用者介面主要由三個部分組成：