create server/client

BaseMax · BaseMax · commit c1deaf8ea5db · 2023-09-20T14:05:04.000+01:00
diff --git a/client.html b/client.html
@@ -0,0 +1,15 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+  <meta charset="UTF-8">
+  <meta name="viewport" content="width=device-width, initial-scale=1.0">
+  <title>WebSocket Chat</title>
+</head>
+<body>
+  <h1>WebSocket Chat</h1>
+  <input type="text" id="messageInput" placeholder="Type your message">
+  <button onclick="sendMessage()">Send</button>
+
+  <script src="client.js"></script>
+</body>
+</html>
diff --git a/client.js b/client.js
@@ -0,0 +1,33 @@
+// Create a WebSocket connection
+const socket = new WebSocket('ws://localhost:8080');
+
+// Event listener for when the connection is opened
+socket.addEventListener('open', (event) => {
+  console.log('Connected to WebSocket server');
+});
+
+// Event listener for messages from the server
+socket.addEventListener('message', (event) => {
+  console.log(`Received from server: ${event.data}`);
+});
+
+// Event listener for when the connection is closed
+socket.addEventListener('close', (event) => {
+  if (event.wasClean) {
+    console.log('Connection closed cleanly');
+  } else {
+    console.error('Connection abruptly closed');
+  }
+});
+
+// Event listener for connection errors
+socket.addEventListener('error', (event) => {
+  console.error('WebSocket error:', event);
+});
+
+// Send a message to the server
+function sendMessage() {
+  const message = document.getElementById('messageInput').value;
+  console.log(message);
+  socket.send(message);
+}
diff --git a/server.js b/server.js
@@ -0,0 +1,39 @@
+// Import required modules
+const http = require('http');
+const WebSocket = require('ws');
+
+// Create an HTTP server
+const server = http.createServer((req, res) => {
+  res.writeHead(200, { 'Content-Type': 'text/plain' });
+  res.end('WebSocket Server Running');
+});
+
+// Create a WebSocket server by passing the HTTP server
+const wss = new WebSocket.Server({ server });
+
+// WebSocket server event handling
+wss.on('connection', (ws) => {
+  console.log('Client connected');
+
+  // Event listener for messages from clients
+  ws.on('message', (message) => {
+    console.log(`Received: ${message}`);
+    
+    // Broadcast the message to all connected clients
+    wss.clients.forEach((client) => {
+      if (client !== ws && client.readyState === WebSocket.OPEN) {
+        client.send(message);
+      }
+    });
+  });
+
+  // Event listener for client disconnection
+  ws.on('close', () => {
+    console.log('Client disconnected');
+  });
+});
+
+// Start the HTTP server on port 8080
+server.listen(8080, () => {
+  console.log('Server listening on http://localhost:8080');
+});
