微信小程序--P2P消息收发模式（MQTT）

前端贾公子 2023-04-03 原文

前言

P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即拥有一个或多个消息发送者和多个消息接收者的场景。

在P2P模式中，发送者发送消息时已经明确该消息预期的接收者信息，并明确该消息只需要被特定的单个客户端消费。发送者发送消息时通过Topic信息直接指定接收者，接收者无需提前订阅即可获取该消息。

P2P模式不仅可以为接收者节省注册订阅关系的成本，此外，由于收发消息的链路有单独的优化，还可以降低推送延迟。

参考文档：P2P消息收发模式（MQTT）

https://help.aliyun.com/document_detail/96176.html?spm=a2c4g.11186623.2.13.229f42caHWXK5fhttps://help.aliyun.com/document_detail/96176.html?spm=a2c4g.11186623.2.13.229f42caHWXK5f参考文档：P2P消息收发模式 .Client.

https://www.eclipse.org/paho/files/jsdoc/Paho.MQTT.Client.htmlhttps://www.eclipse.org/paho/files/jsdoc/Paho.MQTT.Client.html参考文档 paho-mqtt基础库

https://github.com/AwakenCN/InChat/blob/paho-mqtt/wechat-client/utils/paho-mqtt.jshttps://github.com/AwakenCN/InChat/blob/paho-mqtt/wechat-client/utils/paho-mqtt.js

参考文档阿里云安全库

https://cdnjs.cloudflare.com/ajax/libs/crypto-js/3.1.9-1/crypto-js.jshttps://cdnjs.cloudflare.com/ajax/libs/crypto-js/3.1.9-1/crypto-js.js

js demo

<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
        "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
    <title>Aliyun Mqtt Websockets</title>
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <script src="https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.js" type="text/javascript"></script>
    <script src="https://cdnjs.cloudflare.com/ajax/libs/crypto-js/3.1.9-1/crypto-js.js" type="text/javascript"></script>
    <script type="text/javascript">
        instanceId = 'XXXX';//实例 ID，购买后从控制台获取
        host = 'XXXX.mqtt.aliyuncs.com';// 设置当前用户的接入点域名，接入点获取方法请参考接入准备章节文档，先在控制台创建实例
        port = 80;//WebSocket 协议服务端口，如果是走 HTTPS，设置443端口
        topic = 'XXXX';//需要操作的 Topic,第一级父级 topic 需要在控制台申请
        useTLS = false;//是否走加密 HTTPS，如果走 HTTPS，设置为 true
        accessKey = 'XXXXX';//账号的 AccessKey，在阿里云控制台查看
        secretKey = 'XXXXX';//账号的的 SecretKey，在阿里云控制台查看
        cleansession = true;
        groupId = 'GID_XXXX';//MQTT GroupID,创建实例后从 MQTT 控制台创建
        clientId = groupId + '@@@00001';//GroupId@@@DeviceId，由控制台创建的 Group ID 和自己指定的 Device ID 组合构成
        var mqtt;
        var reconnectTimeout = 2000;
        var username = 'Signature|' + accessKey + '|' + instanceId;//username和 Password 签名模式下的设置方法，参考文档 https://help.aliyun.com/document_detail/48271.html?spm=a2c4g.11186623.6.553.217831c3BSFry7
        var password = CryptoJS.HmacSHA1(clientId, secretKey).toString(CryptoJS.enc.Base64);

        function MQTTconnect() {
            mqtt = new Paho.MQTT.Client(
                host,//MQTT 域名
                port,//WebSocket 端口，如果使用 HTTPS 加密则配置为443,否则配置80
                clientId//客户端 ClientId
            );
            var options = {
                timeout: 3,
                onSuccess: onConnect,
                mqttVersion: 4,
                cleanSession: cleansession,
                onFailure: function (message) {
                    setTimeout(MQTTconnect, reconnectTimeout);
                }
            };
            mqtt.onConnectionLost = onConnectionLost;
            mqtt.onMessageArrived = onMessageArrived;
            if (username != null) {
                options.userName = username;
                options.password = password;
                options.useSSL = useTLS;//如果使用 HTTPS 加密则配置为 true
            }
            mqtt.connect(options);
        }

        function onConnect() {
            // Connection succeeded; subscribe to our topic
            //发送 P2P 消息，topic 设置方式参考https://help.aliyun.com/document_detail/96176.html?spm=a2c4g.11186623.6.586.694f7cb4oookL7
            message = new Paho.MQTT.Message("Hello mqtt P2P Msg!!");//set body
            message.destinationName = topic + "/p2p/" + clientId;// set topic
            mqtt.send(message);
        }

        function onConnectionLost(response) {
            setTimeout(MQTTconnect, reconnectTimeout);
        };

        function onMessageArrived(message) {
            var topic = message.destinationName;
            var payload = message.payloadString;
            console.log("recv msg : " + topic + "   " + payload);
        };
        MQTTconnect();
    </script>
