了解一下CoAP（一）

大家好，欢迎来到IT知识分享网。

一. 什么是CoAP？

Coap（Constrained Application Protocol）受限应用协议。一种在物联网世界的类web协议。顾名思义，使用在资源受限的物联网设备上。

CoAP是类HTTP协议，它是对HTTP协议简化，协议非常简单，头部和选项字段较少，占用网络带宽和资源较少。对资源受限设备和网络进行优化，具有低能耗和低带宽消耗的特性。

二. 报文格式

 2 2 4 8 16 +---+---+-----+----------------+---------------------------| |ver| T | TKL | Code | Message ID | +----------------------------------------------------------| | Token(if any, TKL bytes)... | +----------------------------------------------------------| | Optons(if any)... | +---------------+------------------------------------------| |1 1 1 1 1 1 1 1| Payload(if any)... | +----------------------------------------------------------| 

第一行是消息头，必须有，固定4个byte。

三. 如何使用？

1.引入依赖（git地址：https://github.com/eclipse-californium/californium）

 <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> 

2.服务器端（提供接口）

 private void server() throws UnknownHostException { 
    CoapServer coapServer = new CoapServer(); //resource-name 资源名 对应controller的路径参数。路径为/resource-name //new ConcurrentCoapResource("resource-name", 5（线程池线程数）) 按需使用线程安全的resource coapServer.add(new CoAPResourceExample("resource-name")); //CoapEndpoint 是Coap协议的一个传输图层（图层堆栈，层层处理消息），位于 MessageDeliverer 和 Connector 之间。详细解释请看作者类描述，很详细 CoapEndpoint.CoapEndpointBuilder coapEndpointBuilder = new CoapEndpoint.CoapEndpointBuilder(); // CoapEndpoint除了传输还可设置端口以及内部有个线程池保证线程安全 // 设置接口（Resource）绑定的ip地址 和端口 coapEndpointBuilder.setInetSocketAddress(new InetSocketAddress(InetAddress.getByName("ip"), 5683)); //or coapEndpointBuilder.setPort(5683); //网络配置参数，可自定义，这里使用默认配置 coapEndpointBuilder.setNetworkConfig(NetworkConfig.getStandard()); //可自定义连接池 //coapEndpointBuilder.setConnector() coapServer.addEndpoint(coapEndpointBuilder.build()); coapServer.start(); } public static class CoAPResourceExample extends CoapResource { 
    public CoAPResourceExample(String name) { 
    //resource-name 资源名 对应controller的路径参数/uri super(name); } public void handleGET(CoapExchange exchange) { 
    //获取路径参数 List<String> queries = exchange.getRequestOptions().getUriQuery(); //ResponseCode 响应码对应http状态码 contentFormat对应http的contentType。50 =》JSON 0 =》text exchange.respond(CoAP.ResponseCode.CONTENT, "hello world", 0); } public void handlePOST(CoapExchange exchange) { 
    //发送给客户端消息已到达 exchange.accept(); //获取请求参数 String requestBody = exchange.getRequestText(); //ResponseCode 响应码对应http状态码 contentFormat对应http的contentType exchange.respond(CoAP.ResponseCode.CREATED, "{}", 50); } public void handlePUT(CoapExchange exchange) { 
    // ... exchange.respond(CoAP.ResponseCode.CHANGED); changed(); //父类方法 notify all observers(client) the state has changed 见方法注释 } public void handleDELETE(CoapExchange exchange) { 
    delete();//父类方法 删除当前resource并通知所有observers(client) exchange.respond(CoAP.ResponseCode.DELETED); } } 

3.客户端（调用服务器端接口）

 private void client() throws URISyntaxException { 
    URI uri = new URI("coap://ip/resource-name?type=1");// 请求服务器资源resource-name，注意默认端口为5683 String body = "{\"body\":\"hello\"}"; CoapClient client = new CoapClient(uri); CoapResponse response = client.post(body.getBytes(), 50); //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)); // 打印格式良好的输出 } }