新项目后端采用Centrifuge实现实时消息解决方案(点击查看github),第一次接触这个框架,相关文档和demo没有WebSocket的完备,搜罗了google也没有很直观的demo可供参考,自己整理下遇到的坑,希望能帮到第一次接触该框架的朋友
我这里Centrifugo版本为:1.5,具体版本的配置请参考官方文档,以下配置不确认在其他版本的变现一致性。
// 新建Centrifuge对象,填写相应参数,注意参数类型,否则会出问题
let centrifuge = new Centrifuge({
url : ws,
user : uid + '', // 强调此处是字符串类型
timestamp : timestamp + '', // 强调此处是字符串类型
token : token
});
// 监听连接事件
centrifuge.on('connect', function(context) {
console.log(context)
});
// 监听断开连接事件
centrifuge.on('disconnect', function(context) {
console.log(context)
});
// 订阅频道
centrifuge.subscribe(`listen#${uid}`, function(mes) {
// code...
});
// 最后启动连接
centrifuge.connect();
网友评论