</head>
</html>

参数

new Paho.Client 创建对象

JavaScript应用程序使用Paho.MQTT.Client对象与服务器通信。

大多数应用程序只创建一个Client对象，然后调用其connect（）方法，但是如果需要，应用程序可以创建多个Client对象。在这种情况下，每个客户端对象的主机、端口和clientId属性的组合必须不同。

发送、订阅和取消订阅方法被实现为异步JavaScript方法（即使底层协议交换本质上可能是同步的）。这意味着它们通过调用应用程序（通过应用程序提供的有关方法的成功或失败回调函数）来发出完成的信号。这种回调在每个方法调用中最多调用一次，并且不会持续到调用脚本的生命周期之外。

相比之下，Paho.MQTT.Client对象上定义了一些回调函数，尤其是onMessageArrived。这些方法可能会被多次调用，并且与客户端进行的特定方法调用没有直接关系。

host字符串消息服务器的地址，作为完全限定的WebSocket URI，作为DNS名称或虚线十进制IP地址。
port number要连接到的端口号-仅当主机不是URI时才需要
path字符串要连接到的主机上的路径-仅当主机不是URI时使用。默认值：'/mqt'。
clientId字符串消息传递客户端标识符，长度在1到23个字符之间。

onConnectionLost 连接丢失回调

当连接丢失时调用。connect（）方法成功后。建立连接丢失时使用的回调。连接可能会丢失，因为客户端启动了断开连接，或者因为服务器或网络导致客户端断开连接。例如，如果客户端无法连接，则可以在不调用connectionComplete回调的情况下调用disconnect回调。将单个响应对象参数传递给onConnectionLost回调，该回调包含以下字段：

errorCode 错误代码
errorMessage 错误消息

onMessageArrived 监听数据

当消息到达此Paho.MQTT.客户端时调用。传递给onMessageArrived回调的参数为

destinationName：强制消息要发送到的目的地的名称（对于即将发送的消息）或接收消息的目的地名称。（用于onMessage功能接收的消息）。
payloadString ：只读如果有效负载包含有效的UTF-8字符，则将有效负载作为字符串
payloadBytes ：只读作为ArrayBuffer的有效负载
qs：用于传递消息的服务质量。0最大努力（默认）。1至少一次。2正好一次。
retained：如果为true，则服务器将保留该消息，并将其传递给当前订阅和未来订阅。如果为false，则服务器仅将消息传递给当前订户，这是新消息的默认值。如果消息发布时保留的布尔值设置为true，并且在消息发布后进行了订阅，则收到的消息将保留的布尔设置为true。
duplicate ：只读如果为true，则此消息可能与已接收的消息重复。这仅在从服务器接收的消息上设置。

disconnect（） :关闭链接

connect (connectOptions)将此消息客户端连接到其服务器。

connectOptions用于连接的属性

timeout : 如果在该秒数内连接未成功，则视为连接失败。默认值为30秒
userName 此连接的身份验证用户名
password:此连接的身份验证密码。
onSuccess:当从服务器接收到连接确认时调用。单个响应对象参数传递给onSuccess回调，该回调包含以下字段： invocationContext传递给connectOptions中的onSuccess方法。
cleanSession:清除会话 cleanif true（默认值）成功连接时删除客户端和服务器的持久状态。
mqttVersion 用于连接到MQTT代理的MQTT版本。 3or4
useSSL 如果存在且为真，请使用SSL Websocket连接。{如果使用 HTTPS 加密则配置为 true}
onFailure:当连接请求失败或超时时调用。单个响应对象参数传递给onFailure回调，该回调包含以下字段：

