国内物联网平台初探(一) ——百度物接入IoT Hub

2024-06-12 20:08

本文主要是介绍国内物联网平台初探(一) ——百度物接入IoT Hub,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

物接入IoT Hub - 架构

  • 全托管的云服务,帮助建立设备与云端之间安全可靠的双向连接
  • 支撑海量设备的数据收集、监控、故障预测等各种物联网场景

 

物接入IoT Hub - 功能

  • 通信协议:支持MQTT
  • 数据安全:设备级认证、策略授权;双向安全连接、SSL传输
  • 开发语言:支持多种开发语言、兼容主流硬件设备
    • 支持C、C#、Python、Java、PHP等
    • 支持CLI命令行工具(Python)
  • 分析服务:对接百度大数据服务

 

物接入IoT Hub – 概念

概念

描述

MQTT

MQTT是基于二进制消息的发布/订阅(Publish/Subscribe)模式的协议,
最早由IBM提出的,如今已经成为OASIS规范,
更符合M2M大规模沟通。

endpoint

IoT Hub 的服务实例,代表一个完整的IoT Hub 服务。

thing

表示IoT Hub 设备,
用户可以在每个endpoint中创建一个或多个thing。

principal

principal是一个抽象概念,表示设备(thing)的身份。
每个thing可以绑定一个principal,
每个principal拥有一个policy权限。

policy

为身份principal设置对应的策略policy,一个principal对应一个policy。

permission

为每一个policy设置一组权限permission,其中包括主题topic,和对该主题的操作权限operation。

topic

每一个policy都需要指定一个主题项目(topic),在进行使用IoT Hub 服务之前,
需要先为我们即将开展的订阅发布信息创建一个主题名称,
该主题应用于MQTT客户端。topic规则允许字符串可以带一个通配符"#",
例如"temperature/#"就是匹配前缀是temperature的所有topic;单独的"#"表示匹配所有topic。

operation

对topic的操作权限。目前基于MQTT协议,IoT Hub 支持创建发布PUBLISH和订阅SUBSCRIBE两种权限。

 

MQTT协议

MQTT(Message Queuing Telemetry Transport)是一个客户端服务端架构的发布/订阅模式的消息传输协议。它的设计思想是轻巧、开放、简单、规范,易于实现。这些特点使得它对很多场景来说都是很好的选择,特别是对于受限的环境如机器与机器的通信(M2M)以及物联网环境(IoT)。

客户端

  1. 发布应用消息给其它相关的客户端。
  2. 订阅以请求接受相关的应用消息
  3. 取消订阅以移除接受应用消息的请求。
  4. 从服务端断开连接。

服务端

  1. 接受来自客户端的网络连接
  2. 接受客户端发布的应用消息
  3. 处理客户端的订阅和取消订阅请求。
  4. 转发应用消息给符合条件的客户端订阅。

 

MQTT vs HTTPS:

  • 吞吐量:93倍
  • 发送数据电量消耗: 1/11
  • 接收数据电量消耗:1/170
  • 连接保持电量消耗:1/2
  • 网络开销:1/8

 

物接入IoT Hub – 操作流程

目前每个账户只能创建2个endpoint,100个things,100个principal。

 

物接入IoT Hub – 连接类型

  • IoT Hub为每个实例提供3种默认连接方式
    • TCP:端口1883,不支持传输数据加密,可以通过MQTT.fx客户端连接。
    • SSL:端口1884,支持SSL/TLS加密传输,MQTT.fx客户端连接
    • WSS:端口8884,支持WebSocket浏览器方式连接,同样包含SSL加密

 

tcp://yourendpoint.mqtt.iot.gz.baiduce.com:1883

ssl://yourendpoint.mqtt.iot.gz.baiduce.com:1884

wss://yourendpoint.mqtt.iot.gz.baidubce.com:8884

 

物接入IoT Hub – 运维界面

创建设备

创建身份

创建策略

生成秘钥

 

物接入IoT Hub – MQTT客户端类型

  • Websockets Client:百度开放云基于浏览器开发的mqtt客户端
  • MQTT.fx:目前主流的mqtt客户端,可以快速验证是否可以与IoT Hub 服务交流发布或订阅消息
  • Paho:Eclipse基金会提供的开源MQTT客户端实现,可以很好的支持百度开放云物接入IoT Hub 服务以实现设备互联和物联网应用。

 

物接入IoT Hub – Paho客户端源码示例

订阅一栋办公楼内第五层的温度值

通过NetBeans 来展示如何通过代码来与物接入服务发送或者接受消息。新建一个Java应用程序类型的Maven项目,右击"依赖关系"选择添加依赖关系,查询org.eclipse.paho,并加入对org.eclipse.paho.client.mqttv3的依赖。

package com.baidu.iot;

import java.io.InputStream;

import java.security.KeyStore;

import java.security.cert.Certificate;

import java.security.cert.CertificateFactory;

import javax.net.ssl.SSLContext;

import javax.net.ssl.TrustManager;

import javax.net.ssl.TrustManagerFactory;

import org.eclipse.paho.client.mqttv3.MqttClient;

import org.eclipse.paho.client.mqttv3.MqttConnectOptions;

import org.eclipse.paho.client.mqttv3.MqttMessage;

