java 开发指南-----_开发指南（Java）

蔚落 2022-11-05 09:57 258阅读 0赞

设置消息接收接口

连接建立后，服务端会立即向SDK推送已订阅的消息。因此，建立连接时，需要提供消息接收接口，用于处理未设置回调的消息。建议在连接之前，调用 setMessageListener 设置消息回调。

您需要通过 MessageCallback接口的consume方法，和调用messageClient的setMessageListener()方法来设置消息接收接口。

consume方法的返回值决定SDK是否发送 ACK(acknowledgement，即回复确认消息)。

设置消息接收接口的方法如下：MessageCallback messageCallback = new MessageCallback() \{

@Override

public Action consume(MessageToken messageToken) \{

Message m = messageToken.getMessage();

log.info("receive : " + new String(messageToken.getMessage().getPayload()));

return MessageCallback.Action.CommitSuccess;

\}

\};

messageClient.setMessageListener("/$\{YourProductKey\}/\#",messageCallback);

其中：

参数MessageToken指消息回执的消息体。通过MessageToken.getMessage()可获取消息体。MessageToken可以用于手动回复ACK。

消息体包含的内容如下：public class Message \{

// 消息体

private byte\[\] payload;

// Topic

private String topic;

// 消息ID

private String messageId;

// QoS

private int qos;

\}

各类型消息的具体格式，请参见

说明 关于设备上下线状态，为避免消息时序紊乱造成影响，建议您根据消息中的lastTime字段来判断最终设备状态。

示例中，messageClient.setMessageListener("/$\{YourProductKey\}/\#",messageCallback);用于设置指定Topic回调。

您可以设置为指定Topic回调，也可以设置为通用回调。

指定Topic回调

指定Topic回调的优先级高于通用回调。一条消息匹配到多个Topic时，按字典顺序优先调用，并且仅回调一次。

设置回调时，可以指定带通配符的Topic，如/$\{YourProductKey\}/$\{YourDeviceName\}/\# 。

示例： messageClient.setMessageListener("/alEddfaXXXX/device1/\#",messageCallback);

//当收到消息的Topic，如"/alEddfaXXXX/device1/update"，匹配指定Topic时，会优先调用该回调

通用回调

未指定Topic回调的消息，则调用通用回调。

设置通用回调方法： messageClient.setMessageListener(messageCallback);

//当收到消息topic未匹配到已定指的Topic 回调时，调用该回调

设置回复ACK。

QOS=1的消息消费后，需要回复ACK。支持设置为自动回复ACK和手动回复ACK。默认为自动回复 ACK。本示例中未设置回复 ACK，则默认为自动回复。

自动回复ACK：设置为自动回复ACK后，若MessageCallback.consume的返回值为true， SDK会发送ACK；返回false或抛出异常，则不会返回ACK。对于QOS=1且未回复ACK的消息，服务器会重新发送。

手动回复ACK方法： CompletableFuture ack(MessageToken var1);

调用该方法的请求参数为MessageToken，表示需要回复ACK的消息。该参数值从MessageCallback回调信息中获取。

设置回复ACK示例：client.connect(messageToken -> \{

System.out.println(messageToken.getMessage());

asyncHandleMessage(messageToken);

return MessageCallback.Action.CommitAckManually;

\});

public void asyncHandleMessage(MessageToken messageToken) \{

client.ack(messageToken)

\}

发表评论取消回复

表情：

评论列表（有 0 条评论，258人围观）

还没有评论，来说两句吧...

相关阅读

相关 java 开发指南-----_开发指南（Java）

设置消息接收接口连接建立后，服务端会立即向SDK推送已订阅的消息。因此，建立连接时，需要提供消息接收接口，用于处理未设置回调的消息。建议在连接之前，调用 setMessag

蔚落/ 2022年11月05日 09:57/ 0 赞/ 259 阅读

相关 java 开发指南_开发指南（Java）

设置消息接收接口连接建立后，服务端会立即向SDK推送已订阅的消息。因此，建立连接时，需要提供消息接收接口，用于处理未设置回调的消息。建议在连接之前，调用 setMessag

约定不等于承诺〃/ 2022年11月05日 08:56/ 0 赞/ 265 阅读

相关 boost开发指南

C++确实很复杂，神一样的0x不知道能否使C++变得纯粹和干爽？ boost很复杂，感觉某些地方有过度设计和太过于就事论事的嫌疑，对实际开发工作的考虑太过于理想化。学习boo

客官°小女子只卖身不卖艺/ 2022年08月13日 14:47/ 0 赞/ 289 阅读

相关 SMSLib开发指南

一、SMSLib简介 [SMSLib][]是一个开放源代码的短信猫二次开发包，有JAVA和.Net两个版本，目前最新版为v3.5.2。 ![1337509607_3496.

曾经终败给现在/ 2022年06月12日 12:17/ 0 赞/ 336 阅读

相关 flink项目开发-java代码模板开发flink指南

java代码开发flink指南必须的依赖创建项目检查项目构建/编译项目下一步通过几个简单的步骤就可以使用java程序开发

以你之姓@/ 2022年05月30日 10:14/ 0 赞/ 361 阅读

相关 JAVA开发新电脑安装指南

git config --global user.email “自己的邮箱” git config --globa [user.name][] “自己的姓名” 1、of

﹏ヽ暗。殇╰゛Y/ 2022年02月27日 09:18/ 0 赞/ 212 阅读

相关 xwiki开发者指南-脚本API指南

本次指南覆盖main XWiki，可以在wiki页面通过脚本使用的API。这并不意味着全面。对于其他你需要查看[XWiki参考API页面][XWiki_API]。请注意，虽

秒速五厘米/ 2022年02月22日 10:31/ 0 赞/ 378 阅读

相关 javadocker开发，Java校招面试指南

基本概念面试题集（ Spring 相关概念梳理） 1. 谈谈对Spring loC的理解? 2. 谈谈对Spring Dl的理解? 3. BeanFactory 接口和

矫情吗；*/ 2021年07月20日 19:03/ 0 赞/ 559 阅读

相关 Java开发指南！java下载安装步骤

一. 什么是架构和架构本质在软件行业，对于什么是架构，都有很多的争论，每个人都有自己的理解。此君说的架构和彼君理解的架构未必是一回事。因此我们在讨论架构之前，我们先讨

迈不过友情╰/ 2021年07月20日 11:39/ 0 赞/ 471 阅读

相关软件开发指南

1.很多时候，产品开发出来的效果和刚开始的设计以及客户的需求是不一致的，但是最后的结果是大家都接受的样子，虽然产物扭曲了，但是得到了大家的喜欢，所以很多时候我们需要顺其自然，不

柔情只为你懂/ 2021年05月12日 11:51/ 0 赞/ 638 阅读