AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

QT应用编程: 编写MQTT客户端登录OnetNet服务器完成主题订阅与发布

2021-12-19 719
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： QT应用编程: 编写MQTT客户端登录OnetNet服务器完成主题订阅与发布

一、环境介绍

QT版本: 5.12.6


编译器:  MinGW 32


MQTT协议: 参照3.1.1版本文档自己编写 (不是使用QT的qmqtt)


功能介绍:  使用QT编写MQTT客户端（根据mqtt官方文档3.1.1，自己实现过程代码，没有使用其他库），登录OneNet物联网服务器，完成主题订阅、发布等操作。


项目完整源码下载地址: https://download.csdn.net/download/xiaolong1126626497/18725462


软件运行效果图: （2021/06/01 21:30 更新，修复已知BUG）  新加入:  心跳包、域名检测功能

image.png

image.png

image.png

二、在OneNet上创建产品

地址：https://open.iot.10086.cn/

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

image.png

手机APP下载地址：https://download.csdn.net/download/xiaolong1126626497/18697132

image.pngimage.png

三、OneNet的MQTT介绍

onenet服务器的地址:  https://open.iot.10086.cn/doc/mqtt/book/device-develop/manual.html

image.png

设备接入说明: https://open.iot.10086.cn/doc/mqtt/book/get-start/connect.html

image.png

主题订阅与发布的格式说明: https://open.iot.10086.cn/doc/mqtt/book/device-develop/protocol.html

image.png

订阅主题的格式：

$sys/{pid}/{device-name}/dp/post/json/accepted  订阅设备数据点上报成功的消息
$sys/{pid}/{device-name}/dp/post/json/rejected  订阅设备数据点上报失败的消息
$sys/{pid}/{device-name}/dp/post/json/+ 订阅设备数据点上报结果
$sys/{pid}/{device-name}/cmd/request/+  订阅设备所有命令消息
$sys/{pid}/{device-name}/cmd/response/+/+ 订阅设备所有命令应答结果消息
$sys/{pid}/{device-name}/cmd/#  订阅设备所有命令相关消息
$sys/{pid}/{device-name}/#  订阅设备所有相关消息
说明:  参数里的pid就是产品的ID(注意是产品ID不是设备ID)，device-name 就是产品的名称。
如果要订阅设备所有相关信息，就可以这样写：
$sys/427519/GreeningManagement/#

主题发布(数据上传)： https://open.iot.10086.cn/doc/mqtt/book/device-develop/topics/dp-topics.html

image.png

