Signaling Server: এটি কী, কীভাবে কাজ করে এবং কোথায় ব্যবহার করা হয়

Signaling Server কী

Signaling Server — একটি নেটওয়ার্ক পরিষেবা যা দুই বা ততোধিক পিয়ারের মধ্যে WebRTC সংযোগ স্থাপন প্রক্রিয়ার সমন্বয়ের জন্য দায়ী। এটি মিডিয়া ডেটা (অডিও, ভিডিও, DataChannel ডেটা) প্রেরণ করে না, বরং শুধুমাত্র পিয়ার আবিষ্কার এবং সংযোগ প্যারামিটার আলোচনার জন্য প্রয়োজনীয় নিয়ন্ত্রণ তথ্য প্রেরণ করে। সফল P2P চ্যানেল প্রতিষ্ঠিত হওয়ার পর, Signaling Server-এর আর প্রয়োজন নাও হতে পারে, কিন্তু কিছু আর্কিটেকচারে এটি পরবর্তী সিগন্যাল বিনিময়ের (যেমন কল সমাপ্তি, অংশগ্রহণকারী যোগ করা) জন্য থেকে যায়।

সিগন্যালিং আর্কিটেকচারে তিনটি উপাদান অন্তর্ভুক্ত: Signaling Server, Signal Channel (ক্লায়েন্ট এবং সার্ভারের মধ্যে পরিবহন প্রোটোকল) এবং ক্লায়েন্ট API (সাধারণত ব্রাউজারের WebRTC স্ট্যাকে নির্মিত)। WebRTC স্পেসিফিকেশন (W3C, 2024) ইচ্ছাকৃতভাবে সিগন্যালিং প্রোটোকলকে মানসম্মত করে না — ডেভেলপাররা তাদের অ্যাপ্লিকেশনের জন্য উপযুক্ত যে কোনও পরিবহন বেছে নিতে পারেন। এই নমনীয় পদ্ধতি ওয়েব অ্যাপ্লিকেশনের জন্য WebSocket, চ্যাট সিস্টেমের জন্য XMPP বা টেলিকমিউনিকেশন অবকাঠামোর সাথে একীকরণের জন্য SIP ব্যবহারের অনুমতি দেয়।

সিগন্যালিং প্রক্রিয়া: উচ্চ-স্তরের ওভারভিউ

WebRTC সংযোগ স্থাপনের আগে, পিয়ারদের তিন ধরনের বার্তা বিনিময় করতে হবে: সেশন বিবরণ (offer এবং answer), ICE প্রার্থী এবং সেশন সমাপ্তি/পরিবর্তন তথ্য। Signaling Server এই বার্তাগুলিকে পিয়ারদের মধ্যে রুম বা ব্যবহারকারী শনাক্তকারী ব্যবহার করে রুট করে। মানক প্যাটার্ন হল একটি “রুম” তৈরি করা যেখানে দুইজন অংশগ্রহণকারী সংযোগ করে, এবং সার্ভার প্রতিটি অংশগ্রহণকারীর থেকে শুধুমাত্র তার কথোপকথকের কাছে বার্তা রিলে করে।

WebRTC-তে সিগন্যালিং কীভাবে কাজ করে

Signaling Server নিম্নলিখিত সাধারণ WebRTC সংযোগ স্থাপন প্রোটোকল বাস্তবায়ন করে। পিয়াররা WebSocket (বা অন্য পরিবহন) এর মাধ্যমে সার্ভারের সাথে সংযোগ করে এবং একটি রুমে নিবন্ধন করে। পিয়ার A (সূচনাকারী) RTCPeerConnection.createOffer() এর মাধ্যমে একটি offer (আউটগোয়িং মিডিয়া স্ট্রিমের SDP বিবরণ) তৈরি করে, এটিকে স্থানীয় বিবরণ হিসাবে সেট করে এবং Signaling Server-এ পাঠায়। সার্ভার offer টি পিয়ার B-তে রিলে করে। পিয়ার B offer গ্রহণ করে, এটিকে দূরবর্তী বিবরণ হিসাবে সেট করে, createAnswer() এর মাধ্যমে answer তৈরি করে, এটিকে স্থানীয় বিবরণ হিসাবে সেট করে এবং সার্ভারের মাধ্যমে ফেরত পাঠায়। এই প্রক্রিয়াটিকে SDP Offer/Answer বলা হয়।

SDP বিনিময়ের সমান্তরালে, প্রতিটি পিয়ার ICE প্রার্থী (host, srflx, relay) সংগ্রহ করে এবং Signaling Server-এর মাধ্যমে অন্য পিয়ারের কাছে পাঠায়। দূরবর্তী পিয়ার প্রাপ্ত প্রার্থীদের RTCPeerConnection.addIceCandidate() এর মাধ্যমে যোগ করে। ICE প্রক্রিয়া একটি কার্যকর পথ খুঁজতে প্রার্থীদের সকল সমন্বয় পরীক্ষা করে। একবার কার্যকর পথ পাওয়া গেলে (সাধারণত 1–5 সেকেন্ডের মধ্যে), মিডিয়া ট্রাফিক সরাসরি পিয়ারদের মধ্যে প্রবাহিত হতে শুরু করে, এবং Signaling Server আর ডেটা প্রেরণে অংশগ্রহণ করে না — পরবর্তী নিয়ন্ত্রণ ইভেন্ট (কল সমাপ্তি, স্ট্রিম গুণমান পরিবর্তন) পর্যন্ত এর ভূমিকা শেষ হয়।

