基于COAP协议的JAVA客户端CoapClient向EMQ发送消息

鉴于网上基于基于COAP协议的JAVA客户端CoapClient向EMQ发送消息的资料比较少，压根没查到，自己就记录一下怎么使用了。如果有错误的地方希望能指出来。

1、pom.xml需要导入以下依赖：

<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、Java代码

URI uri = null;
uri = new URI("coap://192.168.0.75/mqtt/topic1?c=client1&u=tom&p=secret");  //创建一个资源请求hello资源，注意默认端口为5683
CoapClient client = new CoapClient(uri);
CoapResponse response = client.put("test", MediaTypeRegistry.TEXT_PLAIN);
if(response !=null){
    System.out.println(response.getCode());  //打印请求状态码
    System.out.println(response.getOptions());  //选项参数
    System.out.println(response.getResponseText());  //获取内容文本信息
    System.out.println("
Advanced
");    //
    System.out.println(Utils.prettyPrint(response));  //打印格式良好的输出
}

注意：其实能查到使用 CoapClient发送到CoapServer的例子，但是发送到EMQ上却不行，主要是这个请求uri不适用，必须按照这个格式才能发送到EMQ或者订阅EMQ发送的消息，有兴趣的同学可以自己试试，uri按照我写的格式就能连接到EMQ，不然总是连不通，这个uri是重点，其他的无论是发送消息的方法还是get消息的方法网上都有。

3、打开EMQ的Dashboard，订阅topic1，可以看到以下代表成功