利用Redis和JavaScript构建实时股票行情系统：如何提供实时行情数据

const redis = require('redis');
const client = redis.createClient();

// 模拟获取股票行情数据
const stockData = [
  { symbol: 'AAPL', price: 135.00, volume: 10000 },
  { symbol: 'GOOG', price: 2500.00, volume: 5000 },
  { symbol: 'AMZN', price: 3200.00, volume: 2000 },
  // 更多股票数据...
];

// 将股票行情数据存储到Redis中
for (const stock of stockData) {
  client.hset('stock', stock.symbol, JSON.stringify(stock));
}

const redis = require('redis');
const client = redis.createClient();
const WebSocket = require('ws');

const wss = new WebSocket.Server({ port: 8080 });

// 订阅行情数据更新
client.subscribe('stock-update');

// WebSocket连接建立成功
wss.on('connection', (ws) => {
  console.log('WebSocket connection established');

  // 当有新的行情数据更新时推送给客户端
  client.on('message', (channel, message) => {
    if (channel === 'stock-update') {
      ws.send(message);
    }
  });

  // 客户端断开连接
  ws.on('close', () => {
    console.log('WebSocket connection closed');
  });
});

// 模拟更新行情数据
setInterval(() => {
  const stock = stockData[Math.floor(Math.random() * stockData.length)];
  stock.price += Math.random() * 10;
  client.publish('stock-update', JSON.stringify(stock));
}, 2000);