设备可以通过向系统固定 topic：$sys/{pid}/{device-name}/dp/post/json 发送数据点存储消息，消息中payload字段数据内容仅支持json格式.
发布主题的格式: $sys/427519/GreeningManagement/dp/post/json
如果同时上传温度、湿度、光照度的消息就可以这样写:
{"id":666,"dp":{"temperature":[{"v":21}],"humidity":[{"v":40}],"Light":[{"v":100}]}}
在代码里写上面这串数据时，里面的"要记得转义。
就应该这样写：
{\"id\":666,\"dp\":{\"temperature\":[{\"v\":21}],\"humidity\":[{\"v\":40}],\"Light\":[{\"v\":100}]}}

安全鉴权（就是生成MQTT登录的密码、非常重要）： https://open.iot.10086.cn/doc/mqtt/book/manual/auth/token.html

image.png

下载密码生成工具: https://open.iot.10086.cn/doc/mqtt/book/manual/auth/tool.html

image.png

生成登录面示例：

image.png

参数说明：


res选项参数的格式： products/{产品ID}/devices/{设备名称}

et是设置token过期时间：算出1970-1-1到你想要设置的到期时间，单位是秒，填入即可。

key的参数格式： 就是设备创建之后，在设备详情页的key声明。


根据上面工具获取、得到的MQTT协议登录密码就是下面这个：

version=2018-10-31&res=products%2F427519%2Fdevices%2FGreeningManagement&et=1631378104&method=md5&sign=xz3tM8A31jIrkQ3S1mOcqQ%3D%3D

计算到期时间的代码：(Linux)

#include <stdio.h>
#include <time.h>
#include <time.h>
int main()
{
    time_t time_sec;
    time_sec=time(NULL);  //当前的秒单位时间--UTC时间
  printf("当前时间(秒):%ld\n",time_sec);
  printf("加120天的时间(秒):%ld\n",time_sec+120*24*60*60);
  return 0;
}
wbyq@wbyq:~$ ./a.out 
当前时间(秒):1621010104
加120天的时间(秒):1631378104

四、QT实现mqtt协议核心代码

image.png

4.1 mqtt.cpp

#include "mqtt.h"
//连接成功服务器回应 20 02 00 00
//客户端主动断开连接 e0 00
const quint8 parket_connetAck[] = {0x20,0x02,0x00,0x00};
const quint8 parket_disconnet[] = {0xe0,0x00};
const quint8 parket_heart[] = {0xc0,0x00};
const quint8 parket_heart_reply[] = {0xc0,0x00};
const quint8 parket_subAck[] = {0x90,0x03};
MQTT_WorkClass::~MQTT_WorkClass()
{
    qDebug()<<"析构函数---TCP";
}
void MQTT_WorkClass::run()
{
    qDebug()<<"执行:run";
    if(timer)
    {
        delete  timer;
        timer=nullptr;
    }
    timer = new QTimer(this);
    connect(timer, SIGNAL(timeout()), this, SLOT(EndEvenLoop()));
    socket_type=0;
    //连接到服务器
    ConnectMqttServer(m_ip,m_port);
    //开始事件循环
    StartEvenLoop();
    //初始化mqtt协议
    MQTT_Init();
    //连接mqtt协议
    if(MQTT_Connect(m_MQTT_ClientID.toUtf8().data(),m_MQTT_UserName.toUtf8().data(),m_MQTT_PassWord.toUtf8().data()))
    {
        LogSend("MQTT服务器登录失败.\n");
    }
    else
    {
        LogSend("MQTT服务器登录成功.\n");
    }
}
void MQTT_WorkClass::MQTT_Init(void)
{
    //缓冲区赋值
  mqtt_rxbuf = _mqtt_rxbuf;
    mqtt_rxlen = sizeof(_mqtt_rxbuf);
  mqtt_txbuf = _mqtt_txbuf;
    mqtt_txlen = sizeof(_mqtt_txbuf);
  memset(mqtt_rxbuf,0,mqtt_rxlen);
  memset(mqtt_txbuf,0,mqtt_txlen);
}
/*
函数功能: 登录服务器
函数返回值: 0表示成功 1表示失败
*/
quint8 MQTT_WorkClass::MQTT_Connect(char *ClientID,char *Username,char *Password)
{
    quint8 i,j;
    int ClientIDLen = strlen(ClientID);
    int UsernameLen = strlen(Username);
    int PasswordLen = strlen(Password);
    int DataLen;
  mqtt_txlen=0;
  //可变报头+Payload  每个字段包含两个字节的长度标识
    DataLen = 10 + (ClientIDLen+2) + (UsernameLen+2) + (PasswordLen+2);
  //固定报头
  //控制报文类型
    mqtt_txbuf[mqtt_txlen++] = 0x10;    //MQTT Message Type CONNECT
  //剩余长度(不包括固定头部)
  do
  {
        quint8 encodedByte = DataLen % 128;
    DataLen = DataLen / 128;
    // if there are more data to encode, set the top bit of this byte
    if ( DataLen > 0 )
      encodedByte = encodedByte | 128;
    mqtt_txbuf[mqtt_txlen++] = encodedByte;
  }while ( DataLen > 0 );
  //可变报头
  //协议名
    mqtt_txbuf[mqtt_txlen++] = 0;         // Protocol Name Length MSB    
    mqtt_txbuf[mqtt_txlen++] = 4;           // Protocol Name Length LSB    
    mqtt_txbuf[mqtt_txlen++] = 'M';         // ASCII Code for M    
    mqtt_txbuf[mqtt_txlen++] = 'Q';         // ASCII Code for Q    
    mqtt_txbuf[mqtt_txlen++] = 'T';         // ASCII Code for T    
    mqtt_txbuf[mqtt_txlen++] = 'T';         // ASCII Code for T    
  //协议级别
    mqtt_txbuf[mqtt_txlen++] = 4;           // MQTT Protocol version = 4   对于 3.1.1 版协议，协议级别字段的值是 4(0x04)   
  //连接标志
    mqtt_txbuf[mqtt_txlen++] = 0xc2;          // conn flags 
    mqtt_txbuf[mqtt_txlen++] = 0;           // Keep-alive Time Length MSB    
    mqtt_txbuf[mqtt_txlen++] = 100;         // Keep-alive Time Length LSB  100S心跳包    保活时间
    mqtt_txbuf[mqtt_txlen++] = BYTE1(ClientIDLen);// Client ID length MSB    
    mqtt_txbuf[mqtt_txlen++] = BYTE0(ClientIDLen);// Client ID length LSB   
  memcpy(&mqtt_txbuf[mqtt_txlen],ClientID,ClientIDLen);
    mqtt_txlen += ClientIDLen;
    if(UsernameLen > 0)
    {   
        mqtt_txbuf[mqtt_txlen++] = BYTE1(UsernameLen);    //username length MSB    
        mqtt_txbuf[mqtt_txlen++] = BYTE0(UsernameLen);      //username length LSB    
    memcpy(&mqtt_txbuf[mqtt_txlen],Username,UsernameLen);
        mqtt_txlen += UsernameLen;
    }
    if(PasswordLen > 0)
    {    
        mqtt_txbuf[mqtt_txlen++] = BYTE1(PasswordLen);    //password length MSB    
        mqtt_txbuf[mqtt_txlen++] = BYTE0(PasswordLen);      //password length LSB  
    memcpy(&mqtt_txbuf[mqtt_txlen],Password,PasswordLen);
        mqtt_txlen += PasswordLen; 
    }    
    //清空数据
    memset(mqtt_rxbuf,0,mqtt_rxlen);
    ReadData.clear();
    MQTT_SendBuf(mqtt_txbuf,mqtt_txlen);
    //开始事件循环
    StartEvenLoop();
    if(ReadData.length()==0)
    {
        //开始事件循环
        StartEvenLoop();
    }
    memcpy((char *)mqtt_rxbuf,ReadData.data(),ReadData.length());
    //CONNECT
    if(mqtt_rxbuf[0]==parket_connetAck[0] && mqtt_rxbuf[1]==parket_connetAck[1]) //连接成功
    {
        return 0;//连接成功
    }
  return 1;
}
/*
函数功能: MQTT订阅/取消订阅数据打包函数
函数参数:
    topic       主题   
    qos         消息等级 0:最多分发一次  1: 至少分发一次  2: 仅分发一次
    whether     订阅/取消订阅请求包 (1表示订阅,0表示取消订阅)
返回值: 0表示成功 1表示失败
*/
quint8 MQTT_WorkClass::MQTT_SubscribeTopic(char *topic,quint8 qos,quint8 whether)
{    
    quint8 i,j;
  mqtt_txlen=0;
    int topiclen = strlen(topic);
  int DataLen = 2 + (topiclen+2) + (whether?1:0);//可变报头的长度（2字节）加上有效载荷的长度
  //固定报头
  //控制报文类型
    if(whether)mqtt_txbuf[mqtt_txlen++] = 0x82; //消息类型和标志订阅
    else  mqtt_txbuf[mqtt_txlen++] = 0xA2;    //取消订阅
  //剩余长度
  do
  {
        quint8 encodedByte = DataLen % 128;
    DataLen = DataLen / 128;
    // if there are more data to encode, set the top bit of this byte
    if ( DataLen > 0 )
      encodedByte = encodedByte | 128;
    mqtt_txbuf[mqtt_txlen++] = encodedByte;
  }while ( DataLen > 0 ); 
  //可变报头
    mqtt_txbuf[mqtt_txlen++] = 0;     //消息标识符 MSB
    mqtt_txbuf[mqtt_txlen++] = 0x0A;        //消息标识符 LSB
  //有效载荷
    mqtt_txbuf[mqtt_txlen++] = BYTE1(topiclen);//主题长度 MSB
    mqtt_txbuf[mqtt_txlen++] = BYTE0(topiclen);//主题长度 LSB   
  memcpy(&mqtt_txbuf[mqtt_txlen],topic,topiclen);
    mqtt_txlen += topiclen;
    if(whether)
    {
       mqtt_txbuf[mqtt_txlen++] = qos;//QoS级别
    }
    ReadData.clear();
    MQTT_SendBuf(mqtt_txbuf,mqtt_txlen);
    //开始事件循环
    StartEvenLoop();
    if(ReadData.length()==0)
    {
        //开始事件循环
        StartEvenLoop();
    }
    memcpy((char *)mqtt_rxbuf,ReadData.data(),ReadData.length());
    if(mqtt_rxbuf[0]==parket_subAck[0] && mqtt_rxbuf[1]==parket_subAck[1]) //订阅成功
    {
        return 0;//订阅成功
    }
  return 1; //失败
}
//MQTT发布数据打包函数
//topic   主题 
//message 消息
//qos     消息等级 
quint8 MQTT_WorkClass::MQTT_PublishData(char *topic, char *message, quint8 qos)
{  
    int topicLength = strlen(topic);    
    int messageLength = strlen(message);     
    static quint16 id=0;
  int DataLen;
  mqtt_txlen=0;
  //有效载荷的长度这样计算：用固定报头中的剩余长度字段的值减去可变报头的长度
  //QOS为0时没有标识符
  //数据长度             主题名   报文标识符   有效载荷
    if(qos) DataLen = (2+topicLength) + 2 + messageLength;       
    else  DataLen = (2+topicLength) + messageLength;   
    //固定报头
  //控制报文类型
    mqtt_txbuf[mqtt_txlen++] = 0x30;    // MQTT Message Type PUBLISH  
  //剩余长度
  do
  {
        quint8 encodedByte = DataLen % 128;
    DataLen = DataLen / 128;
    // if there are more data to encode, set the top bit of this byte
    if ( DataLen > 0 )
      encodedByte = encodedByte | 128;
    mqtt_txbuf[mqtt_txlen++] = encodedByte;
  }while ( DataLen > 0 ); 
    mqtt_txbuf[mqtt_txlen++] = BYTE1(topicLength);//主题长度MSB
    mqtt_txbuf[mqtt_txlen++] = BYTE0(topicLength);//主题长度LSB 
  memcpy(&mqtt_txbuf[mqtt_txlen],topic,topicLength);//拷贝主题
    mqtt_txlen += topicLength;
  //报文标识符
    if(qos)
    {
        mqtt_txbuf[mqtt_txlen++] = BYTE1(id);
        mqtt_txbuf[mqtt_txlen++] = BYTE0(id);
        id++;
    }
  memcpy(&mqtt_txbuf[mqtt_txlen],message,messageLength);
    mqtt_txlen += messageLength;
    ReadData.clear();
  MQTT_SendBuf(mqtt_txbuf,mqtt_txlen);
    //开始事件循环
    StartEvenLoop();
    return mqtt_txlen;
}
void MQTT_WorkClass::MQTT_SentHeart(void)
{
    MQTT_SendBuf((quint8 *)parket_heart,sizeof(parket_heart));
}
void MQTT_WorkClass::MQTT_Disconnect(void)
{
    MQTT_SendBuf((quint8 *)parket_disconnet,sizeof(parket_disconnet));
}
void MQTT_WorkClass::MQTT_SendBuf(quint8 *buf,quint16 len)
{
    if(socket_type)
    {
//        qDebug()<<"len:"<<len;
//        for(int i=0;i<len;i++)
//        {
//            qDebug("%#x ",buf[i]);
//        }
       LocalTcpClientSocket->write((const char *)buf,len);
    }
} 
//客户端模式：创建客户端
void MQTT_WorkClass::ConnectMqttServer(QString ip,quint16 port)
{
    if(LocalTcpClientSocket)
    {
        LocalTcpClientSocket->close();
        delete  LocalTcpClientSocket;
        LocalTcpClientSocket=nullptr;
    }
    /*1. 创建本地客户端TCP套接字*/
    LocalTcpClientSocket = new QTcpSocket;
    /*2. 设置服务器IP地址*/
    QHostAddress FarServerAddr(ip);
    /*3. 连接客户端的信号槽*/
    connect(LocalTcpClientSocket,SIGNAL(connected()),this,SLOT(LocalTcpClientConnectedSlot()));
    connect(LocalTcpClientSocket,SIGNAL(disconnected()),this,SLOT(LocalTcpClientDisconnectedSlot()));
    connect(LocalTcpClientSocket,SIGNAL(readyRead()),this,SLOT(LocalTcpClientReadDtatSlot()));
    connect(LocalTcpClientSocket,SIGNAL(bytesWritten(qint64)),this,SLOT(LocalTcpClientBytesWrittenSlot(qint64)));
    /*4. 尝试连接服务器主机*/
    LocalTcpClientSocket->connectToHost(FarServerAddr,port);
}
void MQTT_WorkClass::Set_MQTT_Addr(QString ip,quint16 port,QString MQTT_ClientID,QString MQTT_UserName,QString MQTT_PassWord)
{
    m_ip=ip;
    m_port=port;
    m_MQTT_ClientID=MQTT_ClientID;
    m_MQTT_UserName=MQTT_UserName;
    m_MQTT_PassWord=MQTT_PassWord;
}
//客户端模式：响应连接上服务器之后的操作
void MQTT_WorkClass::LocalTcpClientConnectedSlot()
{
    socket_type=1;
    //通知外部
    emit MQTT_ConnectState(socket_type);
    //结束事件循环
    EndEvenLoop();
}
//客户端模式：断开服务器
void MQTT_WorkClass::LocalTcpClientDisconnectedSlot()
{
    socket_type=0;
    //通知外部
    emit MQTT_ConnectState(socket_type);
}
//客户端模式：读取服务器发过来的数据
void MQTT_WorkClass::LocalTcpClientReadDtatSlot()
{
   ReadData=LocalTcpClientSocket->readAll();
   qDebug()<<"读取服务器发过来的数据:"<<ReadData.length();
   EndEvenLoop(); //退出事件循环
}
//客户端模式：数据发送成功
void MQTT_WorkClass::LocalTcpClientBytesWrittenSlot(qint64 byte)
{
    LogSend(QString("数据发送成功:%1\n").arg(byte));
    EndEvenLoop(); //退出事件循环
}
//订阅主题
void MQTT_WorkClass::slot_SubscribeTopic(QString topic)
{
    if(MQTT_SubscribeTopic(topic.toUtf8().data(),0,1))
    {
        LogSend(QString("主题订阅失败.\n"));
    }
    else
    {
         LogSend(QString("主题订阅成功.\n"));
    }
}
//发布消息
void MQTT_WorkClass::slot_PublishData(QString topic,QString message)
{
     MQTT_PublishData(topic.toUtf8().data(),message.toUtf8().data(),0);
}
void MQTT_WorkClass::EndEvenLoop()
{
    //停止定时器
    timer->stop();
    //先退出事件循环
    loop.exit();
    //qDebug()<<"退出事件循环";
}
//开始事件循环
void MQTT_WorkClass::StartEvenLoop()
{
    //qDebug()<<"开始事件循环";
    timer->start(5000);
    loop.exec();
}
//断开连接
void MQTT_WorkClass::slot_tcp_close()
{
    if(socket_type)
    {
        timer->stop();
        loop.exit();
        LocalTcpClientSocket->close();
    }
}

4.2 mqtt.h

#ifndef XL_MQTT_H
#define XL_MQTT_H
extern "C"
{
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include <stdarg.h>
}
#include <iostream>
#include <QWidget>
#include <QTcpServer>
#include <QHostInfo>  //获取计算机网络信息
#include <QUdpSocket>
#include <QtNetwork>
#include <QHostInfo>
#include <QDebug>
#include <QTcpSocket>
#include <QHostAddress>
#include <QDebug>
#include <QMessageBox>
#include <QLineEdit>
#include <QHBoxLayout>
#include <QComboBox>
#include <QFile>
#include <QTimer>
#include <QScrollBar>
#define BYTE0(dwTemp)       (*(char *)(&dwTemp))
#define BYTE1(dwTemp)       (*((char *)(&dwTemp) + 1))
#define BYTE2(dwTemp)       (*((char *)(&dwTemp) + 2))
#define BYTE3(dwTemp)       (*((char *)(&dwTemp) + 3))
typedef enum
{
    //名字      值       报文流动方向  描述
    M_RESERVED1 =0  , //  禁止  保留
    M_CONNECT   , //  客户端到服务端 客户端请求连接服务端
    M_CONNACK   , //  服务端到客户端 连接报文确认
    M_PUBLISH   , //  两个方向都允许 发布消息
    M_PUBACK    , //  两个方向都允许 QoS 1消息发布收到确认
    M_PUBREC    , //  两个方向都允许 发布收到（保证交付第一步）
    M_PUBREL    , //  两个方向都允许 发布释放（保证交付第二步）
    M_PUBCOMP   , //  两个方向都允许 QoS 2消息发布完成（保证交互第三步）
    M_SUBSCRIBE   , //  客户端到服务端 客户端订阅请求
    M_SUBACK    , //  服务端到客户端 订阅请求报文确认
    M_UNSUBSCRIBE , //  客户端到服务端 客户端取消订阅请求
    M_UNSUBACK    , //  服务端到客户端 取消订阅报文确认
    M_PINGREQ   , //  客户端到服务端 心跳请求
    M_PINGRESP    , //  服务端到客户端 心跳响应
    M_DISCONNECT  , //  客户端到服务端 客户端断开连接
    M_RESERVED2   , //  禁止  保留
}_typdef_mqtt_message;
class MQTT_WorkClass:public QObject
{
    Q_OBJECT
public:
    QTimer *timer=nullptr;
    MQTT_WorkClass(QObject* parent=nullptr):QObject(parent){}
    ~MQTT_WorkClass();
    //用户名初始化
    void OneNet_LoginInit(char *ProductKey,char *DeviceName,char *DeviceSecret);
    //MQTT协议相关函数声明
    quint8 MQTT_PublishData(char *topic, char *message, quint8 qos);
    quint8 MQTT_SubscribeTopic(char *topic,quint8 qos,quint8 whether);
    void MQTT_Init(void);
    quint8 MQTT_Connect(char *ClientID,char *Username,char *Password);
    void MQTT_SentHeart(void);
    void MQTT_Disconnect(void);
    void MQTT_SendBuf(quint8 *buf,quint16 len);
    void ConnectMqttServer(QString ip,quint16 port);
    void Set_MQTT_Addr(QString ip,quint16 port,QString MQTT_ClientID,QString MQTT_UserName,QString MQTT_PassWord);
    void StartEvenLoop();
public slots:
    void EndEvenLoop();
    void run();
    void LocalTcpClientConnectedSlot();
    void LocalTcpClientDisconnectedSlot();
    void LocalTcpClientReadDtatSlot();
    void LocalTcpClientBytesWrittenSlot(qint64 byte);
    //订阅主题
    void slot_SubscribeTopic(QString topic);
    //发布消息
    void slot_PublishData(QString topic,QString message);
    //断开连接
    void slot_tcp_close();
signals:
    void LogSend(QString text);
    void MQTT_ConnectState(bool state);
private:
    quint8 *mqtt_rxbuf;
    quint8 *mqtt_txbuf;
    quint16 mqtt_rxlen;
    quint16 mqtt_txlen;
    quint8 _mqtt_txbuf[256];//发送数据缓存区
    quint8 _mqtt_rxbuf[256];//接收数据缓存区
    QTcpSocket *LocalTcpClientSocket=nullptr;
    QString m_ip;
    quint16 m_port;
    bool socket_type=0;  //这是网络的状态: 1表示已经连接 0表示未连接
    QString m_MQTT_ClientID;
    QString m_MQTT_UserName;
    QString m_MQTT_PassWord;
    QEventLoop loop;
    QByteArray  ReadData;
};
#endif


文章标签：
云消息队列 MQ
C语言
Linux
数据安全/隐私保护
物联网
安全
编译器
关键词：
云消息队列 MQ订阅
客户端云服务器 ECS
云服务器 ECS客户端
云服务器 ECS登录
编程云服务器 ECS
相关实践学习
消息队列RocketMQ版：基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能，涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列：消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验：基于MNS，0基础轻松构建 Web Client 本节课带您一起基于MNS，0基础轻松构建 Web Client
DS小龙哥
目录
相关文章
zzy的aly
|
2月前
|
Python
Socket学习笔记(二):python通过socket实现客户端到服务器端的图片传输
使用Python的socket库实现客户端到服务器端的图片传输，包括客户端和服务器端的代码实现，以及传输结果的展示。
zzy的aly
145 3
Socket学习笔记(二):python通过socket实现客户端到服务器端的图片传输
zzy的aly
|
2月前
|
JSON 数据格式 Python
Socket学习笔记(一):python通过socket实现客户端到服务器端的文件传输
本文介绍了如何使用Python的socket模块实现客户端到服务器端的文件传输，包括客户端发送文件信息和内容，服务器端接收并保存文件的完整过程。
zzy的aly
158 1
Socket学习笔记(一):python通过socket实现客户端到服务器端的文件传输
追逐时光者
|
2月前
|
网络协议 Unix Linux
一个.NET开源、快速、低延迟的异步套接字服务器和客户端库
一个.NET开源、快速、低延迟的异步套接字服务器和客户端库
追逐时光者
91 4
一位隐者
|
2月前
|
安全 区块链 数据库
计算机网络的逻辑分类：对等网络与客户端/服务器网络
【10月更文挑战第11天】
一位隐者
53 0
弹性计算小冉
|
13天前
|
人工智能 弹性计算 编解码
阿里云GPU云服务器性能、应用场景及收费标准和活动价格参考
GPU云服务器作为阿里云提供的一种高性能计算服务，通过结合GPU与CPU的计算能力，为用户在人工智能、高性能计算等领域提供了强大的支持。其具备覆盖范围广、超强计算能力、网络性能出色等优势，且计费方式灵活多样，能够满足不同用户的需求。目前用户购买阿里云gpu云服务器gn5 规格族（P100-16G）、gn6i 规格族（T4-16G）、gn6v 规格族（V100-16G）有优惠，本文为大家详细介绍阿里云gpu云服务器的相关性能及收费标准与最新活动价格情况，以供参考和选择。
弹性计算小冉
45 4
我是暴发户
|
18天前
|
机器学习/深度学习 人工智能 弹性计算
什么是阿里云GPU云服务器？GPU服务器优势、使用和租赁费用整理
阿里云GPU云服务器提供强大的GPU算力，适用于深度学习、科学计算、图形可视化和视频处理等多种场景。作为亚太领先的云服务提供商，阿里云的GPU云服务器具备灵活的资源配置、高安全性和易用性，支持多种计费模式，帮助企业高效应对计算密集型任务。
我是暴发户
60 6
弹性计算小冉
|
20天前
|
存储 分布式计算 固态存储
阿里云2核16G、4核32G、8核64G配置云服务器租用收费标准与活动价格参考
2核16G、8核64G、4核32G配置的云服务器处理器与内存比为1:8，这种配比的云服务器一般适用于数据分析与挖掘，Hadoop、Spark集群和数据库，缓存等内存密集型场景，因此，多为企业级用户选择。目前2核16G配置按量收费最低收费标准为0.54元/小时，按月租用标准收费标准为260.44元/1个月。4核32G配置的阿里云服务器按量收费标准最低为1.08元/小时，按月租用标准收费标准为520.88元/1个月。8核64G配置的阿里云服务器按量收费标准最低为2.17元/小时，按月租用标准收费标准为1041.77元/1个月。本文介绍这些配置的最新租用收费标准与活动价格情况，以供参考。
弹性计算小冉
79 6
用数据说话
|
18天前
|
机器学习/深度学习 人工智能 弹性计算
阿里云GPU服务器全解析_GPU价格收费标准_GPU优势和使用说明
阿里云GPU云服务器提供强大的GPU算力，适用于深度学习、科学计算、图形可视化和视频处理等场景。作为亚太领先的云服务商，阿里云GPU云服务器具备高灵活性、易用性、容灾备份、安全性和成本效益，支持多种实例规格，满足不同业务需求。
用数据说话
99 2
上云百科
|
26天前
|
弹性计算
阿里云2核16G服务器多少钱一年？亲测价格查询1个月和1小时收费标准
阿里云2核16G服务器提供多种ECS实例规格，内存型r8i实例1年6折优惠价为1901元，按月收费334.19元，按小时收费0.696221元。更多规格及详细报价请访问阿里云ECS页面。
上云百科
64 9
游客ca6oksdpxmrrg
|
22天前
|
监控 Ubuntu Linux
使用VSCode通过SSH远程登录阿里云Linux服务器异常崩溃
通过 VSCode 的 Remote - SSH 插件远程连接阿里云 Ubuntu 22 服务器时，会因高 CPU 使用率导致连接断开。经排查发现，VSCode 连接根目录 ".." 时会频繁调用"rg"（ripgrep）进行文件搜索，导致 CPU 负载过高。解决方法是将连接目录改为"root"（或其他具体的路径），避免不必要的文件检索，从而恢复正常连接。
游客ca6oksdpxmrrg
103 3

热门文章

最新文章

  • 1
    信用算力基于 RocketMQ 实现金融级数据服务的实践
  • 2
    RabbitMQ入门指南(十一)：延迟消息-延迟消息插件
  • 3
    消息中间件的技术选型心得－RabbitMQ、ActiveMQ和ZeroMQ
  • 4
    解决微信小程序MQTT真机连接问题与合法域名配置SSL问题
  • 5
    RocketMQ 消息发送system busy、broker busy原因分析与解决方案
  • 6
    【Spring常见错误】Rocketmq 闪退
  • 7
    STM32通过esp8266连接WiFi接入MQTT服务器
  • 8
    RabbitMQ队列中unacked消息持续时间很久
  • 9
    rabbitmq消息件在idc机房监控中的应用
  • 10
    STM32配合W5500网卡连接MQTT服务器
  • 1
    服务器Linux系统配置mysql数据库主从自动备份
    206
  • 2
    香港服务器需要备案吗
    178
  • 3
    LabVIEW中如何在网络上使用远程VI服务器
    81
  • 4
    LabVIEW将视觉生成器AI用作OPC服务器
    66
  • 5
    阿里云服务器计算型c7、计算型c7a、计算型c8a、计算型c8y实例区别及选择参考
    207
  • 6
    ECS使用体验
    30
  • 7
    【服务器】python通过JDBC连接到位于Linux远程服务器上的Oracle数据库
    90
  • 8
    服务器硬件基础知识
    92
  • 9
    阿里云轻量应用服务器、云服务器、gpu云服务器最新收费标准参考
    763
  • 10
    LabVIEW中ActiveX控件、ActiveX服务器和类型库注册
    245

    • 相关课程

    更多
  • RocketMQ知识精讲与项目实战（第一阶段）
  • RocketMQ知识精讲与项目实战（第三阶段）
  • 微服务实战-RocketMQ Binder
  • Linux Web服务器Nginx搭建与配置
  • 7天玩转云服务器
  • 云服务器选型、迁云最佳实践

    • 相关电子书

    更多
  • RocketMQ Client-GO 介绍
  • RocketMQ Prometheus Exporter 打造定制化 DevOps 平台
  • 基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台

    • 相关实验场景

    更多
  • 使用ECS和RDS搭建个人博客
  • 利用云备份Cloud Backup实现ECS文件备份
  • 基于ECS搭建FTP服务
  • 基于ECS和NAS搭建个人网盘
  • 使用ECS和OSS搭建个人网盘
  • 基于ECS搭建云上博客

    • 推荐镜像

    更多
  • qt
  • eclipse
  • python-release
    • 下一篇
    阿里云无影云电脑免费试用，最长可试用3个月