WebSocket и Real-time: Socket.io и Server-Sent Events

1npm install socket.io

1import { Server } from 'socket.io';
2
3const io = new Server(3000, {
4  cors: {
5    origin: 'http://localhost:5173',
6  },
7});
8
9io.on('connection', (socket) => {
10  console.log('Клиент подключился:', socket.id);
11
12  socket.on('message', (data) => {
13    io.emit('message', data);
14  });
15
16  socket.on('disconnect', () => {
17    console.log('Клиент отключился:', socket.id);
18  });
19});

1<script src="/socket.io/socket.io.js"></script>
2<script>
3  const socket = io('http://localhost:3000');
4
5  socket.emit('message', 'Привет сервер!');
6  socket.on('message', (data) => {
7    console.log('Сообщение:', data);
8  });
9</script>

1io.on('connection', (socket) => {
2  socket.on('join-room', (roomId) => {
3    socket.join(roomId);
4  });
5
6  socket.on('send-message', ({ roomId, message }) => {
7    io.to(roomId).emit('message', message);
8  });
9});

1io.use((socket, next) => {
2  const token = socket.handshake.auth.token;
3  const user = verifyToken(token);
4  if (!user) {
5    return next(new Error('Не авторизован'));
6  }
7  socket.user = user;
8  next();
9});

1import express from 'express';
2
3const app = express();
4
5app.get('/events', (req, res) => {
6  res.setHeader('Content-Type', 'text/event-stream');
7  res.setHeader('Cache-Control', 'no-cache');
8  res.setHeader('Connection', 'keep-alive');
9
10  const sendEvent = (data) => {
11    res.write(`data: ${JSON.stringify(data)}\n\n`);
12  };
13
14  // Отправка событий
15  setInterval(() => {
16    sendEvent({ time: new Date().toISOString() });
17  }, 1000);
18
19  req.on('close', () => {
20    // Очистка при отключении
21  });
22});

1const eventSource = new EventSource('/events');
2
3eventSource.onmessage = (event) => {
4  const data = JSON.parse(event.data);
5  console.log('Получено:', data);
6};
7
8eventSource.onerror = (error) => {
9  console.error('Ошибка:', error);
10};

1// Сервер
2io.on('connection', (socket) => {
3  socket.on('join', (username) => {
4    socket.username = username;
5    io.emit('user-connected', username);
6  });
7
8  socket.on('chat-message', (message) => {
9    io.emit('chat-message', {
10      message,
11      username: socket.username,
12      time: new Date().toISOString(),
13    });
14  });
15
16  socket.on('disconnect', () => {
17    io.emit('user-disconnected', socket.username);
18  });
19});

1// Сервер
2app.get('/notifications', (req, res) => {
3  res.setHeader('Content-Type', 'text/event-stream');
4  res.setHeader('Cache-Control', 'no-cache');
5  res.setHeader('Connection', 'keep-alive');
6
7  const sendNotification = (notification) => {
8    res.write(`event: notification\n`);
9    res.write(`data: ${JSON.stringify(notification)}\n\n`);
10  };
11
12  // Подписка на Redis pub/sub для уведомлений
13  redis.subscribe('notifications', (message) => {
14    sendNotification(JSON.parse(message));
15  });
16});

1import { createAdapter } from '@socket.io/redis-adapter';
2import { createClient } from 'redis';
3
4const pubClient = createClient();
5const subClient = pubClient.duplicate();
6
7io.adapter(createAdapter(pubClient, subClient));

1const io = new Server(3000, {
2  cors: {
3    origin: 'https://example.com',
4    credentials: true,
5  },
6});
7
8// Аутентификация
9io.use((socket, next) => {
10  const token = socket.handshake.auth.token;
11  if (!verifyToken(token)) {
12    return next(new Error('Не авторизован'));
13  }
14  next();
15});