SOCKET.IO
CÁC CHỦ ĐỀ
BÀI MỚI NHẤT
MỚI CẬP NHẬT

Broadcasting trong Socket.io

Trong bài này chúng mình sẽ cùng nhau đi tìm hiểu về khái niệm Broadcasting trong Socket.io.

Nếu như trong các bài trước khi mình gửi dữ liệu từ server về clients bằng cách sử dụng phương thức socket.emit() thì tất cả client đã kết nối sẽ bắt được events đó, kể cả người gửi (sender). Khi gửi bằng cách này trong một vài trường hợp rất bất tiện, bởi vậy Socket.io cung cấp cho chúng ta Broadcasting để giải quyết vấn đề này.

1. Broadcasting trong Socket.io

Broadcasting có nghĩa là gửi tin nhắn đến tất cả các clients được kết nối. Socket có thể được thực hiện ở nhiều cấp độ. Socket có thể gửi tin nhắn đến tất cả các máy khách(clients) được kết nối, đến các máy khác có không gian cụ thể. Để gửi một sự kiện cho máy khách chúng ta thường sử dụng phương thức io.socket.emit(). Khi sử dụng phương thức này nó sẽ gửi đến tất cả các clients được kết nối.

Khi bạn muốn gửi cho tất cả các clients được kết nối chúng ta sử dụng:

io.on("connection", function(socket) {
   //Gửi cho tất cả client được kết nối
    io.socket.emit('new msg', {msg: '!hello guy =))'})
});

socketio broadcasting png

Khi bạn muốn gửi cho tất cả các clients được kết nối mà ngoại trừ sender chúng ta sử dụng :

io.on("connection", function(socket) {
    socket.broadcast.emit('new msg', {msg: 'msg here!'})
});

Xây dựng ví dụ

Trong phần này chúng ta sẽ đi xây dựng một website đếm người truy cập sử dụng socket.io. Khi có bất cứ kết nối nào thì trình duyệt sẽ hiển thị số kết nối và thông báo người mới join.

Như trong các ví dụ trước, chúng ta sẽ có cấu trúc thư mục quen thuộc:

broadcasting_socket
---app.js
---views/
-------index.html

Cài đặt các module cần tiết trong quá trình khởi tạo server bằng cách mở terminal và gõ dòng lệnh :

npm install --save express socket.io

Chúng ta sẽ làm việc với file app.js bên phía server :

var app = require("express")();
var http = require("http").createServer(app);
var io = require("socket.io")(http);

app.get("/", function(req, res) {
  res.sendFile(__dirname + "/views/index.html");
});
var clients = 0;
io.on("connection", function(socket) {
  clients++;
  socket.emit("new msg", { msg: `Hiện tại có ${clients} đang kết nối !!` });
  socket.emit("new noti", { msg: "Một người vừa mới tham gia ! " });
  socket.on("disconnect", function() {
    clients--;
    socket.emit("new noti", { msg: "Một người vừa mới rời đi! " });
  });
});

http.listen(3000, function() {
  console.log("listening on *:3000");
});

Bên phía clients chúng ta sẽ xử lý ở file index.html nằm trong thư mục views/

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>Socket.io -  Broadcasting</title>
</head>
<body>
    <p id="msg">

    </p>
    <div id="noti">

    </div>
    <script src="https://ajax.googleapis.com/ajax/libs/jquery/3.4.1/jquery.min.js"></script>
    <script src="/socket.io/socket.io.js"></script>
    <script>
        var socket = io()
        socket.on('new msg', function(data) {
            $('#msg').text(data.msg)
        })
        socket.on('new noti', function(data) {
            //console.log(data)
           $('#noti').append(data.msg + '<br>')
        })
    </script>
</body>
</html>

Chúng ta sẽ khởi chạy server và truy cập thử, khởi tạo 3 clients chúng ta sẽ thấy như trong hình:

socketIo broadcasting trong socketio png

Bằng cách này socket sẽ gửi một thông báo "Một người vừa mới truy cập !" cho tất cả mọi người. Bây giờ, nếu chúng ta muốn gửi thông báo đó cho tât cả mọi người, nhưng ngoại trừ người vừa mới truy cập. Chúng ta sẽ sử dụng phương thức socket.broadcast.emit()

Cùng đi sửa một chút ở file app.js để thấy sự khác biệt nhé. Thay phương thức soket.emit('new noti') thành socket.broadcast.emit('new noti'). Trong file app.js chúng ta sẽ sửa thành:

var app = require("express")();
var http = require("http").createServer(app);
var io = require("socket.io")(http);

app.get("/", function(req, res) {
  res.sendFile(__dirname + "/views/index.html");
});
var clients = 0;
io.on("connection", function(socket) {
  clients++;
  socket.emit("new msg", { msg: `Hiện tại có ${clients} đang kết nối !!` });
  socket.broadcast.emit("new noti", { msg: "Một người vừa mới tham gia ! " });
  socket.on("disconnect", function() {
    clients--;
    socket.broadcast.emit("new noti", { msg: "Một người vừa mới rời đi! " });
  });
});

http.listen(3000, function() {
  console.log("listening on *:3000");
});

Đây là kết quả sau khi sửa:

socketIo broadcasting trong socketio 2 png

Lúc này clients chỉ có thể nhận được thông báo có người truy cập khi đã kết nối, những người mới truy cập sẽ hoàn toàn không nhận được thông báo.

Trong bài viết này chúng ta đã cùng nhau đi tìm hiểu về khái niệm Broadcasting trong Socket.io, mong qua những phần mà mình đề cập cũng như các ví dụ sẽ giúp cho bạn hiểu rõ hơn về phần này. Cảm ơn bạn đã quan tâm.

Cùng chuyên mục:

Crawl dữ liệu website bằng NodeJS cơ bản

Crawl dữ liệu website bằng NodeJS cơ bản

CORS là gì ? Xử lý CORS trong NodeJS

CORS là gì ? Xử lý CORS trong NodeJS

Chắc hẳn trong quá trình xử lý các request tới server thì một vài trường…

Xử lý form trong Express

Xử lý form trong Express

Xây dựng URL trong Express

Xây dựng URL trong Express

Trong bài viết này chúng ta sẽ cùng nhau đi tìm hiểu về cách xây…

Populate trong Mongoose

Populate trong Mongoose

Error Handling & Debugging trong Socket.io

Error Handling & Debugging trong Socket.io

Namespaces & Rooms trong Socket.io

Namespaces & Rooms trong Socket.io

Middleware trong Mongoose

Middleware trong Mongoose

Create / Read / Update / Delete trong Mongoose

Create / Read / Update / Delete trong Mongoose

Validation trong Mongoose

Validation trong Mongoose

Subdocuments trong Mongooose

Subdocuments trong Mongooose

Documents trong Mongoose

Documents trong Mongoose

Trong bài viết này chúng ta sẽ tìm hiểu về documents trong Mongoose

Models trong Mongoose

Models trong Mongoose

SchemaTypes trong Mongoose

SchemaTypes trong Mongoose

Schemas trong Mongoose

Schemas trong Mongoose

Mongoose trong NodeJS

Mongoose trong NodeJS

Làm việc với Table MySQL sử dụng Nodejs

Làm việc với Table MySQL sử dụng Nodejs

Kết nối với MongoDB trong NodeJS

Kết nối với MongoDB trong NodeJS

Giới thiệu MongoDB trong NodeJS

Giới thiệu MongoDB trong NodeJS

Insert / Update / Delete / Select MySQL trong NodeJS

Insert / Update / Delete / Select MySQL trong NodeJS

Top