إرسال الرسائل واستقبالها

إرسال النصوص

socket.onopen = () => {
  socket.send("ping");
};

الاستقبال باستخدام onmessage

socket.onmessage = (event) => {
  console.log("Received:", event.data);
};

تغليف JSON

socket.send(JSON.stringify({ type: "chat", text: "hi" }));
socket.onmessage = (e) => {
  const msg = JSON.parse(e.data);
  console.log(msg.type, msg.text);
};

توجيه الرسائل حسب النوع

socket.onmessage = (e) => {
  const msg = JSON.parse(e.data);
  switch (msg.type) {
    case "chat": showChat(msg); break;
    case "presence": updatePresence(msg); break;
  }
};

إرسال البيانات الثنائية

const bytes = new Uint8Array([1, 2, 3, 4]);
socket.send(bytes.buffer);

استقبال البيانات الثنائية

socket.binaryType = "arraybuffer";
socket.onmessage = (e) => {
  if (e.data instanceof ArrayBuffer) {
    const view = new Uint8Array(e.data);
    console.log(view.length);
  }
};

التحكم في التدفق باستخدام bufferedAmount

if (socket.bufferedAmount < 1_000_000) {
  socket.send(payload);
}

نبضات التحقق

setInterval(() => {
  if (socket.readyState === WebSocket.OPEN) {
    socket.send(JSON.stringify({ type: "ping" }));
  }
}, 30000);

الطلب/الاستجابة عبر WebSocket

const pending = new Map();
function request(payload) {
  const id = crypto.randomUUID();
  socket.send(JSON.stringify({ id, ...payload }));
  return new Promise((res) => pending.set(id, res));
}
socket.onmessage = (e) => {
  const msg = JSON.parse(e.data);
  if (pending.has(msg.id)) { pending.get(msg.id)(msg); pending.delete(msg.id); }
};

وضع الرسائل في قائمة الانتظار قبل الفتح

const queue = [];
function safeSend(data) {
  if (socket.readyState === WebSocket.OPEN) socket.send(data);
  else queue.push(data);
}
socket.onopen = () => { queue.forEach((d) => socket.send(d)); queue.length = 0; };

التحقق من البيانات الواردة

socket.onmessage = (e) => {
  let msg;
  try { msg = JSON.parse(e.data); }
  catch { return; }
  if (typeof msg.type !== "string") return;
  handle(msg);
};

تحقق سريع

مراجعة: الإرسال والاستقبال