以下是一个简单的示例代码,实现了客户端使用WebSocket和Redis进行消息订阅,并在页面中显示收到的消息。
首先,在HTML页面中添加如下代码来连接WebSocket:
var websocket = new WebSocket("ws://localhost:8080/websocket");
websocket.onopen = function(event) {
console.log("连接成功!");
}
websocket.onmessage = function(event) {
console.log("收到消息:" + event.data);
// 将收到的消息显示在页面上
var div = document.createElement('div');
div.innerHTML = event.data;
document.getElementById('messages').appendChild(div);
}
websocket.onclose = function(event) {
console.log("连接断开!");
}
然后,在JavaScript代码中订阅Redis频道:
var redis = new Redis();
redis.subscribe('monitor', function(err, count) {
if (err) {
console.error(err);
return;
}
console.log('已订阅 ' + count + ' 个频道');
});
redis.on('message', function(channel, message) {
console.log('收到消息:' + message);
});
注意,这里使用了一个名为Redis的第三方库,可以通过npm安装并引入该库。同时需要确保客户端与Redis服务器在同一网络环境下。