서예진

socket.js, sse,js

1 +const SocketIO = require('socket.io');
2 +
3 +module.exports = (server, app) => {
4 + const io = SocketIO(server, { path: '/socket.io' });
5 +
6 + app.set('io', io);
7 +
8 + io.on('connection', (socket) => {
9 + const req = socket.request;
10 + const { headers: { referer } } = req;
11 + const roomId = referer.split('/')[referer.split('/').length - 1];
12 + socket.join(roomId);
13 + socket.on('disconnect', () => {
14 + socket.leave(roomId);
15 + });
16 + });
17 +};
1 +const SSE = require('sse');
2 +
3 +module.exports = (server) => {
4 + const sse = new SSE(server);
5 + sse.on('connection', (client) => {
6 + setInterval(() => {
7 + client.send(Date.now().toString());
8 + }, 1000);
9 + });
10 +};