地址

 github: https://github.com/centrifugal/centrifugo
 官网地址: https://centrifugal.dev

什么是Centrifugo

Centrifugo 是一种与语言无关的可扩展实时消息传递服务器。

Centrifugo 与使用任何编程语言编写的应用程序后端协同工作。它作为单独的服务运行，并与通过多种支持的传输类型（WebSocket、SockJS、EventSource、GRPC、HTTP 流）建立的应用程序客户端保持持久连接。当您需要实时向客户端发送事件时，您可以将其发布到 Centrifugo 服务器 API——然后 Centrifugo 将事件广播给所有对此事件感兴趣的连接客户端（订阅事件频道的客户端）。换句话说 – Centrifugo 是一个面向用户的 PUB/SUB 服务器。

安装

## 安装地址: https://centrifugal.dev/docs/getting-started/installation

创建config.json配置

{
  "token_hmac_secret_key": "46b38493-147e-4e3f-86e0-dc5ec54f5133",
  "admin_password": "123456",
  "admin_secret": "583bc4b7-0fa5-4c4a-8566-16d3ce4ad401",
  "api_key": "aaaf202f-b5f8-4b34-bf88-f6c03a1ecda6",
  "admin": true,
 "allowed_origins": [
    "http://192.168.4.141:5500",
    "http://192.168.4.63:5500",
    "http://192.168.3.197:8301",
    "http://192.168.3.198:8301"
  ] 
}

创建docker-compose.yml

centrifugo:
  container_name: centrifugo
  image: centrifugo/centrifugo:v3
  volumes:
    - ./config.json:/centrifugo/config.json
  command: centrifugo -c config.json
  ports:
    - 8000:8000
  ulimits:
    nofile:
      soft: 65535
      hard: 65535

运行

docker-compose up

调整配置

## 进入doker容器中
docker exec -it  容器ID  /bin/sh
cd ..
cd /usr/local/bin/
vi vi config.json

## 调整config.json
{
  "token_hmac_secret_key": "46b38493-147e-4e3f-86e0-dc5ec54f5133",
  "admin_password": "123456",
  "admin_secret": "583bc4b7-0fa5-4c4a-8566-16d3ce4ad401",
  "api_key": "aaaf202f-b5f8-4b34-bf88-f6c03a1ecda6",
  "admin": true,
 "allowed_origins": [
    "http://192.168.4.141:5500",
    "http://192.168.4.63:5500",
    "http://192.168.3.197:8301",
    "http://192.168.3.198:8301"
  ] 
}

## 重启dokcer
docker restart 容器id

## 测试地址
http://192.168.3.169:8000
密码: 123456

html页面脚本文件

$(function () {
    var centrifuge_api_url = "ws://192.168.3.169/connection/websocket";
    var centrifuge_api_token = "token";

    function Conn() {
        const centrifuge = new Centrifuge(centrifuge_api_url);
        centrifuge.setToken(centrifuge_api_token);

        centrifuge.on('connect', function (obj) {
            console.log("链接成功...", obj);
        });

        centrifuge.on('disconnect', function (obj) {
            console.log("断开链接...", obj);
        });

        centrifuge.subscribe("mango-number", function (obj) {
            console.log(obj);
        });
        centrifuge.connect();
    }
    Conn();
})