রুম মেকানিজম এবং নিবন্ধন

বার্তা ঠিকানার জন্য, Signaling Server রুম (rooms) বা চ্যানেল মেকানিজম ব্যবহার করে। প্রতিটি নতুন WebRTC সেশন একটি অনন্য শনাক্তকারী (সাধারণত UUID) সহ একটি রুম তৈরি করে। সূচনাকারী রুম তৈরি করে এবং দ্বিতীয় পিয়ারের সংযোগের অপেক্ষা করে। দ্বিতীয় পিয়ার বাহ্যিক চ্যানেলের (যেমন আমন্ত্রণ লিঙ্ক) মাধ্যমে প্রাপ্ত ID ব্যবহার করে রুমে যোগ দেয়। সার্ভার রুমের একটি ম্যাপ বজায় রাখে, যেখানে প্রতিটি ID সংযুক্ত ক্লায়েন্টের তালিকার সাথে মিলে যায়। যখন অংশগ্রহণকারীর সংখ্যা দুইয়ে পৌঁছায়, সার্ভার তাদের মধ্যে সিগন্যালিং বার্তা রিলে করা শুরু করে।

WebRTC সিগন্যালিং প্রোটোকল

Signaling Server বিভিন্ন পরিবহন প্রোটোকল ব্যবহার করতে পারে, প্রতিটির নিজস্ব সুবিধা এবং অসুবিধা রয়েছে। প্রোটোকলের পছন্দ অ্যাপ্লিকেশনের ধরন, অবকাঠামোর সীমাবদ্ধতা এবং সামঞ্জস্যের প্রয়োজনীয়তার উপর নির্ভর করে। নীচে সবচেয়ে সাধারণ প্রোটোকল এবং তাদের বৈশিষ্ট্য দেওয়া হল।

WebSocket ওয়েব অ্যাপ্লিকেশনে Signaling Server-এর জন্য সবচেয়ে জনপ্রিয় প্রোটোকল। এটি পূর্ণ-দ্বৈত যোগাযোগ সরবরাহ করে, যা SDP এবং ICE প্রার্থীদের অ্যাসিঙ্ক্রোনাস বিনিময়ের জন্য গুরুত্বপূর্ণ, এবং WebSocket API-এর মাধ্যমে সমস্ত আধুনিক ব্রাউজার দ্বারা স্থানীয়ভাবে সমর্থিত। সার্ভার-সাইড WebSocket বাস্তবায়ন সমস্ত জনপ্রিয় প্ল্যাটফর্মে (Node.js, Python, Java, Go) উপলব্ধ। লক্ষ লক্ষ ব্যবহারকারীর অ্যাপ্লিকেশনের জন্য, Signaling Server ইনস্ট্যান্সের মধ্যে সিঙ্ক্রোনাইজেশনের জন্য Redis Pub/Sub বা Kafka-ভিত্তিক স্কেলেবল WebSocket সমাধান ব্যবহার করা হয়।

Signaling Server বাস্তবায়ন উদাহরণ

আসুন ws লাইব্রেরি (WebSocket) এবং বিল্ট-ইন HTTP সার্ভার ব্যবহার করে Node.js-এ একটি সহজ Signaling Server বাস্তবায়ন দেখি। সার্ভার ব্যবহারকারী নিবন্ধন, রুম তৈরি এবং অংশগ্রহণকারীদের মধ্যে বার্তা রিলে সমর্থন করে।

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);
}

এই Signaling Server মৌলিক কার্যকারিতা বাস্তবায়ন করে: রুমে সংযোগ, দুই পিয়ারের মধ্যে WebRTC বার্তা (offer, answer, ice-candidate) রিলে এবং সংযোগ বিচ্ছিন্ন ব্যবস্থাপনা। সার্ভার সংযুক্ত WebSocket ক্লায়েন্ট সহ রুম সংরক্ষণের জন্য Map ব্যবহার করে। relayToPeer ফাংশন প্রেরক ব্যতীত রুমের সকল অংশগ্রহণকারীকে বার্তা পাঠায়। উৎপাদনের জন্য, আপনার বার্তার ধরণ যাচাইকরণ, JSON পার্সিং ত্রুটি হ্যান্ডলিং এবং ভাঙা সংযোগ সনাক্ত করার জন্য heartbeat প্রক্রিয়া যুক্ত করতে হবে।

Signaling Server-এর সাথে ক্লায়েন্ট একীকরণ

