Экземпляр Socket (серверная сторона)
Помимо:
Экземпляр Socket имеет несколько атрибутов, которые могут быть полезны в вашем приложении:
Socket#id
Каждое новое подключение получает случайный идентификатор из 20 символов.
Этот идентификатор синхронизирован со значением на стороне клиента.
// server-side
io.on("connection", (socket) => {
console.log(socket.id); // ojIckSD2jqNzOqIrAGzL
});
// client-side
socket.on("connect", () => {
console.log(socket.id); // ojIckSD2jqNzOqIrAGzL
}); |
При создании Socket подключается к комнате, идентифицируемой его собственным id, что позволяет использовать его для приватного обмена сообщениями:
io.on("connection", socket => {
socket.on("private message", (anotherSocketId, msg) => {
socket.to(anotherSocketId).emit("private message", socket.id, msg);
});
}); |
Примечание: вы не можете перезаписать этот идентификатор, так как он используется в нескольких частях кода Socket.IO.
Socket#handshake
Этот объект содержит некоторые детали о рукопожатии, происходящем в начале сессии Socket.IO.
{
headers: /* the headers of the initial request */
query: /* the query params of the initial request */
auth: /* the authentication payload */
time: /* the date of creation (as string) */
issued: /* the date of creation (unix timestamp) */
url: /* the request URL string */
address: /* the ip of the client */
xdomain: /* whether the connection is cross-domain */
secure: /* whether the connection is secure */
} |
Пример:
{
"headers": {
"user-agent": "xxxx",
"accept": "*/*",
"host": "example.com",
"connection": "close"
},
"query": {
"EIO": "4",
"transport": "polling",
"t": "NNjNltH"
},
"auth": {
"token": "123"
},
"time": "Sun Nov 22 2020 01:33:46 GMT+0100 (Central European Standard Time)",
"issued": 1606005226969,
"url": "/socket.io/?EIO=4&transport=polling&t=NNjNltH",
"address": "::ffff:1.2.3.4",
"xdomain": false,
"secure": true
} |
Socket#rooms
Это ссылка на комнаты, в которых в данный момент находится Socket.
io.on("connection", (socket) => {
console.log(socket.rooms); // Set { <socket.id> }
socket.join("room1");
console.log(socket.rooms); // Set { <socket.id>, "room1" }
}); |
Дополнительные атрибуты
До тех пор, пока вы не перезапишете существующий атрибут, вы можете добавить любой атрибут к экземпляру Socket и использовать его позже:
// in a middleware
io.use(async (socket, next) => {
try {
const user = await fetchUser(socket);
socket.user = user;
} catch (e) {
next(new Error("unknown user"));
}
});
io.on("connection", (socket) => {
console.log(socket.user);
// in a listener
socket.on("set username", (username) => {
socket.username = username;
});
});
|
События
На серверной стороне экземпляр Socket отправляет два специальных события:
disconnect
Это событие срабатывает в экземпляре Socket при отключении.
io.on("connection", (socket) => {
socket.on("disconnect", (reason) => {
// ...
});
}); |
Вот список возможных причин:
| Причина | Описание |
|---|---|
server namespace disconnect |
Сокет был принудительно отключен с помощью socket.disconnect() |
client namespace disconnect |
Клиент вручную отключил сокет, используя socket.disconnect() |
server shutting down |
Сервер завершает работу |
ping timeout |
Клиент не отправил пакет PONG в течение pingTimeout задержки |
transport close |
Подключение было закрыто (например, пользователь потерял подключение или сеть изменилась с Wi-Fi на 4G) |
transport error |
Подключение столкнулось с ошибкой |
disconnecting
Это событие аналогично disconnect, но срабатывает немного раньше, когда набор Socket#rooms еще не пуст.
io.on("connection", (socket) => {
socket.on("disconnecting", (reason) => {
for (const room of socket.rooms) {
if (room !== socket.id) {
socket.to(room).emit("user has left", socket.id);
}
}
});
}); |
Примечание: эти события, наряду с connect, connect_error, newListener и removeListener, являются специальными событиями, которые не следует использовать в вашем приложении:
// BAD, will throw an error
socket.emit("disconnect"); |
Полный API
Полный API, предоставляемый экземпляром Socket, можно найти здесь.
© 2014–2021 Automattic
Licensed under the MIT License.
https://socket.io/docs/v3/server-socket-instance