物联网协议之COAP简介及Java实践

目录

前言

一、COAP简介

1、关于COAP

 2、COAP特点

3、基于COAP的NB-IoT接入流程

二、CoAP协议JAVA实践

1、californium介绍

2、Java集成 

3、Maven 资源引入

4、定义Server端

5、Client调用

6、运行测试

总结


前言

        今天平安夜,祝大家圣诞快乐,平平安安。最近几年,随着物联网的兴起,很多设备都已经可以实现互联互通。相信很多从事安防、智慧城市、智能家居、智慧农业、应急消防、自然资源行业的朋友们,物联网已经是很成熟的技术了。很多的摄像头、传感器、计量水表、电表、燃气表、湿度传感器等等设备不仅可以支持实时的上传数据,还可以跟物联网平台进行互联互通,接收服务端的指令并进行执行相应操作。

        在实现物联网设备和互联网连接的过程中,除了基础的网络通信保障,还有一个重要的基础设施,就是物联网协议。相信大家对协议都不陌生,从TCP/IP、UDP,从HTTP、MQTT、COAP,很多的协议在我们日常的工作当中,当然更多使用的是HTTP协议。关于协议,很多书籍都已经讲解得非常详细。

        本文将围绕物联网的COAP协议,首先对其进行简单介绍,然后基于JAVA语言来进行COAP协议通讯编程实战,帮助大家对COAP有一个简单的认知,经过编程实践掌握协议的通信机制。

一、COAP简介

        为了让不熟悉COAP协议的读者在读这篇博文时,不至于不知道COAP是什么?因为还是在此对COAP进行一个简单的介绍,让每个读者都有一个直观的认识。如果对COAP非常熟悉的朋友,可以略过,直接进入后面的编程实战环节。

1、关于COAP

        CoAP(Constrained Application Protocol,受限应用协议)是一种专为物联网(IoT)设备和资源受限网络设计的应用层协议。它的诞生也是由于物联网设备大多都是资源限制型的,比如 CPU、RAM、Flash、网络宽带等;对于这类设备来说,想要直接使用现有网络的TCP和HTTP来实现设备信息交换是不现实的,为了让这部分设备能够顺利接入网络,CoAP 协议因此诞生。

 2、COAP特点

序号特点说明
1轻量级CoAP协议非常简单,头部和选项字段较少,占用网络带宽和资源较少。
2基于UDP基于UDP运行,使得更适用于无连接、低延迟和高效率的通信,通过CoAP的CON(Confirmable)和ACK(Acknowledgment)消息实现可靠性传输。
3类Restful架构采用类RESTful架构风格,支持GET、POST、PUT和DELETE等常用的HTTP方法(有所区分),以进行资源的读取、创建、更新和删除。
4低能耗、低带宽对资源受限设备和网络进行优化,具有低能耗和低带宽消耗的特性。
5资源标识符使用统一资源标识符(URI)来标识资源
6IP多播允许一对多的通信,对物联网中的多个设备同时接收非常有用
7可扩展性允许在消息头中包含自定义选项,以满足特定应用的需求,可扩展性高。

3、基于COAP的NB-IoT接入流程

         上图是某云基于Coap的NB-IoT的数据接入框架,这也是当前很多物联网平台接入的架构(可供参考),是一种比较容易实现的方式。

序号描述
1在设备端NB-IoT模块中,集成物联网平台SDK。厂商在物联网平台控制台申请设备证书(ProductKey、DeviceName和DeviceSecret)并烧录到设备中。
2NB-IoT设备通过运营商的蜂窝网络进行入网。需要联系当地运营商,确保设备所属地区已经覆盖NB网络,并已具备NB-IoT入网能力。
3设备入网成功后,NB设备产生的流量数据及产生的费用数据,将由运营商的M2M平台管理。此部分平台能力由运营商提供。
4设备开发者可通过CoAP/UDP协议,将设备采集的实时数据上报到云物联网平台,借助物联网平台,实现海量亿级设备的安全连接和数据管理能力。并且,可通过规则引擎,将数据转发至大数据产品、云数据库、表格存储等服务中进行处理。
5物联网平台提供相关的数据开放接口和消息推送服务,可将数据转发到业务服务器中,实现设备资产与实际应用的快速集成。

