Signaling Server: bu nima, qanday ishlaydi va qayerda ishlatiladi

Signaling Server nima

Signaling Server — bu ikki yoki undan ortiq peer o'rtasida WebRTC ulanishini o'rnatish jarayonini muvofiqlashtirish uchun mas'ul bo'lgan tarmoq xizmati. U media ma'lumotlarini (audio, video, DataChannel kanal ma'lumotlari) uzatmaydi, faqat peerlarni aniqlash va ulanish parametrlarini kelishish uchun zarur bo'lgan xizmat ma'lumotlarini uzatadi. P2P kanali muvaffaqiyatli o'rnatilgandan so'ng, Signaling Server endi kerak bo'lmasligi mumkin, ammo ba'zi arxitekturalarda keyingi signal almashinuvi uchun qoladi (masalan, qo'ng'iroqni tugatish, ishtirokchilarni qo'shish).

Signalizatsiya arxitekturasi uch komponentni o'z ichiga oladi: Signaling Server, Signal Channel (mijoz va server o'rtasidagi transport protokoli) va mijoz API (odatda brauzerning WebRTC stekiga o'rnatilgan). WebRTC spetsifikatsiyasi (W3C, 2024) ataylab signal protokolini standartlashtirmaydi — ishlab chiquvchilar o'z ilovalari uchun mos keladigan har qanday transportni tanlashi mumkin. Ushbu moslashuvchan yechim veb ilovalari uchun WebSocket, chat tizimlari uchun XMPP yoki telekommunikatsiya infratuzilmasi bilan integratsiya uchun SIPdan foydalanish imkonini beradi.

Signalizatsiya jarayoni: yuqori daraja

WebRTC ulanishi o'rnatilishidan oldin peerlar uch turdagi xabarlarni almashishlari kerak: session description (offer va answer), ICE candidates va sessiyani tugatish/o'zgartirish haqidagi ma'lumot. Signaling Server bu xabarlarni peerlar o'rtasida yo'naltiradi, manzillash uchun xona yoki foydalanuvchi identifikatorlaridan foydalanadi. Standart namuna — ikkita ishtirokchi ulanadigan “xona” yaratiladi va server har bir ishtirokchidan kelgan xabarlarni faqat uning suhbatdoshiga uzatadi.

WebRTCda signalizatsiya qanday ishlaydi

Signaling Server quyidagi odatiy WebRTC ulanishini o'rnatish protokolini amalga oshiradi. Peerlar WebSocket (yoki boshqa transport) orqali serverga ulanadi va xonada ro'yxatdan o'tadi. Peer A (tashabbuskor) RTCPeerConnection.createOffer() orqali offer (chiqish media oqimining SDP tavsifi) yaratadi, uni local description sifatida o'rnatadi va Signaling Serverga yuboradi. Server offerni peer B ga uzatadi. Peer B offerni oladi, uni remote description sifatida o'rnatadi, createAnswer() orqali answer yaratadi, uni local description sifatida o'rnatadi va server orqali qaytarib yuboradi. Bu jarayon SDP Offer/Answer deb ataladi.

SDP almashinuvi bilan parallel ravishda, har bir peer ICE candidates (host, srflx, relay) to'playdi va ularni Signaling Server orqali boshqa peerga yuboradi. Uzoqdagi peer olingan nomzodlarni RTCPeerConnection.addIceCandidate() orqali qo'shadi. ICE jarayoni ishlaydigan yo'lni topish uchun nomzodlarning barcha kombinatsiyalarini tekshiradi. Ishlaydigan yo'l topilgandan so'ng (odatda 1–5 soniya ichida), media trafigi to'g'ridan-to'g'ri peerlar o'rtasida uzatila boshlaydi va Signaling Server endi ma'lumotlarni uzatishda ishtirok etmaydi — uning roli keyingi xizmat hodisasigacha (qo'ng'iroqni tugatish, oqim sifatini o'zgartirish) tugaydi.

Xona mexanizmi va ro'yxatdan o'tish