public class Thermometer {

public static void main(String[] args) throws Exception {

String endpoint = "hostname"; //输入创建实例endpoint返回的hostname

String username = "yourendpoint/yourthing"; //输入创建thing返回的username

String password = "Dm3yyvOHb7zt/uRWsPgsfsgbnj7CxuVMc+uDbf4j960="; //输入创建principal返回的password

String topic = "building-b/floor-5/temperature-1"; //订阅的消息主题,本例是指订阅b号楼第五层的温度

TrustManagerFactory tmf = TrustManagerFactory.getInstance("X509");

tmf.init((KeyStore)null);

TrustManager[] trustManagers = tmf.getTrustManagers();

 

SSLContext ctx = SSLContext.getInstance("TLS");

ctx.init(null, trustManagers, null);

MqttConnectOptions options = new MqttConnectOptions();

options.setCleanSession(true);

options.setUserName(username);

options.setPassword(password.toCharArray());

options.setSocketFactory(ctx.getSocketFactory());

MqttClient client = new MqttClient(endpoint, "java-client");

client.connect(options);

MqttMessage message = new MqttMessage();

message.setPayload("15".getBytes());

client.publish(topic, message);

client.disconnect();

}

}

 

物接入IoT Hub – 与大数据分析服务对接

分类: 物联网

这篇关于国内物联网平台初探(一) ——百度物接入IoT Hub的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1055214

相关文章

使用国内镜像源优化pip install下载的方法步骤

《使用国内镜像源优化pipinstall下载的方法步骤》在Python开发中,pip是一个不可或缺的工具,用于安装和管理Python包,然而,由于默认的PyPI服务器位于国外,国内用户在安装依赖时可... 目录引言1. 为什么需要国内镜像源?2. 常用的国内镜像源3. 临时使用国内镜像源4. 永久配置国内镜

国内环境搭建私有知识问答库踩坑记录(ollama+deepseek+ragflow)

《国内环境搭建私有知识问答库踩坑记录(ollama+deepseek+ragflow)》本文给大家利用deepseek模型搭建私有知识问答库的详细步骤和遇到的问题及解决办法,感兴趣的朋友一起看看吧... 目录1. 第1步大家在安装完ollama后,需要到系统环境变量中添加两个变量2. 第3步 “在cmd中

Python使用DeepSeek进行联网搜索功能详解

《Python使用DeepSeek进行联网搜索功能详解》Python作为一种非常流行的编程语言,结合DeepSeek这一高性能的深度学习工具包,可以方便地处理各种深度学习任务,本文将介绍一下如何使用P... 目录一、环境准备与依赖安装二、DeepSeek简介三、联网搜索与数据集准备四、实践示例:图像分类1.

IDEA接入Deepseek的图文教程

《IDEA接入Deepseek的图文教程》在本篇文章中,我们将详细介绍如何在JetBrainsIDEA中使用Continue插件接入DeepSeek,让你的AI编程助手更智能,提高开发效率,感兴趣的小... 目录一、前置准备二、安装 Continue 插件三、配置 Continue 连接 DeepSeek四

SpringBoot快速接入OpenAI大模型的方法(JDK8)

《SpringBoot快速接入OpenAI大模型的方法(JDK8)》本文介绍了如何使用AI4J快速接入OpenAI大模型,并展示了如何实现流式与非流式的输出,以及对函数调用的使用,AI4J支持JDK8... 目录使用AI4J快速接入OpenAI大模型介绍AI4J-github快速使用创建SpringBoot

Python使用国内镜像加速pip安装的方法讲解

《Python使用国内镜像加速pip安装的方法讲解》在Python开发中,pip是一个非常重要的工具,用于安装和管理Python的第三方库,然而,在国内使用pip安装依赖时,往往会因为网络问题而导致速... 目录一、pip 工具简介1. 什么是 pip?2. 什么是 -i 参数?二、国内镜像源的选择三、如何

PyCharm 接入 DeepSeek最新完整教程

《PyCharm接入DeepSeek最新完整教程》文章介绍了DeepSeek-V3模型的性能提升以及如何在PyCharm中接入和使用DeepSeek进行代码开发,本文通过图文并茂的形式给大家介绍的... 目录DeepSeek-V3效果演示创建API Key在PyCharm中下载Continue插件配置Con

Spring AI Alibaba接入大模型时的依赖问题小结

《SpringAIAlibaba接入大模型时的依赖问题小结》文章介绍了如何在pom.xml文件中配置SpringAIAlibaba依赖,并提供了一个示例pom.xml文件,同时,建议将Maven仓... 目录(一)pom.XML文件:(二)application.yml配置文件(一)pom.xml文件:首

PyCharm接入DeepSeek实现AI编程的操作流程

《PyCharm接入DeepSeek实现AI编程的操作流程》DeepSeek是一家专注于人工智能技术研发的公司,致力于开发高性能、低成本的AI模型,接下来,我们把DeepSeek接入到PyCharm中... 目录引言效果演示创建API key在PyCharm中下载Continue插件配置Continue引言

流媒体平台/视频监控/安防视频汇聚EasyCVR播放暂停后视频画面黑屏是什么原因?

视频智能分析/视频监控/安防监控综合管理系统EasyCVR视频汇聚融合平台,是TSINGSEE青犀视频垂直深耕音视频流媒体技术、AI智能技术领域的杰出成果。该平台以其强大的视频处理、汇聚与融合能力,在构建全栈视频监控系统中展现出了独特的优势。视频监控管理系统EasyCVR平台内置了强大的视频解码、转码、压缩等技术,能够处理多种视频流格式,并以多种格式(RTMP、RTSP、HTTP-FLV、WebS