广播通信 - 消息通信| 阿里云

背景信息

向全量在线设备广播消息
业务服务器调用PubBroadcast接口，传入指定产品的ProductKey和MessageContent消息内容，产品的全量在线设备可通过广播Topic/sys/${productKey}/${deviceName}/broadcast/request/${MessageId}，收到MessageContent消息内容。

广播Topic中的MessageId是物联网平台生成的消息ID，成功发送消息后，将作为PubBroadcast接口的返回数据返回业务服务器。

例如，厂家有多个智能门锁接入物联网平台，可通过业务服务器向全部在线设备发送一条相同的指令，使某个密码失效。
向订阅了指定Topic的所有设备广播消息
设备端订阅相同的广播Topic，业务服务器调用PubBroadcast接口，传入指定产品的ProductKey、MessageContent消息内容和要接收广播消息的Topic全称（格式为：/broadcast/${productKey}/自定义字段），已订阅广播Topic的在线设备，收到MessageContent消息内容。
注意
- 广播Topic是在设备开发时编码定义的，无需在物联网平台控制台创建。
- 一个广播Topic最多可被1,000个设备订阅。如果您的设备超过数量限制，您可以对设备进行分组。例如，如果您有5,000个设备，您可以将设备按每组1,000个，而分成5组。您需要分5次调用广播Topic，自定义字段分别设置为group1、group2、group3、group4、group5，然后让每组设备分别订阅各自分组的广播Topic。
广播接口调用的更多详细说明，请参见PubBroadcast。

使用限制

广播消息仅推送给产品下当前在线的设备。
指定在线设备广播时，需指定Topic订阅广播，广播接口最大调用频次：1次/秒。
全量在线设备广播时，无需订阅广播Topic，广播接口最大调用频次：1次/分钟。
广播消息体报文最大为64 KB。

注意广播消息不会被消息上下行TPS规格限流。例如，消息上下行TPS为100条/秒，当前在线设备为500个时，每次调用广播接口，消息不会只发送给100个在线设备，而是可以发送给500个在线设备。

准备开发环境

本示例中，设备端和云端均使用Java语言的SDK，需先准备Java开发环境。您可从Java 官方网站下载，并安装Java最新开发环境。

添加Maven项目依赖

新建项目，在pom.xml中，添加以下Maven依赖。

<dependencies>
  <dependency>
     <groupId>com.aliyun.alink.linksdk</groupId>
     <artifactId>iot-linkkit-java</artifactId>
     <version>1.2.0.1</version>
     <scope>compile</scope>
  </dependency>
  <dependency>
      <groupId>com.aliyun</groupId>
      <artifactId>aliyun-java-sdk-core</artifactId>
      <version>3.7.1</version>
  </dependency>
  <dependency>
      <groupId>com.aliyun</groupId>
      <artifactId>aliyun-java-sdk-iot</artifactId>
      <version>7.6.0</version>
  </dependency>
  <dependency>
    <groupId>com.aliyun.openservices</groupId>
    <artifactId>iot-client-message</artifactId>
    <version>1.1.2</version>
  </dependency>
</dependencies>

创建产品和设备

登录物联网平台控制台。
在左侧导航栏，单击设备管理 > 产品。
单击创建产品，创建智能门锁产品。具体操作，请参见创建产品。
在左侧导航栏，单击设备管理 > 设备，然后在智能门锁产品下，创建三个设备。具体操作，请参见批量创建设备。

配置设备端SDK

配置设备端接入物联网平台。

配置设备认证信息。
```
final String productKey = "<yourProductKey>";
final String deviceName = "<yourDeviceName>";
final String deviceSecret = "<yourDeviceSecret>";
final String region = "<yourRegionID>";
```
productKey、deviceName和deviceSecret是设备证书信息，请在物联网平台控制台，选择设备管理 > 设备，单击设备对应的查看，进入设备详情页获取。

region是设备所属地域。region的表达方法，请参见地域和可用区中的Region ID。

设置初始化连接参数，包括MQTT配置、设备信息和初始状态。