传入connectOptions中onFailure方法的invocationContext。
errorCode表示错误性质的数字。
error描述错误的消息文本。

mqtt 频繁断开和重连问题

mqtt.js底层没有对你调用它方法传入的callback函数做异常捕获（你传入callback函数里面不做异常捕获，会导致mqtt底层代码逻辑异常，导致频繁断连&重连问题发生），所以你所有的callback函数都需要增加try..catch..方法捕获异常（比如发布，订阅，监听等方法调用的时候的第二个callback函数）

小程序实践

 const Paho = require('../../utils/mqtt');
 const CryptoJS = require('../../utils/crypto-js.js');
 let instanceId = 'XXXX';//实例 ID，购买后从控制台获取
 let host = 'XXXX.mqtt.aliyuncs.com';// 设置当前用户的接入点域名，接入点获取方法请参考接入准备章节文档，先在控制台创建实例
 let port = 80;//WebSocket 协议服务端口，如果是走 HTTPS，设置443端口
 let topic = 'XXXX';//需要操作的 Topic,第一级父级 topic 需要在控制台申请
 let useTLS = false;//是否走加密 HTTPS，如果走 HTTPS，设置为 true
 let accessKey = 'XXXXX';//账号的 AccessKey，在阿里云控制台查看
 let secretKey = 'XXXXX';//账号的的 SecretKey，在阿里云控制台查看
 let cleansession = true;
 let groupId = 'GID_XXXX';//MQTT GroupID,创建实例后从 MQTT 控制台创建
 let clientId = groupId + '@@@00001';//GroupId@@@DeviceId，由控制台创建的 Group ID 和自己指定的 Device ID 组合构成
 var mqtt;
 var reconnectTimeout = 2000;
 var username = 'Signature|' + accessKey + '|' + instanceId;//username和 Password 签名模式下的设置方法，参考文档 https://help.aliyun.com/document_detail/48271.html?spm=a2c4g.11186623.6.553.217831c3BSFry7
 var password = CryptoJS.HmacSHA1(clientId, secretKey).toString(CryptoJS.enc.Base64);

onLoad(options) {
 this.MQTTconnect()
},
// MQTT连接
  MQTTconnect() {
    try {
      let that = this
      //创建mqtt对象
      mqtt = new Paho.Client(
        host,//MQTT 域名
        port,//WebSocket 端口，如果使用 HTTPS 加密则配置为443,否则配置80
        clientId//客户端 ClientId
      );
      // 准备链接属性
      var options = {
        timeout: 3, //超时时间
        onSuccess: that.onConnect, //当从服务器接收到连接确认时调用
        mqttVersion: 4,//用于连接到MQTT代理的MQTT版本。
        cleanSession: cleansession,//清除会话  cleanif true（默认值）成功连接时删除客户端和服务器的持久状态。
        onFailure: function (message) {//当连接请求失败或超时时调用。
          console.log(message, "连接请求失败或超时。");
          setTimeout(that.MQTTconnect, reconnectTimeout);
        }
      };

      mqtt.onConnectionLost = that.onConnectionLost;  //连接丢失回调
      mqtt.onMessageArrived = that.onMessageArrived;  //监听数据回调

      if (username != null) {
        options.userName = username;//此连接的身份验证密码。
        options.password = password;//此连接的身份验证用户名s
        options.useSSL = useTLS;//如果使用 HTTPS 加密则配置为 true
      }
      //链接
      mqtt.connect(options);
    } catch (error) {

    }
  },
  //当从服务器接收到连接确认时调用
  onConnect() {
    try {
      // Connection succeeded; subscribe to our topic
      //发送 P2P 消息，topic 设置方式参考https://help.aliyun.com/document_detail/96176.html?spm=a2c4g.11186623.6.586.694f7cb4oookL7
      message = new Paho.Message("Hello mqtt P2P Msg!!");//set body
      message.destinationName = topic + "/p2p/" + clientId;// set topic
      mqtt.send(message);
    } catch (error) {

    }
  },
  //连接丢失回调
  onConnectionLost(response) {
    try {
      let that = this
      console.log("连接丢失了:" + response.errorCode + response.errorMessage)
      setTimeout(that.MQTTconnect, reconnectTimeout);
    } catch (error) {

    }
  },
  //监听数据
  onMessageArrived(message) {
    try {
      var topic = message.destinationName;
      var payload = message.payloadString;
      console.log("recv msg : " + topic + "   " + payload);
    } catch (error) {

    }
  },

