Menggunakan Redis dan JavaScript untuk membina sistem sebut harga saham masa nyata: cara menyediakan data sebut harga masa nyata
Dengan perkembangan pesat Internet dan perubahan pesat dalam teknologi, permintaan untuk data sebut harga saham masa nyata semakin meningkat semakin mendesak. Bagi pelabur dan institusi kewangan, data pasaran yang tepat dan tepat pada masanya adalah kunci kepada membuat keputusan. Menggunakan Redis dan JavaScript, kami boleh membina sistem sebut harga saham masa nyata yang cekap.
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)); }
Dalam kod di atas, kami menggunakan pustaka klien Redis dan mencipta contoh klien Redis. Kemudian, kami memperoleh data pasaran berbilang stok melalui simulasi tatasusunan dan menggunakan perintah hset
untuk menyimpan data ke dalam jadual cincang stock
. hset
命令将数据存储到stock
哈希表中。
下面是一个示例的JavaScript代码,演示如何订阅行情数据并通过WebSocket发送实时数据:
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);
在上述代码中,我们创建了一个WebSocket服务器,监听8080端口。当WebSocket连接建立成功后,我们订阅了Redis频道stock-update
,并在有新的行情数据更新时,通过WebSocket将数据发送给客户端。
另外,我们使用setInterval
函数模拟了行情数据的更新,每隔2秒钟随机选择一支股票,修改其价格,并将更新后的数据发布到stock-update
Untuk menyediakan data pasaran masa nyata, kami boleh menggunakan mekanisme penerbitan/langganan Redis. Apabila data pasaran baharu dikemas kini, kami menerbitkan data ke saluran dan menolak data kepada pelanggan dalam masa nyata melalui WebSocket.
Berikut ialah contoh kod JavaScript yang menunjukkan cara melanggan data pasaran dan menghantar data masa nyata melalui WebSocket:
stock-update
dan menghantar data kepada pelanggan melalui WebSocket apabila data pasaran baharu dikemas kini. 🎜🎜Selain itu, kami menggunakan fungsi setInterval
untuk mensimulasikan kemas kini data pasaran, memilih stok secara rawak setiap 2 saat, mengubah suai harganya dan menerbitkan data yang dikemas kini kepada Atas ialah kandungan terperinci Menggunakan Redis dan JavaScript untuk membina sistem sebut harga saham masa nyata: cara menyediakan data sebut harga masa nyata. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!