二、CoAP协议JAVA实践

        协议一般与编程语言无关。因此,您可以使用熟悉的技术栈来进行实现即可,这里以作者熟悉的Java语言为例,简单的介绍适用Java进行CoAP的协议开发。采用Java实现的原因很简单,基于Java良好的生态,有一款基于Java开发的CoAP协议实现框架californium,基于这个框架可以快速实现CoAP的Server端和Client的开发,帮助我们快速实现物联网业务。

1、californium介绍

        Californium框架是一款基于Java实现的Coap技术框架,californium官网地址,该项目实现了Coap协议的各种请求响应定义,支持CON/NON不同的可靠性传输模式。Californium 基于分层设计且高度可扩展。Californium三层架构如下:

        1 网络层:负责处理端口监听,网络数据收发;

        2 协议层:负责Coap协议数据包解析及封装,实现消息的路由、可靠性传输、Token处理、观察者模型;

        3 逻辑层:负责 Resource定义和映射,一个Resource 对应一个URL,可独立实现Coap 请求处理。可以将resource是一个controller。

2、Java集成 

        实现申明,在这里,我们使用californium的版本是2.0.x版本,使用2.0版本是因为在3的版本中座了优化和调整,导致有一些配置需要重写。为了保证最简单的实现,我们用2.0作为示例例子,下次可以说明一下在更高级的版本中如何使用。

        Java开发环境软件说明:

        Eclipse、Jdk1.8、Maven3.3.9、californium 2.0.0-M7

3、Maven 资源引入

        首先新建一个Maven工程,在Pom.xml中引入所需要的资源jar包。

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.yelangking</groupId><artifactId>californium-client-demo</artifactId><version>0.0.1-SNAPSHOT</version><dependencies><dependency><groupId>org.eclipse.californium</groupId><artifactId>californium-core</artifactId><version>2.0.0-M7</version></dependency><dependency><groupId>org.eclipse.californium</groupId><artifactId>element-connector</artifactId><version>2.0.0-M7</version></dependency><dependency><groupId>org.eclipse.californium</groupId><artifactId>scandium</artifactId><version>2.0.0-M7</version></dependency>
</dependencies>
</project>

4、定义Server端

        基于californium的server端开发,其实非常简单。关键代码如下:

