devinggo devinggo
首页
  • 系统介绍
  • 开发环境搭建
  • 快速开始
  • 生产部署
  • 目录结构
  • MVC开发
  • 权限控制
  • 拦截器
  • 定时任务
  • 消息队列
  • websocket服务器
  • 缓存
  • module开发
  • 代码自动生成
  • 命令
前端开发
常见问题
演示
GitHub (opens new window)
首页
  • 系统介绍
  • 开发环境搭建
  • 快速开始
  • 生产部署
  • 目录结构
  • MVC开发
  • 权限控制
  • 拦截器
  • 定时任务
  • 消息队列
  • websocket服务器
  • 缓存
  • module开发
  • 代码自动生成
  • 命令
前端开发
常见问题
演示
GitHub (opens new window)
  • 目录结构
  • MVC开发
  • 权限控制
  • 拦截器
  • 定时任务
  • 消息队列
  • websocket服务器
  • 缓存
  • module开发
  • 代码自动生成
  • 命令
  • 系统开发
Kai
2025-01-07

websocket服务器

  • 基于redis
  • 核心代码位于 modules/system/pkg/websocket
  • 启动http同时也启动websocket服务 go run main.go http
  • 支持分布式部署实现基于redis 发布订阅,因此此处redis不能使用分布式部署
也可以改写成rabbitmq,kafaka等队列,将modules/system/pkg/websocket/pubsub.go里面的SubscribeMessage,PublishMessage改写即可
注意保证消息的顺序性
  • config.yaml 配置
  websocket:
    address: 106.14.10.255:6379
    pass: "redis_Q2QSYN"
    db: 7
    minIdle: 10
    maxIdle: 1000
    maxActive: 5000
    idleTimeout: 600s
    waitTimeout: 30s
    dialTimeout: 30s
    readTimeout: 30s
    writeTimeout: 30s
上次更新: 2025/01/08, 17:33:46
消息队列
缓存

← 消息队列 缓存→

Theme by Vdoing | Copyright © 2025-2025 Kai
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式