การแพร่ภาพและ WebSocket การบูรณาการใน Node.js

การเผยแพร่ข้อมูลและการผสานรวม WebSocket เป็นสองส่วนสำคัญในการสร้างแอปพลิเคชันแบบเรียลไทม์ Node.js ด้วย ในบทความนี้ เราจะสำรวจวิธีการเผยแพร่ข้อมูลและบูรณาการ WebSocket เพื่อสร้างประสบการณ์ผู้ใช้แบบโต้ตอบและตอบสนอง

ขั้นตอนที่ 1: การออกอากาศข้อมูลจากเซิร์ฟเวอร์

หากต้องการเผยแพร่ข้อมูลจากเซิร์ฟเวอร์ไปยังการเชื่อมต่อไคลเอนต์ คุณสามารถใช้วิธีต่างๆ เช่น broadcast ส่งข้อความไปยังการเชื่อมต่อทั้งหมดหรือ send เพื่อส่งข้อความไปยังการเชื่อมต่อเฉพาะ ต่อไปนี้เป็นตัวอย่างของการเผยแพร่ข้อมูลจากเซิร์ฟเวอร์:

// ... Initialize WebSocket server  
  
// Broadcast data to all connections  
function broadcast(message) {  
    for(const client of clients) {  
        client.send(message);  
    }  
}  
  
// Handle new connections  
server.on('connection',(socket) => {  
    // Add connection to the list  
    clients.add(socket);  
  
    // Handle incoming messages from the client  
    socket.on('message',(message) => {  
        // Broadcast the message to all other connections  
        broadcast(message);  
    });  
  
    // Handle connection close  
    socket.on('close',() => {  
        // Remove the connection from the list  
        clients.delete(socket);  
    });  
});  

ขั้นตอนที่ 2: การรวมเข้า WebSocket กับ Node.js แอปพลิเคชัน

ในการรวมเข้า WebSocket กับ Node.js แอปพลิเคชัน คุณต้องสร้าง WebSocket การเชื่อมต่อในโค้ด JavaScript ของคุณ ต่อไปนี้คือตัวอย่างการผสานรวม WebSocket ในฝั่งไคลเอนต์ของแอปพลิเคชันของคุณ:

// Initialize WebSocket connection from the client  
const socket = new WebSocket('ws://localhost:8080');  
  
// Handle incoming messages from the server  
socket.onmessage =(event) => {  
    const message = event.data;  
    // Process the received message from the server  
    console.log('Received message:', message);  
};  
  
// Send a message from the client to the server  
function sendMessage() {  
    const messageInput = document.getElementById('messageInput');  
    const message = messageInput.value;  
    socket.send(message);  
    messageInput.value = '';  
}  

บทสรุป

คุณสามารถสร้างแอปพลิเคชันเรียลไทม์แบบโต้ตอบและตอบสนองได้ โดยการเผยแพร่ข้อมูลและการรวมเข้า WebSocket ด้วยกัน Node.js สิ่งนี้ช่วยปรับปรุงประสบการณ์ผู้ใช้และเปิดใช้งานการโต้ตอบแบบเรียลไทม์ระหว่างแอปพลิเคชันไคลเอ็นต์และเซิร์ฟเวอร์