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

组件分享之后端组件——基于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/centrifugodocker 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组件请持续关注我，有迫切需要的组件也可以在文章评论中进行留言，我将根据留言进行一些特别需要的组件分享内容。

88x31.png

​​知识共享许可协议​​

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

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。