**Course Title:** Mastering Express.js: Building Scalable Web Applications and APIs **Section Title:** Real-Time Applications with WebSockets **Topic:** Handling Events and Broadcasting Messages **Introduction:** In real-time applications, events and broadcasting messages are crucial for maintaining a seamless user experience. In this topic, we will explore how to handle events and broadcast messages in Express.js applications using WebSockets. We will cover the basics of WebSockets, event handling, and broadcasting messages, along with practical examples and takeaways. **What are WebSockets?** WebSockets are a protocol that enables bidirectional, real-time communication between a web browser (or client) and a server over the web. They allow for efficient, low-latency communication, making them ideal for real-time applications such as live updates, chat applications, and gaming. **Setting up WebSockets in Express.js** To set up WebSockets in Express.js, we need to install the `ws` library using npm: ```bash npm install ws ``` We can then create a WebSocket server using the `ws` library: ```javascript const WebSocket = require('ws'); const wss = new WebSocket.Server({ port: 8080 }); ``` **Handling Events and Broadcasting Messages** To handle events and broadcast messages, we need to create a WebSocket connection and listen for incoming messages. We can then broadcast messages to all connected clients using the `broadcast` method: ```javascript wss.on('connection', (ws) => { console.log('Client connected'); ws.on('message', (message) => { console.log(`Received message: ${message}`); wss.broadcast(message); }); ws.on('close', () => { console.log('Client disconnected'); }); }); ``` In this example, we create a WebSocket connection and listen for incoming messages. When a message is received, we broadcast it to all connected clients using the `broadcast` method. **Broadcasting Messages** To broadcast messages to all connected clients, we can use the `wss.broadcast` method: ```javascript wss.broadcast(message, (error) => { if (error) { console.error(error); } else { console.log(`Broadcasted message to ${wss.clients.length} clients`); } }); ``` In this example, we broadcast a message to all connected clients and log the number of clients that received the message. **Example Use Case: Live Updates** To demonstrate the power of WebSockets, let's create a simple live updates application. We can create a WebSocket server that broadcasts updates to all connected clients: ```javascript const WebSocket = require('ws'); const wss = new WebSocket.Server({ port: 8080 }); wss.on('connection', (ws) => { console.log('Client connected'); ws.on('message', (message) => { console.log(`Received message: ${message}`); wss.broadcast(message); }); ws.on('close', () => { console.log('Client disconnected'); }); }); setInterval(() => { wss.broadcast('New update!', (error) => { if (error) { console.error(error); } else { console.log('Broadcasted update to all clients'); } }); }, 1000); ``` In this example, we create a WebSocket server that broadcasts updates to all connected clients every second. **Practical Takeaways:** 1. WebSockets enable bidirectional, real-time communication between a web browser and a server. 2. To handle events and broadcast messages, create a WebSocket connection and listen for incoming messages. 3. Use the `broadcast` method to broadcast messages to all connected clients. 4. Use `setInterval` to broadcast updates to all connected clients at regular intervals. **Exercise:** Create a simple WebSocket server that broadcasts messages to all connected clients. Use the `broadcast` method to send messages to all clients. **Comment or Ask for Help:** Please leave a comment or ask for help if you have any questions or need further clarification on any of the concepts covered in this topic.

npm install ws

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

wss.on('connection', (ws) => {
  console.log('Client connected');

  ws.on('message', (message) => {
    console.log(`Received message: ${message}`);
    wss.broadcast(message);
  });

  ws.on('close', () => {
    console.log('Client disconnected');
  });
});

wss.broadcast(message, (error) => {
  if (error) {
    console.error(error);
  } else {
    console.log(`Broadcasted message to ${wss.clients.length} clients`);
  }
});

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

wss.on('connection', (ws) => {
  console.log('Client connected');

  ws.on('message', (message) => {
    console.log(`Received message: ${message}`);
    wss.broadcast(message);
  });

  ws.on('close', () => {
    console.log('Client disconnected');
  });
});

setInterval(() => {
  wss.broadcast('New update!', (error) => {
    if (error) {
      console.error(error);
    } else {
      console.log('Broadcasted update to all clients');
    }
  });
}, 1000);