pid

flink saas 资产推送 订单盈利 订单流转 578

roy 行情系统 k线 market 502

saas 配置更新 策略更新 502 openapi开通账户通知 503

norton metatrader模块 66

功能

1. ws 集群
2. 使用 pprof 进行性能分析 pprof 当启动http服务时，如果设置pprof开启，那么pprof会伴随启动，假设服务运行在 6060 端口,访问 http://localhost:6060/debug/pprof/ 可以查看性能分析数据参考文档 https://goframe.org/pages/viewpage.action?pageId=17203722
3. 使用 prometheus 进行指标监控 常用query
   • 5分钟内HTTP请求持续时间的50th百分位数 histogram_quantile(0.5, sum(rate(request_duration_bucket[5m])) by (le))
   • 5分钟内HTTP请求持续时间的95th百分位数 histogram_quantile(0.95, sum(rate(request_duration_bucket[5m])) by (le))
   • 5m内请求时间< =0.3秒的请求数量与总请求数量的比率 sum(rate(request_duration_bucket{le="0.3"}[5m])) by (job) / sum(rate(request_duration_count[5m])) by (job)
   • 请求url统计 request_url_total{job="ws-cluster"}
   • 请求总数 request_total{job="ws-cluster"}
   • ws实时连接数 ws_connection{job="ws-cluster"}
4. 使用 swagger 进行接口文档管理 swagger 访问路径 http://localhost:9092/swagger/index.html
5. 使用 jenkins 进行自动化构建,使用k8s进行部署
6. 使用sentry记录错误日志 地址： https://docs.sentry.io/

使用

./ws-cluster --node 200 --ws_port 8812 --http_port 8912 --queue redis --env dev

流程

1. 客户端向服务端请求建立长连接，通过 nginx或k8s负载均衡器，将请求转发到任意一个服务端

2. 业务系统将推送的数据发送到服务端，服务端将数据发送到消息队列，消息队列以广播的方式将数据发送到所有的服务端

3. 所有服务端消费消息队列中的数据,如果确定对应的用户在自己的服务端上,将数据发送到客户端

todo

1. 接口文档
2. 负载均衡router
3. 日志切割导致日志丢失的问题
4. http接口
5. redis队列读取阻塞问题
6. 设备类型上传
7. 压力测试
8. 集成openTelemetry
9. 心跳检测

客户端：

1. 连接接口：/ws/connect?pid=xxx&uid=xxx&sign=xxx

   请求参数
    pid(项目 id)
    uid(用户 id)
    type(连接类型) 1:client 2:server
    sign(签名)
   响应参数
     client_id(客户端 id)
   

2. ws消息：
   • 客户端：

     请求参数
      type: subscribe(订阅)
      tags: 标签
     

业务系统：

1. 推送接口：/ws/push 参数：

   如果指定了uids,client_ids,tags,则会将所有条件求交集
   请求参数 
    pid(项目 id) 必选
    uids(用户 id) 可选 多个用逗号分隔
    cids(客户端 id) 可选 多个用逗号分隔
    tags (标签) 可选 多个用逗号分隔
    sign(签名) 必选
    data(数据) 必选
   
    设备类型
   

交互类型

1. 连接
2. 订阅
3. 请求
   c1->router->s1->router->c1