Xabarlarni manzillash uchun Signaling Server xonalar (rooms) yoki kanallar mexanizmidan foydalanadi. Har bir yangi WebRTC seansi identifikator (odatda UUID) bilan noyob xona yaratadi. Tashabbuskor xona yaratadi va ikkinchi peerning ulanishini kutadi. Ikkinchi peer tashqi kanal (masalan, taklif havolasi) orqali olingan ID bilan xonaga ulanadi. Server xonalar xaritasini saqlaydi, unda har bir IDga ulangan mijozlar ro'yxati mos keladi. Ishtirokchilar soni ikkitaga yetganda, server ular o'rtasida signal xabarlarini uzatishni boshlaydi.

WebRTC signalizatsiya protokollari

Signaling Server turli transport protokollaridan foydalanishi mumkin, ularning har biri o'zining afzalliklari va kamchiliklariga ega. Protokolni tanlash ilova turiga, infratuzilma cheklovlariga va moslik talablariga bog'liq. Quyida eng keng tarqalgan protokollar va ularning xususiyatlari keltirilgan.

WebSocket veb ilovalarida Signaling Server uchun eng mashhur protokoldir. U SDP va ICE nomzodlarining asinxron almashinuvi uchun muhim bo'lgan to'liq dupleks aloqani ta'minlaydi va barcha zamonaviy brauzerlar tomonidan WebSocket API orqali qo'llab-quvvatlanadi. WebSocketning server implementatsiyasi barcha mashhur platformalarda (Node.js, Python, Java, Go) mavjud. Millionlab foydalanuvchilari bo'lgan ilovalar uchun Signaling Server instansiyalari o'rtasida sinxronizatsiya uchun Redis Pub/Sub yoki Kafka asosidagi masshtablanadigan WebSocket yechimlari qo'llaniladi.

Signaling Server implementatsiyasi namunasi

ws (WebSocket) kutubxonasi va o'rnatilgan HTTP serveridan foydalangan holda Node.js da oddiy Signaling Server implementatsiyasini ko'rib chiqaylik. Server foydalanuvchilarni ro'yxatdan o'tkazish, xonalar yaratish va ishtirokchilar o'rtasida xabarlarni uzatishni qo'llab-quvvatlaydi.

const WebSocket = require("ws");
const server = new WebSocket.Server({ port: 8080 });
const rooms = new Map();

server.on("connection", (ws) => {
    ws.roomId = null;

    ws.on("message", (data) => {
        const msg = JSON.parse(data);

        switch (msg.type) {
            case "join":
                handleJoin(ws, msg.roomId);
                break;
            case "offer":
            case "answer":
            case "ice-candidate":
                relayToPeer(ws, msg);
                break;
            case "leave":
                handleLeave(ws);
                break;
        }
    });

    ws.on("close", () => handleLeave(ws));
});

function handleJoin(ws, roomId) {
    if (!rooms.has(roomId)) {
        rooms.set(roomId, []);
    }

    const room = rooms.get(roomId);
    room.push(ws);
    ws.roomId = roomId;

    if (room.length === 2) {
        room[0].send(JSON.stringify({ type: "peer-joined" }));
        room[1].send(JSON.stringify({ type: "peer-joined" }));
    }
}

function relayToPeer(sender, msg) {
    const room = rooms.get(sender.roomId);
    if (!room) return;

    room.forEach(peer => {
        if (peer !== sender && peer.readyState === WebSocket.OPEN) {
            peer.send(JSON.stringify(msg));
        }
    });
}

function handleLeave(ws) {
    if (!ws.roomId) return;
    const room = rooms.get(ws.roomId);
    if (!room) return;

    const idx = room.indexOf(ws);
    if (idx !== -1) room.splice(idx, 1);
    if (room.length === 0) rooms.delete(ws.roomId);
}

