Centrifugo简单试用

2019/04/09 20:14
阅读数 292

今天尝试用 centrifugo 来做一个在聊天室,以前用workerman做过,相对来说 workerman的配置就显得复杂多了,需要自己搭建PHP环境,

而 centrifugo 就清爽多了,官网下载二进制单文件直接运行,得益于go语言,centrifugo 的性能应该是大于workerman的,

但也得提醒一下,从github上看centrifugo是 2018年底才开始的,目前还在快速更新中,稳定性有一定风险。

测试系统: Debian 9

下载二进制文件:

https://github.com/centrifugal/centrifugo/releases

添加执行权限

chmod a+x centrifugo

生成配置文件 config.json文件

./centrifugo genconfig

内容大致这样的

{
  "secret": "16bfd798-4f9f-4362-98e8-d88cb4997db2",
  "admin_password": "18d34296-f9c2-4c65-a04a-118cbe020481",
  "admin_secret": "e6adffc9-e54f-41ef-a487-3b172ea962db",
  "api_key": "3fe2e20a-af48-48d1-9aab-51ae88d92c5e"
}

启动 centrifugo

./centrifugo  -c config.json

前台采用 centrifugo的js客户端,下载地址: https://github.com/centrifugal/centrifuge-js

通过文档得知,要链接到centrifugo服务器,需要一个jwt的token,打开 https://jwt.io/,准本生成一个测试用的jwtToken

 

PAYLOAD框框里面去掉 name和iat,只保留sub一项,不然连不上,我猜测是centrifugo 不支持
(文档里面确实写了支持exp,info的,实测不行)
VERIFY SIGNATURE 框框里面补充config.json文件里面的secret字段值
这个时候 左边 Encoded框框 里面的一串密文就是我们要用到的

嫌麻烦可以直接使用我生成好的两个(使用的前提是你的config.js secret字段要跟我的一样):

eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiIxIn0.GvmVuP_7yADlqHk6fB7Tcq2V5EGY98PQw3EkX3DbBmQ
eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiIyIn0.ZOIIW5dReDRHEWkBakTJn0-cn0JFL6MIcrkOtElevRk

为了接下来的测试方便,我先配置一下config文件的常用选项:

{
  "admin": true, # 开启管理员后台
  "posrt": 8000, # 端口
  "debug": true, # 开启debug模式
  "presence": true, # 开启系统状态信息
  "history_size": 100, # 历史消息保存条数,0不保存
  "history_lifetime": 600, # 历史消息保存秒数 0 保存
  "secret": "16bfd798-4f9f-4362-98e8-d88cb4997db2", 
  "admin_password": "18d34296-f9c2-4c65-a04a-118cbe020481",
  "admin_secret": "e6adffc9-e54f-41ef-a487-3b172ea962db",
  "api_key": "3fe2e20a-af48-48d1-9aab-51ae88d92c5e",
  "publish": true # 允许客户端直接发布消息到centrifugo通道中,不经过我们自己的服务器,方便没有后端的情况下测试
}

测试的html文件是这样的:

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <meta http-equiv="X-UA-Compatible" content="ie=edge">
    <title>socktest</title>
    <script src="./centrifuge.min.js"></script>
</head>
<body>
    <button onclick="init()">连接</button>
    <button onclick="closeit()">关闭连接</button>
    <button onclick="publish()">发送消息</button>
    <button onclick="subscribe()">订阅频道</button>
    <button onclick="unsubscribe()">取消订阅</button>
    <button onclick="history()">拉取历史消息</button>
</body>
</html>
<script>
// js 代码
</script>

js代码:

function init() {
        // 初始化 centrifugo 客户端
        window.centrifuge = new Centrifuge('ws://localhost:8000/connection/websocket');
        // 设置 token
        centrifuge.setToken("eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiIyIn0.ZOIIW5dReDRHEWkBakTJn0-cn0JFL6MIcrkOtElevRk");
        // 监听连接事件
        centrifuge.on('connect',function(context) {
            console.log(context)
        })
        // 监听断开连接事件
        centrifuge.on('disconnect', function(context) {
            console.log(context)
        });
        // 启动连接
        centrifuge.connect();
    }
    // 发布消息到通道 
    function publish () {
        centrifuge.publish("news", {"input": "hello-publish"}).then(function(res) {
            console.log(res);
        }, function(err) {
            console.log('publish error', err);
        });
    }
    // 订阅频道
    function subscribe() {
        // 监听频道内的消息
        var callbacks = {
            "publish": function(message) {
                console.log(message);
            },
            "join": function(message) {
                console.log(message);
            },
            "leave": function(message) {
                console.log(message);
            },
            "subscribe": function(context) {
                console.log(context);
            },
            "error": function(errContext) {
                console.log(err);
            },
            "unsubscribe": function(context) {
                console.log(context);
            }
        }
        window.subscription = centrifuge.subscribe("news", callbacks);
    }
    // 取消订阅
    function unsubscribe() {
        subscription.unsubscribe();
        subscription.removeAllListeners();
    }
    // 查看历史消息
    function history() {
        subscription.history().then(function(message) {
            console.log(message);
        }, function(err) {
            console.log(err);
        });
    }
    // 关闭连接
    function closeit() {
        centrifuge.disconnect();
    }

测试流程,开两个窗口,两个窗口的token不一样,打开调试工具的日志界面,

 

第一个窗口先点击连接,然后订阅频道,第二个窗口同样,

这个时候在第一个窗口点击发送消息,看另外一个窗口有没有接收到消息

centrifugo 提供了一个简易的后台面板:http://www.testserver.com:8000

测试过程中遇到一个问题:如果开启历史消息,开两个客户端测试时发现有个客户端无法发送消息,提示insufficient state(状态信息不足)

关闭历史消息的选项就没有问题

 

展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部