单例模式 mqtt 封装

保证只有一个链接对象，便于复用，页使用面重写 onConnectionLost & onMessageArrived

getInstance 创建链接
onConnect 服务器确认链接回调
disconnect 关闭链接
onConnectionLost 连接丢失回调
onMessageArrived 监听数据
onFailure 创建链接失败回调页面传入callback
info 链接信息

initMqtt文件

var single = (function () {
    let mqtt, instanceId, host, port, accessKey, secretKey, clientId, username, password, topic;
    let i = 0
    let cleansession = true; // true（默认值）成功连接时删除客户端和服务器的持久状态。
    let useTLS = true;//是否走加密 HTTPS，如果走 HTTPS，设置为 true
    // 创建链接
    function getInstance(callback, info) {
        try {
            console.log('getInstance执行', mqtt, i++);
            if (mqtt === undefined) {
                console.log('创建', info);
                instanceId = info.instanceId;//实例 ID，购买后从控制台获取
                host = info.host;// 设置当前用户的接入点域名，接入点获取方法请参考接入准备章节文档，先在控制台创建实例
                port = 443;//WebSocket 协议服务端口，如果是走 HTTPS，设置443端口
                accessKey = info.accessKey;//账号的 AccessKey，在阿里云控制台查看
                secretKey = info.secretKey;//账号的的 SecretKey，在阿里云控制台查看
                clientId = info.client_id + info.xmid//GroupId@@@DeviceId，由控制台创建的 Group ID 和自己指定的 Device ID 组合构成
                username = 'Signature|' + accessKey + '|' + instanceId;//username和 Password 签名模式下的设置方法，参考文档 https://help.aliyun.com/document_detail/48271.html?spm=a2c4g.11186623.6.553.217831c3BSFry7
                password = CryptoJS.HmacSHA1(clientId, secretKey).toString(CryptoJS.enc.Base64);
                topic = info.topic;//需要操作的 Topic,第一级父级 topic 需要在控制台申请
                //创建mqtt对象
                mqtt = new Paho.Client(
                    host,//MQTT 域名
                    port,//WebSocket 端口，如果使用 HTTPS 加密则配置为443,否则配置80
                    clientId//客户端 ClientId
                );
            }
            // 准备链接属性
            var options = {
                timeout: 3, //超时时间
                onSuccess: onConnect, //当从服务器接收到连接确认时调用
                mqttVersion: 4,//用于连接到MQTT代理的MQTT版本。
                cleanSession: cleansession,//清除会话  cleanif true（默认值）成功连接时删除客户端和服务器的持久状态。
                onFailure: callback//当连接请求失败或超时时调用
            };
            mqtt.onConnectionLost = onConnectionLost;  //连接丢失回调
            mqtt.onMessageArrived = onMessageArrived;  //监听数据回调
            if (username != null) {
                options.userName = username;//此连接的身份验证密码。
                options.password = password;//此连接的身份验证用户名s
                options.useSSL = useTLS;//如果使用 HTTPS 加密则配置为 true
            }
            //链接
            mqtt.connect(options);
        } catch (error) { }
        return mqtt;
    }

    //服务器确认链接回调
    function onConnect() {
        try {
            // Connection succeeded; subscribe to our topic
            //发送 P2P 消息，topic 设置方式参考https://help.aliyun.com/document_detail/96176.html?spm=a2c4g.11186623.6.586.694f7cb4oookL7
            message = new Paho.Message("Hello mqtt P2P Msg!!");//set body
            message.destinationName = topic + "/p2p/" + clientId;// set topic
            mqtt.send(message);
        } catch (error) { }

    }
    // 关闭链接
    function Disconnect() {
        console.log('通道关闭 js文件');
        mqtt.disconnect()
        mqtt = undefined
    }
    // 连接丢失回调
    function onConnectionLost() {
        console.log("连接丢失回调 js文件");
    }
    // 监听数据
    function onMessageArrived() {
        console.log("监听数据js 文件");
    }
    return {
        getInstance: getInstance,
        Disconnect: Disconnect
    }

})();

