// 創(chuàng)建一個(gè) Shared Worker
const worker = new SharedWorker('worker.js');

// 監(jiān)聽來自 Shared Worker 的消息
worker.port.onmessage = function(event) {
  console.log('Received message from worker:', event.data);
};

// 向 Shared Worker 發(fā)送消息
worker.port.postMessage('Hello from main page!');

// 監(jiān)聽來自主頁(yè)面的消息
self.onconnect = function(event) {
  const port = event.ports[0];
  
  // 監(jiān)聽來自主頁(yè)面的消息
  port.onmessage = function(event) {
    console.log('Received message from main page:', event.data);
    
    // 向主頁(yè)面發(fā)送消息
    port.postMessage('Hello from shared worker!');
  };
};

// 打開或創(chuàng)建 IndexedDB 數(shù)據(jù)庫(kù)
const request = indexedDB.open('messageDatabase', 1);

request.onupgradeneeded = function(event) {
  const db = event.target.result;
  
  // 創(chuàng)建一個(gè)對(duì)象存儲(chǔ)空間用于存儲(chǔ)消息
  db.createObjectStore('messages', { keyPath: 'id', autoIncrement: true });
};

request.onsuccess = function(event) {
  const db = event.target.result;
  
  // 向數(shù)據(jù)庫(kù)中添加一條新消息
  const transaction = db.transaction(['messages'], 'readwrite');
  const objectStore = transaction.objectStore('messages');
  
  const message = { content: 'Hello from sender!' };
  
  objectStore.add(message);
  
  transaction.oncomplete = function() {
    console.log('Message sent successfully!');
    
    // 關(guān)閉數(shù)據(jù)庫(kù)連接
    db.close();
  };
};

request.onerror = function(event) {
  console.error('Error opening database:', event.target.error);
};

// 打開或創(chuàng)建 IndexedDB 數(shù)據(jù)庫(kù)
const request = indexedDB.open('messageDatabase', 1);

request.onsuccess = function(event) {
  const db = event.target.result;
  
  // 創(chuàng)建一個(gè)定時(shí)器，每隔一段時(shí)間輪詢數(shù)據(jù)庫(kù)中的消息
  setInterval(function() {
    // 創(chuàng)建一個(gè)事務(wù)
    const transaction = db.transaction(['messages'], 'readwrite');
    const objectStore = transaction.objectStore('messages');
    
    // 獲取存儲(chǔ)在對(duì)象存儲(chǔ)中的所有消息
    const request = objectStore.getAll();
    
    request.onsuccess = function(event) {
      const messages = event.target.result;
      
      // 處理消息
      messages.forEach(function(message) {
        console.log('Received message:', message.content);
        
        // 在處理完消息后，刪除該消息
        objectStore.delete(message.id);
      });
      
      // 關(guān)閉事務(wù)
      transaction.oncomplete = function() {
        console.log('Messages processed successfully!');
      };
    };
    
    request.onerror = function(event) {
      console.error('Error retrieving messages:', event.target.error);
      
      // 關(guān)閉事務(wù)
      transaction.abort();
    };
  }, 1000);
};

request.onerror = function(event) {
  console.error('Error opening database:', event.target.error);
};

// 設(shè)置一個(gè) Cookie，將消息存儲(chǔ)在 Cookie 中
document.cookie = 'message=Hello from sender!';

// 創(chuàng)建一個(gè)定時(shí)器，每隔一段時(shí)間輪詢 Cookie 中的數(shù)據(jù)
setInterval(function () {
  // 獲取存儲(chǔ)在 Cookie 中的消息
  const cookies = document.cookie.split(';')
  let message = ''

  for (let i = 0; i < cookies.length; i++) {
    const cookie = cookies[i].trim()

    if (cookie.startsWith('message=')) {
      message = cookie.substring('message='.length)
      break
    }
  }

  // 處理消息
  if (message) {
    console.log('Received message:', decodeURIComponent(message))

    // 清除 Cookie
    document.cookie = 'message=; expires=Thu, 01 Jan 1970 00:00:00 UTC; path=/;'
  }
}, 1000)

// 創(chuàng)建一個(gè) WebSocket 連接
const socket = new WebSocket('ws://example.com');
// 監(jiān)聽連接成功的事件
socket.onopen = function() {
 // 發(fā)送消息到服務(wù)器
  socket.send('Hello from sender!');
};

// 創(chuàng)建一個(gè) WebSocket 連接
const socket = new WebSocket('ws://example.com');
// 監(jiān)聽來自服務(wù)器的消息
socket.onmessage = function(event) {
  console.log('Received message:', event.data);
};

// 創(chuàng)建一個(gè) WebSocket 服務(wù)器
const WebSocketServer = require('ws').Server
const wss = new WebSocketServer({ port: 8080 })
// 監(jiān)聽來自客戶端的連接
wss.on('connection', function (socket) {
  // 監(jiān)聽來自客戶端的消息
  socket.on('message', function (message) {
    console.log('Received message:', message)

    // 向所有客戶端發(fā)送消息
    wss.clients.forEach(function (client) {
      client.send(message)
    })
  })
})