LinkKitInitParams params = new LinkKitInitParams();
//LinkKit底层是MQTT协议，设置MQTT配置。
IoTMqttClientConfig config = new IoTMqttClientConfig();
config.productKey = productKey;
config.deviceName = deviceName;
config.deviceSecret = deviceSecret;
config.channelHost = productKey + ".iot-as-mqtt." + region + ".aliyuncs.com:1883";
//设备信息。
DeviceInfo deviceInfo = new DeviceInfo();
deviceInfo.productKey = productKey;
deviceInfo.deviceName = deviceName;
deviceInfo.deviceSecret = deviceSecret;
//报备的设备初始状态。
Map<String, ValueWrapper> propertyValues = new HashMap<String, ValueWrapper>();
params.mqttClientConfig = config;
params.deviceInfo = deviceInfo;
params.propertyValues = propertyValues;

初始化连接。

//连接并设置连接成功以后的回调函数。
LinkKit.getInstance().init(params, new ILinkKitConnectListener() {
     @Override
     public void onError(AError aError) {
         System.out.println("Init error:" + aError);
     }
     //初始化成功以后的回调。
     @Override
     public void onInitDone(InitResult initResult) {
         System.out.println("Init done:" + initResult);
     }
 });

在回调函数onInitDone中，通过前缀来识别广播Topic，广播Topic的前缀为：/sys/${productKey}/${deviceName}/broadcast/request/。

public void onInitDone(InitResult initResult) {

                //设置下行消息到来时的回调函数。
                IConnectNotifyListener notifyListener = new IConnectNotifyListener() {
                    //此处定义收到下行消息以后的回调函数。
                    @Override
                    public void onNotify(String connectId, String topic, AMessage aMessage) {

                        //过滤得到广播消息。
                        if(topic.startsWith(broadcastTopic)){
                            System.out.println(
                                    "received broadcast message from topic=" + topic + ",\npayload=" + new String((byte[])aMessage.getData()));
                        }

                    }

                    @Override
                    public boolean shouldHandle(String s, String s1) {
                        return false;
                    }

                    @Override
                    public void onConnectStateChange(String s, ConnectState connectState) {

                    }
                };
                LinkKit.getInstance().registerOnNotifyListener(notifyListener);
            }

配置服务端SDK

配置云端Java SDK发送广播消息。

配置身份认证信息。

 String regionId = "<yourRegionID>";
 String accessKey = "<yourAccessKey>";
 String accessSecret = "<yourAccessSecret>";
 final String productKey = "<yourProductKey>";

配置服务端调用云端API PubBroadcast广播消息。

//设置client的参数。
DefaultProfile profile = DefaultProfile.getProfile(regionId, accessKey, accessSecret);
IAcsClient client = new DefaultAcsClient(profile);
PubBroadcastRequest request = new PubBroadcastRequest();
//设置广播消息的产品productKey。
request.setProductKey(productKey);
//设置消息的内容，一定要用base64编码，否则乱码。
request.setMessageContent(Base64.encode("{\"pwd\":\"2892nd6Y\"}"));

服务端发送广播消息。

try {
    PubBroadcastResponse response = client.getAcsResponse(request);
System.out.println("broadcast pub success: broadcastId =" + response.getMessageId());
} catch (Exception e) {
    System.out.println(e);
}

验证操作

先运行各设备的Link SDK代码，使设备上线，然后运行云端SDK代码，调用接口PubBroadcast向设备广播消息。

云端SDK中，向设备端广播的消息内容为："{\"pwd\":\"2892nd6Y\"}"。

设备端本地日志都将显示收到广播消息：{\"pwd\":\"2892nd6Y\"}。

门锁1：

门锁2：

门锁3：

附录：Demo

查看以下完整的配置代码Demo，其中包含物联网平台云端SDK和设备端SDK示例。

向全量在线设备广播消息：下载PubBroadcastDemo。
向订阅了指定Topic的所有设备广播消息：下载BroadcastDemo。