页面创建链接

  onShow() {
    let that = this
    let mqtt = single.getInstance(that.onFailure)
    mqtt.onConnectionLost = this.onConnectionLost
    mqtt.onMessageArrived = this.onMessageArrived
  },
  // mqtt连接超时的回调
  onFailure(response) {
    let that = this
    console.log("连接超时:" + response.errorCode + response.errorMessage)
    if (response.errorCode != 8) {//8通道关闭
      setTimeout(function () {
        let mqtt = single.getInstance(that.onFailure)
        mqtt.onConnectionLost = that.onConnectionLost
        mqtt.onMessageArrived = that.onMessageArrived
      }, 2000);
    }
  },
  //监听数据
  onMessageArrived(message) {
    try {
      var topic = message.destinationName;
      var payload = JSON.parse(message.payloadString);
      console.log(payload, '通知');
    } catch (error) {

    }
  },
  // 连接丢失回调
  onConnectionLost(response) {
    try {
      let that = this
      console.log("连接丢失了:" + response.errorCode + response.errorMessage)
      if (response.errorCode != 0) {//0 链接关闭
        setTimeout(function () {
          let mqtt = single.getInstance(that.onFailure)
          mqtt.onConnectionLost = that.onConnectionLost
          mqtt.onMessageArrived = that.onMessageArrived
        }, 2000);
      }
    } catch (error) {

    }
  },

有关微信小程序--P2P消息收发模式（MQTT）的更多相关文章