package com.yelagking;import java.text.SimpleDateFormat;
import java.util.Date;import org.eclipse.californium.core.CoapResource;
import org.eclipse.californium.core.CoapServer;
import org.eclipse.californium.core.coap.CoAP.ResponseCode;
import org.eclipse.californium.core.server.resources.CoapExchange;public class HelloCoAPServer {public static void main(String[] args) {CoapServer server = new CoapServer();// 主机为localhost 端口为默认端口5683server.add(new CoapResource("hello") {// 创建一个资源为hello 请求格式为 主机:端口\hello@Overridepublic void handleGET(CoapExchange exchange) { // 重写处理GET请求的方法exchange.respond(ResponseCode.CONTENT, "Hello CoAP!This is from Java coap server");}});server.add(new CoapResource("time") { // 创建一个资源为time 请求格式为 主机:端口\time@Overridepublic void handleGET(CoapExchange exchange) {Date date = new Date();exchange.respond(ResponseCode.CONTENT, new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(date));}});server.start();}
}

        在上面的代码中,相当与定义了两个controller,分别为hello和time,在类里面,开放了一个get访问接口(相当于是restful的get)。在实际业务中,我们可以在get里面做业务逻辑了,比如把接收到的数据进行入库,或者把执行命令一起推送给下游的设备端。

server.add(new CoapResource("hello") {// 创建一个资源为hello 请求格式为 主机:端口\hello@Overridepublic void handleGET(CoapExchange exchange) { // 重写处理GET请求的方法exchange.respond(ResponseCode.CONTENT, "Hello CoAP!This is from Java coap server");}});

5、Client调用

        有了服务端之后,我们再进行客户端的开发。由于是示例,并未做分离部署,及客户端和服务端在一台机器上,实际情况下肯定是需要分开的。关键代码如下:

package com.yelangking;import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;import org.eclipse.californium.core.CoapClient;
import org.eclipse.californium.core.CoapResponse;
import org.eclipse.californium.core.Utils;
import org.eclipse.californium.core.coap.MediaTypeRegistry;public class ClientTest {public static void main(String[] args) throws URISyntaxException, IOException {URI uri = null;uri = new URI("coap://localhost:5683/hello"); // 创建一个资源请求hello资源,注意默认端口为5683//uri = new URI("coap://127.0.0.1:5683/core/time?type=1");CoapClient client = new CoapClient(uri);CoapResponse response = client.get();if (response != null) {System.out.println(response.getCode()); // 打印请求状态码System.out.println(response.getOptions()); // 选项参数System.out.println(response.getResponseText()); // 获取内容文本信息System.out.println("\nAdvanced\n"); //System.out.println(Utils.prettyPrint(response)); // 打印格式良好的输出}}}

6、运行测试

        在编写完server端和client端代码后,我们分别来测试一下是否可用,以及通过client调用server,是否有请求报文。首先将Server端启动起来。

        然后再启动client,同时访问hello接口,测试能否从接口中获取数据。运行main函数后,发现控制台有以下输出:

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
2.05
{"Content-Format":"text/plain"}
Hello CoAP!This is from Java coap serverAdvanced==[ CoAP Response ]============================================
MID    : 59202
Token  : [d845e70ed6398b48]
Type   : ACK
Status : 2.05
Options: {"Content-Format":"text/plain"}
RTT    : 51 ms
Payload: 40 Bytes
---------------------------------------------------------------
Hello CoAP!This is from Java coap server
===============================================================

        可以看到,client成功发起了一个get请求,server端正常接收请求,并返回了相应。一次CoAP的协议调用过程实例就成功了。

总结

        以上就是本文的主要内容,本文将围绕物联网的COAP协议,首先对其进行简单介绍,然后基于JAVA语言来进行COAP协议通讯编程实战,帮助大家对COAP有一个简单的认知,经过编程实践掌握协议的通信机制。

本文部分插图参考网络资源,原文地址:

1、Coap协议和Californium框架使用示例。

2、CoAP连接通信。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/297238.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【AI提示词艺术】第12期 摄影艺术构图处理和人像生成的技巧

摄影艺术构图 星空宇宙 关键词&#xff1a; 强烈的明暗对比,8k,精细的描述,相片纸,超高分辨率,无建筑的,大自然,星空&#xff0c;云朵&#xff0c;刺眼流星&#xff0c;群星&#xff0c;银河&#xff0c;仰视视角&#xff0c;广角镜头 以下是按照提示词类别整理的相关描述&a…

身为Java“搬砖”程序员,你掌握了多线程吗?

摘要&#xff1a;互联网的每一个角落&#xff0c;无论是大型电商平台的秒杀活动&#xff0c;社交平台的实时消息推送&#xff0c;还是在线视频平台的流量洪峰&#xff0c;背后都离不开多线程技术的支持。在数字化转型的过程中&#xff0c;高并发、高性能是衡量系统性能的核心指…

golang的jwt学习笔记

文章目录 初始化项目加密一步一步编写程序另一个参数--加密方式关于StandardClaims 解密解析出来的怎么用关于`MapClaims`上面使用结构体的全代码实战项目关于验证这个项目的前端初始化项目 自然第一步是暗转jwt-go的依赖啦 #go get github.com/golang-jwt/jwt/v5 go get githu…

HarmonyOS - 鸿蒙开发入门

文章目录 HarmonyOS核心资源特性&#xff1a;全场景终端HarmonyOS 版本 HarmonyOS 和 OpenHarmony教程资源开发环境开发工具 - DevEco开发语言 - ArkTS核心框架 - ArkUI 考证 HarmonyOS 开发交流秋秋群&#xff1a;23458659&#xff0c;V : ez-code&#xff0c;期待交流和合作 …

07_堆的特性

07_堆 一、堆1.1堆的定义1.3堆的实现insert插入方法的实现delMax删除最大元素方法的实现堆的实现代码 1.4堆排序堆构造过程堆排序过程 一、堆 1.1堆的定义 堆是计算机科学中一类特殊的数据结构的统称&#xff0c;堆通常可以被看做是一棵完全二叉树的数组对象。堆的特性&#x…

智能变电站协议系列-2、SV/SMV协议示例(IEC61850)以及5G专网下的电力方案分析

文章目录 一、前言二、资料准备三、libiec61850的SV运行示例及抓包分析1、单独编译示例程序2、运行示例程序及5G专网场景下部署3、wireshark抓包分析 四、最后 一、前言 之前我们对IEC61850协议有了整体的了解&#xff0c;对一些概念有了一定的认识&#xff0c;并针对GOOSE协议…

2023年全球前端大技术大会(GMTC北京站2023)-核心PPT资料下载

一、峰会简介 大会以“业务至上&#xff0c;效率为王”为主题&#xff0c;策划了 1 个主会场&#xff0c;10 个技术专场。会议议题包含前端 DevOps 实践、低代码、大前端监控、跨端技术选型、团队可持续发展、IoT 动态应用开发、移动端性能与效率优化、TypeScript、大前端技术…

ioDraw AI:思维导图、流程图、序列图、类图、饼图,一应俱全

前言 在信息爆炸的时代&#xff0c;我们每天接收着大量的信息&#xff0c;如何高效地整理和呈现这些信息成为了一项重要的挑战。思维导图作为一种可视化思维工具&#xff0c;能够帮助我们快速构建和整理复杂的信息结构&#xff0c;便于我们理解和记忆。ioDraw AI绘图工具正是基…

怎么使用jupter notebook并配置环境变量

有的时候需要使用Jupyter Notebook运行代码&#xff0c;Jupyter Notebook的主要特点&#xff1a; ① 编程时具有语法高亮、缩进、tab补全的功能。 ② 可直接通过浏览器运行代码&#xff0c;同时在代码块下方展示运行结果。 ③ 以富媒体格式展示计算结果。富媒体格式包括&…

若依框架部署(2023年前后端分离部署)

目录 1.下载源码 2.加载maven依赖 3.数据库配置 4.后端配置启动 5.前端配置启动 ​编辑 6.登录测试 来都来了给我点个赞和收藏关注一下在走呗~~~~&#x1f339;&#x1f339;&#x1f339;&#x1f339; 下面的是若依前后端版本的官方文档地址&#xff1a; 介绍 | RuoY…

【Linux】Linux线程互斥与同步

文章目录 一、Linux线程互斥1.进程线程间的互斥相关背景概念2.互斥量的接口3.互斥量实现原理4.可重入VS线程安全4.1.可重入和线程安全的概念4.2常见的线程不安全的情况4.3常见的线程安全的情况4.4常见不可重入的情况4.5常见可重入的情况4.6可重入与线程安全联系4.7可重入与线程…

Redis-运维

转自 极客时间 Redis 亚风 原文视频&#xff1a;https://u.geekbang.org/lesson/535?article681062 Redis 同步 Redis主从数据同步,主从第⼀次同步是全量同步 replicaof 主机 端口 #当前这个机器做Master的备份master如何判断slave是不是第⼀次来同步数据&#xff1a; Repl…