Ushbu Signaling Server asosiy funksionallikni amalga oshiradi: xonaga ulanish, ikki peer o'rtasida WebRTC xabarlarini (offer, answer, ice-candidate) uzatish va uzilishlarni boshqarish. Server ulangan WebSocket mijozlari bilan xonalarni saqlash uchun Mapdan foydalanadi. relayToPeer funksiyasi jo'natuvchidan tashqari xonadagi barcha ishtirokchilarga xabar yuboradi. Ishlab chiqarish muhiti uchun xabar turlarini tasdiqlash, JSON parsering xatolarini qayta ishlash va uzilgan ulanishlarni aniqlash uchun heartbeat mexanizmi qo'shilishi kerak.

Signaling Server bilan mijoz integratsiyasi

Mijoz tomonida Signaling Server brauzerning WebSocket API si orqali integratsiyalanadi. Mijoz serverga ulanadi, xonaga qo'shilish so'rovini yuboradi, so'ngra kiruvchi WebRTC xabarlarini qayta ishlaydi va ularni setRemoteDescription() va addIceCandidate() orqali RTCPeerConnection ga uzatadi. Mijoz kodi shuningdek onicecandidate hodisalari va offer/answer yaratilgandan so'ng RTCPeerConnection dan olingan o'zining SDP va ICE nomzodlarini serverga yuboradi.

Signalizatsiyada SDP va ICEning roli

Signaling Server ikki asosiy metama'lumot turini uzatadi: SDP (Session Description Protocol) va ICE candidates. SDP media oqimining parametrlarini — kodeklarni, tanlash chastotasini, kanallar sonini, uzatish yo'nalishini (sendrecv, sendonly, recvonly, inactive) tavsiflaydi. ICE candidates peer ulanish uchun mavjud bo'lishi mumkin bo'lgan tarmoq manzillarini (mahalliy, STUN dan olingan, TURN dan relay) o'z ichiga oladi.

SDP sessiyalar va media bo'limlarini o'z ichiga olgan matn formatida taqdim etiladi. Sessiya qismi umumiy parametrlarni (sessiya identifikatori, versiya, nom) tavsiflaydi, media bo'limlari esa har bir media oqimini (audio, video, DataChannel) uning kodeki, porti va protokoli bilan tavsiflaydi. ICE nomzodlari foundation (guruhlash uchun identifikator), priority, IP manzil, port, tur (host, srflx, relay) va protokol (UDP, TCP) ni o'z ichiga oladi. Har bir candidate shuningdek uni aniq ICE jarayoni bilan bog'laydigan ufrag (username fragment) atributini o'z ichiga oladi.

• SDP Offer — tashabbuskor o'zining media imkoniyatlari tavsifini yaratadi va uni Signaling Server orqali uzoqdagi peerga yuboradi.
• SDP Answer — uzoqdagi peer o'z tavsifi bilan javob beradi, media formatlari va kodeklarni tasdiqlaydi yoki tuzatadi.
• ICE Candidate — har bir peer ICE framework tomonidan aniqlanganda o'zining tarmoq nomzodlarini signal serveriga yuboradi.
• Trickle ICE — zamonaviy optimallashtirish, bunda nomzodlar to'plash tugagandan so'ng hammasi birdan emas, balki aniqlanganda birma-bir yuboriladi.
• Re-negotiation — media parametrlari o'zgarganda (videoni yoqish/o'chirish, ishtirokchini qo'shish) peerlar Signaling Server orqali takroriy SDP almashinuvini boshlaydi.

Trickle ICE WebRTC ulanishini o'rnatishni sezilarli darajada tezlashtiradi. Barcha ICE nomzodlarini to'liq to'plashni kutish o'rniga (murakkab tarmoqlarda 2–10 soniya davom etishi mumkin), har bir nomzod aniqlangandan so'ng darhol Signaling Serverga yuboriladi. Uzoqdagi peer nomzodni oladi va darhol ICE framework orqali ulanishni tekshirishni boshlaydi. Bu ko'p hollarda ulanishni o'rnatish vaqtini 500–1500 ms gacha kamaytiradi.