온라인 퀴즈 시험점수 실시간 푸시 및 알림 기능 구현 방법

// 创建WebSocket连接
const socket = new WebSocket('wss://example.com/ws');

// 监听连接打开事件
socket.onopen = function(event) {
  console.log('WebSocket连接已打开');
};

// 监听收到消息事件
socket.onmessage = function(event) {
  const message = JSON.parse(event.data);
  console.log('收到消息:', message);
  // 处理收到的消息，例如更新答题成绩
};

// 监听连接关闭事件
socket.onclose = function(event) {
  console.log('WebSocket连接已关闭');
};

// 发送消息
function sendMessage(message) {
  socket.send(JSON.stringify(message));
}

// 导入WebSocket模块
const WebSocket = require('ws');

// 创建WebSocket服务器
const wss = new WebSocket.Server({ port: 8080 });

// 监听连接事件
wss.on('connection', function(socket) {
  console.log('客户端已连接');

  // 发送消息
  function sendMessage(message) {
    socket.send(JSON.stringify(message));
  }

  // 监听收到消息事件
  socket.on('message', function(message) {
    console.log('收到消息:', message);
    // 处理收到的消息，例如计算得分和发送得分信息
    const score = calculateScore(message);
    sendMessage({ type: 'score', score: score });
  });

  // 监听连接关闭事件
  socket.on('close', function() {
    console.log('客户端已断开连接');
  });
});

// 创建WebSocket连接
const socket = new WebSocket('wss://example.com/ws');

// 监听连接打开事件
socket.onopen = function(event) {
  console.log('WebSocket连接已打开');
};

// 监听收到消息事件
socket.onmessage = function(event) {
  const message = JSON.parse(event.data);
  if (message.type === 'score') {
    // 收到答题成绩
    console.log('得分:', message.score);
    // 显示得分信息，例如更新页面上的得分
  }
};

// 监听连接关闭事件
socket.onclose = function(event) {
  console.log('WebSocket连接已关闭');
};

// 提交答案并发送消息
function submitAnswer(answer) {
  const message = { type: 'answer', answer: answer };
  socket.send(JSON.stringify(message));
}