ruby-on-rails - Rails - 子类化模型的设计模式是什么？ - 2
我有一个模型:classItem项目有一个属性“商店”基于存储的值，我希望Item对象对特定方法具有不同的行为。Rails中是否有针对此的通用设计模式？如果方法中没有大的if-else语句，这是如何干净利落地完成的？最佳答案通常通过Single-TableInheritance. 关于ruby-on-rails-Rails-子类化模型的设计模式是什么？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.co
ruby - 解析 RDFa、微数据等的最佳方式是什么，使用统一的模式/词汇(例如 schema.org)存储和显示信息 - 2
我主要使用Ruby来执行此操作，但到目前为止我的攻击计划如下:使用gemsrdf、rdf-rdfa和rdf-microdata或mida来解析给定任何URI的数据。我认为最好映射到像schema.org这样的统一模式，例如使用这个yaml文件，它试图描述数据词汇表和opengraph到schema.org之间的转换:#SchemaXtoschema.orgconversion#data-vocabularyDV:name:namestreet-address:streetAddressregion:addressRegionlocality:addressLocalityphoto:i
ruby - 如何在续集中重新加载表模式？ - 2
鉴于我有以下迁移:Sequel.migrationdoupdoalter_table:usersdoadd_column:is_admin,:default=>falseend#SequelrunsaDESCRIBEtablestatement,whenthemodelisloaded.#Atthispoint,itdoesnotknowthatusershaveais_adminflag.#Soitfails.@user=User.find(:email=>"admin@fancy-startup.example")@user.is_admin=true@user.save!ende
ruby-on-rails - 如何在 Rails View 上显示错误消息？ - 2
我是rails的新手，想在form字段上应用验证。myviewsnew.html.erb.....模拟.rbclassSimulation{:in=>1..25,:message=>'Therowmustbebetween1and25'}end模拟Controller.rbclassSimulationsController我想检查模型类中row字段的整数范围，如果不在范围内则返回错误信息。我可以检查上面代码的范围，但无法返回错误消息提前致谢最佳答案关键是您使用的是模型表单，一种显示ActiveRecord模型实例属性的表单。c
ruby - 是否有用于序列化和反序列化各种格式的对象层次结构的模式？ - 2
给定一个复杂的对象层次结构，幸运的是它不包含循环引用，我如何实现支持各种格式的序列化？我不是来讨论实际实现的。相反，我正在寻找可能会派上用场的设计模式提示。更准确地说:我正在使用Ruby，我想解析XML和JSON数据以构建复杂的对象层次结构。此外，应该可以将该层次结构序列化为JSON、XML和可能的HTML。我可以为此使用Builder模式吗？在任何提到的情况下，我都有某种结构化数据-无论是在内存中还是文本中-我想用它来构建其他东西。我认为将序列化逻辑与实际业务逻辑分开会很好，这样我以后就可以轻松支持多种XML格式。最佳答案我最
ruby - 使用 Ruby 通过 Outlook 发送消息的最简单方法是什么？ - 2
我的工作要求我为某些测试自动生成电子邮件。我一直在四处寻找，但未能找到可以快速实现的合理解决方案。它需要在outlook而不是其他邮件服务器中，因为我们有一些奇怪的身份验证规则，我们需要保存草稿而不是仅仅发送邮件的选项。显然win32ole可以做到这一点，但我找不到任何相当简单的例子。最佳答案假设存储了Outlook凭据并且您设置为自动登录到Outlook，WIN32OLE可以很好地完成此操作:require'win32ole'outlook=WIN32OLE.new('Outlook.Application')message=
Ruby - 如何将消息长度表示为 2 个二进制字节 - 2
我正在使用Ruby，我正在与一个网络端点通信，该端点在发送消息本身之前需要格式化“header”。header中的第一个字段必须是消息长度，它被定义为网络字节顺序中的2二进制字节消息长度。比如我的消息长度是1024。如何将1024表示为二进制双字节？最佳答案 Ruby(以及Perl和Python等)中字节整理的标准工具是pack和unpack。ruby的packisinArray.您的长度应该是两个字节长，并且按网络字节顺序排列，这听起来像是n格式说明符的工作:n|Integer|16-bitunsigned,network(bi
微信小程序通过字典表匹配对应数据 - 2
前言一般来说，前端根据后台返回code码展示对应内容只需要在前台判断code值展示对应的内容即可，但要是匹配的code码比较多或者多个页面用到时，为了便于后期维护，后台就会使用字典表让前端匹配，下面我将在微信小程序中通过wxs的方法实现这个操作。为什么要使用wxs？{{method(a,b)}}可以看到，上述代码是一个调用方法传值的操作，在vue中很常见，多用于数据之间的转换，但由于微信小程序诸多限制的原因，你并不能优雅的这样操作，可能有人会说，为什么不用if判断实现呢？但是if判断的局限性在于如果存在数据量过大时，大量重复性操作和if判断会让你的代码显得异常冗余。wxswxs相当于是一个独立
计算机毕业设计ssm+vue基本微信小程序的小学生兴趣延时班预约小程序 - 2
项目介绍随着我国经济迅速发展,人们对手机的需求越来越大,各种手机软件也都在被广泛应用,但是对于手机进行数据信息管理,对于手机的各种软件也是备受用户的喜爱小学生兴趣延时班预约小程序的设计与开发被用户普遍使用,为方便用户能够可以随时进行小学生兴趣延时班预约小程序的设计与开发的数据信息管理,特开发了小程序的设计与开发的管理系统。小学生兴趣延时班预约小程序的设计与开发的开发利用现有的成熟技术参考,以源代码为模板,分析功能调整与小学生兴趣延时班预约小程序的设计与开发的实际需求相结合,讨论了小学生兴趣延时班预约小程序的设计与开发的使用。开发环境开发说明：前端使用微信微信小程序开发工具：后端使用ssm：VU
微信小程序开发入门与实战（Behaviors使用） - 2
@作者:SYFStrive @博客首页:HomePage📜：微信小程序📌：个人社区（欢迎大佬们加入）👉：社区链接🔗📌：觉得文章不错可以点点关注👉：专栏连接🔗💃：感谢支持,学累了可以先看小段由小胖给大家带来的街舞👉微信小程序（🔥）目录自定义组件-behaviors 1、什么是behaviors 2、behaviors的工作方式 3、创建behavior 4、导入并使用behavior 5、behavior中所有可用的节点 6、同名字段的覆盖和组合规则总结最后自定义组件-behaviors 1、什么是behaviorsbehaviors是小程序中，用于实现