组件分享之后端组件——基于Go的可扩展实时消息服务器Centrifugo

组件分享之后端组件——基于Go的可扩展实时消息服务器Centrifugo

背景

近期正在探索前端、后端、系统端各类常用组件与工具，对其一些常见的组件进行再次整理一下，形成标准化组件专题，后续该专题将包含各类语言中的一些常用组件。

组件基本信息

• 组件：centrifugo
• 开源协议：Apache-2.0 License

内容

在日常开发时我们经常遇到需要通知其他系统或订阅某些特定事件的场景，在golang中我们可以简单的实现一个该逻辑，那有没有合适的组件方便我们来进行呢，答案肯定是有的，本节我们分享的centrifugo 是一种与语言无关的可扩展实时消息服务器，它可以作为一个单独的服务运行，并支持WebSocket、SockJS、EventSource、GRPC、HTTP-streaming多种传输类型，其他客户端可以进行订阅它，当我们需要发布消息时只需要将消息发布到centrifugo，它将会把这个事件广播给所有已经订阅的客户端，从而实现消息事件的实时传递。

以下是其特性

• Centrifugo 速度快，能够扩展到数百万个同时连接
• 与任何应用程序的简单集成——作为单独的服务工作，提供 HTTP 和 GRPC API
• 适用于流行前端环境的客户端连接器——适用于 Web 和移动开发
• 基于 Protobuf 模式的严格客户端协议
• 双向传输支持（WebSocket 和 SockJS），用于全功能通信
• 无需客户端连接器的单向传输支持 - 使用本机 API（SSE、Fetch、WebSocket、GRPC）
• 使用 JWT 或通过连接请求代理对已配置的 HTTP/GRPC 端点进行用户身份验证
• 适当的连接管理和过期控制
• 各种类型的通道：匿名、认证、私有、用户限制
• 各种类型的订阅：客户端或服务器端
• 将 WebSocket/SockJS 上的 RPC 调用转换为配置的 HTTP 或 GRPC 端点调用
• 频道的存在信息（显示频道中的所有活动客户端）
• 频道的历史信息（最后发布到频道的消息）
• 频道的加入/离开事件（客户端订阅/取消订阅）
• 在配置的保留期内重新连接之间自动恢复丢失的消息
• 内置管理网络面板
• 跨平台——适用于 Linux、macOS 和 Windows
• 准备部署（Docker、RPM/DEB 包、自动 TLS 证书、Prometheus 工具、Grafana 仪表板）
• 开源许可证

以下是其docker安装方式：

docker pull centrifugo/centrifugo
docker run --ulimit nofile=65536:65536 -v /host/dir/with/config/file:/centrifugo -p 8000:8000 centrifugo/centrifugo centrifugo -c config.json

config.json配置文件

{
  "token_hmac_secret_key": "my_secret",
  "api_key": "my_api_key",
  "admin_password": "password",
  "admin_secret": "secret",
  "admin": true
}

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

更多安装方式可以参考官方说明

本节我们就分享到这里，想要了解更多好用的golang组件请持续关注我，有迫切需要的组件也可以在文章评论中进行留言，我将根据留言进行一些特别需要的组件分享内容。

知识共享许可协议

本作品由 cn華少 采用 知识共享署名-非商业性使用 4.0 国际许可协议 进行许可。