ক্লায়েন্ট পক্ষে, Signaling Server ব্রাউজারের WebSocket API-এর মাধ্যমে একীভূত হয়। ক্লায়েন্ট সার্ভারের সাথে সংযোগ স্থাপন করে, একটি রুমে যোগ দেওয়ার অনুরোধ পাঠায়, এবং তারপর setRemoteDescription() এবং addIceCandidate()-এর মাধ্যমে RTCPeerConnection-এ পাস করে আগত WebRTC বার্তাগুলি প্রক্রিয়া করে। ক্লায়েন্ট কোড onicecandidate ইভেন্টের মাধ্যমে এবং offer/answer তৈরি করার পরে RTCPeerConnection থেকে প্রাপ্ত নিজস্ব SDP এবং ICE প্রার্থীও সার্ভারে পাঠায়।

সিগন্যালিং-এ SDP এবং ICE-এর ভূমিকা

Signaling Server দুই ধরনের মূল মেটাডেটা প্রেরণ করে: SDP (Session Description Protocol) এবং ICE প্রার্থী। SDP মিডিয়া স্ট্রিম প্যারামিটার বর্ণনা করে — কোডেক, নমুনাকরণ হার, চ্যানেলের সংখ্যা, প্রেরণ দিক (sendrecv, sendonly, recvonly, inactive)। ICE প্রার্থীতে নেটওয়ার্ক ঠিকানা (স্থানীয়, STUN থেকে প্রাপ্ত, TURN থেকে রিলে) থাকে যার মাধ্যমে পিয়ার সংযোগের জন্য অ্যাক্সেসযোগ্য হতে পারে।

SDP একটি পাঠ্য বিন্যাসে উপস্থাপিত হয় যাতে সেশন এবং মিডিয়া বিভাগ থাকে। সেশন অংশ সাধারণ প্যারামিটার (সেশন ID, সংস্করণ, নাম) বর্ণনা করে, যখন মিডিয়া বিভাগগুলি তার কোডেক, পোর্ট এবং প্রোটোকল সহ প্রতিটি মিডিয়া স্ট্রিম (অডিও, ভিডিও, DataChannel) বর্ণনা করে। ICE প্রার্থীতে foundation (গ্রুপিং শনাক্তকারী), অগ্রাধিকার, IP ঠিকানা, পোর্ট, ধরণ (host, srflx, relay) এবং প্রোটোকল (UDP, TCP) থাকে। প্রতিটি প্রার্থীতে একটি ufrag (ব্যবহারকারীর নাম খণ্ড) বৈশিষ্ট্যও অন্তর্ভুক্ত থাকে যা এটিকে একটি নির্দিষ্ট ICE প্রক্রিয়ার সাথে সংযুক্ত করে।

• SDP Offer — সূচনাকারী তার মিডিয়া ক্ষমতার বিবরণ তৈরি করে এবং Signaling Server-এর মাধ্যমে দূরবর্তী পিয়ারে পাঠায়।
• SDP Answer — দূরবর্তী পিয়ার নিজস্ব বিবরণ দিয়ে উত্তর দেয়, মিডিয়া ফর্ম্যাট এবং কোডেক নিশ্চিত বা সামঞ্জস্য করে।
• ICE Candidate — প্রতিটি পিয়ার ICE ফ্রেমওয়ার্ক দ্বারা আবিষ্কৃত হওয়ার সাথে সাথে তার নেটওয়ার্ক প্রার্থী সিগন্যালিং সার্ভারে পাঠায়।
• Trickle ICE — একটি আধুনিক অপ্টিমাইজেশন যেখানে প্রার্থীদের সংগ্রহ সম্পূর্ণ হওয়ার পর একসাথে পাঠানোর পরিবর্তে আবিষ্কৃত হওয়ার সাথে সাথে একে একে পাঠানো হয়।
• পুনরালোচনা — যখন মিডিয়া প্যারামিটার পরিবর্তিত হয় (ভিডিও সক্ষম/অক্ষম করা, অংশগ্রহণকারী যোগ করা), পিয়াররা Signaling Server-এর মাধ্যমে নতুন SDP বিনিময় শুরু করে।

Trickle ICE WebRTC সংযোগ স্থাপনাকে উল্লেখযোগ্যভাবে গতিশীল করে। সমস্ত ICE প্রার্থীর সম্পূর্ণ সংগ্রহের জন্য অপেক্ষা করার পরিবর্তে (যা জটিল নেটওয়ার্কে 2–10 সেকেন্ড নিতে পারে), প্রতিটি প্রার্থী আবিষ্কারের সাথে সাথে Signaling Server-এ পাঠানো হয়। দূরবর্তী পিয়ার প্রার্থী গ্রহণ করে এবং ICE ফ্রেমওয়ার্কের মাধ্যমে অবিলম্বে সংযোগ পরীক্ষা শুরু করে। এটি অধিকাংশ ক্ষেত্রে সংযোগ স্থাপনের সময় 500–1500 ms পর্যন্ত কমিয়ে দেয়।