zoukankan      html  css  js  c++  java
  • MQTT&Mosquitto 推送服务

    1.目标:测试Mosquitto使用MQTT协议发消息的相关性能指标,包含发送速度,并发负载能力,资源占用,消息到达率。

    2.MQTT协议简介:

      1).建立长连接。客户端发起请求和服务端建立长连接,建立成功后,服务端会返回ACK(CONNACK)

      2).客户端订阅:客户端发起订阅,订阅成功后,服务端会返回ACK(SUBACK)

      3).发消息:发布者会给服务端发消息,服务端在把消息给合适的客户端。

                       Qos=0(服务质量):客户端消息收到后,不会发出ACK给服务端(PUBACK)。

           Qos =1:服务端会发ACK给发布者,客户端收到消息后会发ACK给服务端。

      4).取消订阅:客户端发起取消订阅,服务端返回ACK(UNSUBACK)  

      5)Pingreq&Pingresp:客户端和服务端会保持心跳。

    3.存在问题:

      1. 如何模拟出40W的用户

      2. 如何长连接,订阅,发消息,取消订阅,Pingreq行为如何实现。

    4. python开源库 Mosquitto.py,解决所有问题

      1. 模拟40W用户

        a)可以使用虚拟机和Mosquitto.py实现,具体为:一般一台虚拟机最多是6W+的模拟数据(需要修改句柄数,我使用5W),方法是Client_id可以简单的做出5W个来,然后调用Mosquitto里面的connect方法,建立长连接。准备8台虚拟机就可以实现40W客户端的模拟

      2.行为的模拟

        a)订阅:Mosquitto.subscribe /  发消息:Mosquitto.publish  /  取消订阅:Mosquitto.unsubscribe。 简单一句话 Mosquitto库实现所有的行为.

    5. 指标:发送速度,到达率,并发负载,资源占用。

      a. 发送速度:服务端日志记录,分析解决

      b. 到达率: 1.客户端记录下收到消息,分析计算。2.计算服务端收到的PUBACK(客户端收到消息返回的ACK),进行计算

      c. 并发负载:5W 用户不断增加,注意观察服务端的负载情况。

      e.资源占用:其实主要是cpu/mem/带宽:cpu多核的话需要观察top命令下的_id字段,  mem可以观察free -h命令的剩余mem, 带宽可以使用mpstat进行观察

    6. 可以遇见问题:

      a. 模拟客户端的虚拟机需要修改句柄数才能支持5W的客户端模拟数量

      b. 要先吃透MQTT协议的流程,吃透了进行测试会非常的方便

      c. Clear session,设置为true则不为客户端保留休息,设置为false保留消息。其实就是客户端离线后在连接上可以收到之前推出的消息。

  • 相关阅读:
    Swift学习一
    Swift开发学习(一):初始篇
    objc_msgSend arm64 崩溃问题
    更改navigationController push和pop界面切换动画
    iOS 改变UITextField中光标颜色
    IOS Core Animation Advanced Techniques的学习笔记(五)
    使用CAShapeLayer与UIBezierPath画出想要的图形
    亮相SIGGRAPH 太极拳三维教学App制作揭秘
    MySQL优化——索引
    求职前一个月复习知识
  • 原文地址:https://www.cnblogs.com/chengdu-jackwu/p/4530173.html
Copyright © 2011-2022 走看看