商业源码 阿里云mqtt收费标准
以下是阿里云mqtt收费标准：
其中铂金版实例、标准版实例、轻量版实例是包年包月（预付费）。是一种预付费模式，即先付费再使用。一般适用于业务量较大且长期运行的场景，通过包年包月付费方式您可以提前预留资源，同时享受更大的价格优化，帮您最大程度节省成本。
还有就是按量付费实例是按量付费（后付费）。即是一种后付费模式，即先使用再付费。一般适用于业务流量波峰波谷差异明显或临时测试的场景，可以有效避免资源浪费。
微消息队列mqtt版费用组成：
按量付费包括：同时在线连接数；消息收发量；订阅关系数
包年包月包括：连接数上限；消息TPS上限；订阅关系数上限
计价倍率介绍：
MQTT协议QoS=0且cleanSession=true 1
MQTT协议QoS=0且cleanSession=false 1
MQTT协议QoS=1且cleanSession=true 2
MQTT协议QoS=1且cleanSession=false 5
MQTT协议QoS=2且cleanSession=true 5
1、 下载Apollo服务器，下载后解压，然后运行apache-apollo-16\bin\apollocmd，输入create mybroker（名字任意取，这里是根据 官网 介绍的来取的）创建服务器实例，服务器实例包含了所有的配置，运行时数据等，并且和一个服务器进程关联。
2、create mybroker之后会在bin目录下生成mybroker文件夹，里面包含有很多信息，其中etc\apolloxml文件下是配置服务器信息的文件，etc\usersproperties文件包含连接MQTT服务器时用到的用户名和密码，后面会介绍，可以修改原始的admin=password，可以接着换行添加新的用户名密码。
3、打开cmd，运行…apache-apollo-16\bin\mybroker\bin\apollo-brokercmd run 开启服务器，可以在浏览器中输入 http://127001:61680/ 查看是否安装成功，该界面展示了topic，连接数等很多信息。
经过上面的简单步骤，服务器基本上就已经完成，下一篇将介绍Android客户端的编写和注意事项。
客户端使用的API，开始我使用的是mqtt-client，使用过后发现问题百出，不能很好的满足要求，后来使用了官方推荐的 Eclipse Paho ，下面开始客户端代码的编写，为了方便测试这里有android和j2se两个工程：
1、新建android工程MQTTClient
2、MainActivity代码如下：
[java] view plaincopyprint
package ldwmqttclient;
import javautilconcurrentExecutors;
import javautilconcurrentScheduledExecutorService;
import javautilconcurrentTimeUnit;
import orgeclipsepahoclientmqttv3IMqttDeliveryToken;
import orgeclipsepahoclientmqttv3MqttCallback;
import orgeclipsepahoclientmqttv3MqttClient;
import orgeclipsepahoclientmqttv3MqttConnectOptions;
import orgeclipsepahoclientmqttv3MqttException;
import orgeclipsepahoclientmqttv3MqttMessage;
import orgeclipsepahoclientmqttv3persistMemoryPersistence;
import androidappActivity;
import androidosBundle;
import androidosHandler;
import androidosMessage;
import androidviewKeyEvent;
import androidwidgetTextView;
import androidwidgetToast;
public class MainActivity extends Activity {
private TextView resultTv;
private String host = "tcp://127001:1883";
private String userName = "admin";
private String passWord = "password";
private Handler handler;
private MqttClient client;
private String myTopic = "test/topic";
private MqttConnectOptions options;
private ScheduledExecutorService scheduler;
@Override
protected void onCreate(Bundle savedInstanceState) {
superonCreate(savedInstanceState);
setContentView(Rlayoutmain);
resultTv = (TextView) findViewById(Ridresult);
init();
handler = new Handler() {
@Override
public void handleMessage(Message msg) {
superhandleMessage(msg);
if(msgwhat == 1) {
ToastmakeText(MainActivitythis, (String) msgobj,
ToastLENGTH_SHORT)show();
Systemoutprintln("-----------------------------");
} else if(msgwhat == 2) {
ToastmakeText(MainActivitythis, "连接成功", ToastLENGTH_SHORT)show();
try {
clientsubscribe(myTopic, 1);
} catch (Exception e) {
eprintStackTrace();
}
} else if(msgwhat == 3) {
ToastmakeText(MainActivitythis, "连接失败，系统正在重连", ToastLENGTH_SHORT)show();
}
}
};
startReconnect();
}
private void startReconnect() {
scheduler = ExecutorsnewSingleThreadScheduledExecutor();
schedulerscheduleAtFixedRate(new Runnable() {
@Override
public void run() {
if(!clientisConnected()) {
connect();
}
}
}, 0 1000, 10 1000, TimeUnitMILLISECONDS);
}
private void init() {
try {
//host为主机名，test为clientid即连接MQTT的客户端ID，一般以客户端唯一标识符表示，MemoryPersistence设置clientid的保存形式，默认为以内存保存
client = new MqttClient(host, "test",
new MemoryPersistence());
//MQTT的连接设置
options = new MqttConnectOptions();
//设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，这里设置为true表示每次连接到服务器都以新的身份连接
optionssetCleanSession(true);
//设置连接的用户名
optionssetUserName(userName);
//设置连接的密码
optionssetPassword(passWordtoCharArray());
// 设置超时时间 单位为秒
optionssetConnectionTimeout(10);
// 设置会话心跳时间 单位为秒 服务器会每隔1520秒的时间向客户端发送个消息判断客户端是否在线，但这个方法并没有重连的机制
optionssetKeepAliveInterval(20);
//设置回调
clientsetCallback(new MqttCallback() {
@Override
public void connectionLost(Throwable cause) {
//连接丢失后，一般在这里面进行重连
Systemoutprintln("connectionLost----------");
}
@Override
public void deliveryComplete(IMqttDeliveryToken token) {
//publish后会执行到这里
Systemoutprintln("deliveryComplete---------"
+ tokenisComplete());
}
@Override
public void messageArrived(String topicName, MqttMessage message)
throws Exception {
//subscribe后得到的消息会执行到这里面
Systemoutprintln("messageArrived----------");
Message msg = new Message();
msgwhat = 1;
msgobj = topicName+"---"+messagetoString();
handlersendMessage(msg);
}
});
// connect();
} catch (Exception e) {
eprintStackTrace();
}
}
private void connect() {
new Thread(new Runnable() {
@Override
public void run() {
try {
clientconnect(options);
Message msg = new Message();
msgwhat = 2;
handlersendMessage(msg);
} catch (Exception e) {
eprintStackTrace();
Message msg = new Message();
msgwhat = 3;
handlersendMessage(msg);
}
}
})start();
}
@Override
public boolean onKeyDown(int keyCode, KeyEvent event) {
if(client != null && keyCode == KeyEventKEYCODE_BACK) {
try {
clientdisconnect();
} catch (Exception e) {
eprintStackTrace();
}
}
return superonKeyDown(keyCode, event);
}
@Override
protected void onDestroy() {
superonDestroy();
try {
schedulershutdown();
clientdisconnect();
} catch (MqttException e) {
eprintStackTrace();
}
}
}
由于项目需要，我用到了心跳重连。根据 这里 的解释设置apolloxml，主要有设置主机连接的地址。另外，options还有个setWill方法，如果项目中需要知道客户端是否掉线可以调用该方法。
MQTT通信协议的基本介绍参考文章 NT35 MQTT通信 ，本篇给出阿里云的基本操作，NT35E通过订阅阿里云的主题&发布信息与阿里云平台相互通信。
登录阿里云 → 工作台 → 物联网平台 → 进入控制台→ 公共实例
阿里云默认通信协议为MQTT，不需要特殊选择，用户按照如下步骤创建自己的产品：
创建产品 → 添加设备
在"查看"标签中，包含了MQTT连接的基本三元组信息，也就是后面设备要填充的基本参数
用户每定义一类产品都会自动生成对应的Topic列表，当然我们也可以"自定义Topic"便于自己测试。
指令解析参考《Lierda NT35E&NT26E-CN AT命令手册》，这里给出使用到的AT指令对应参数说明以便于理解。
AT+LMQTTCFG=cloud,<tcpconnectID>[,<cloud _ type>,<data_type > ]
<tcpconnectID> 。MQTT Socket 标识符。范围：0~4。
<cloud_type>整型。2 alibaba，其他参数指定其他平台
<data_type>整型。阿里云平台 1 json数据
AT+LMQTTCFG="cloud",0,2,1 对应就是对接阿里云平台，发送json格式的数据
AT+LMQTTCFG=aliauth,<tcpconnectID>[,<product_key>,<device_name>,<device_secret>]
填充阿里云平台中设备的三元组信息
AT+LMQTTCFG="aliauth",0,"a1JszCpjS61","NT35E_06011","390358fc595040aa73221e8393aba86c"
这部分是模组进行TCP链路连接(需抓包确认)
AT+LMQTTOPEN=<tcpconnectID>,<host_name>,<port>
host_name对应阿里云 "设备信息"→"MQTT连接参数" 中的 "mqttHostUrl"
AT+LMQTTOPEN=0,"a1JszCpjS61iot-as-mqttcn-shanghaialiyuncscom",1883
模组作为客户端，通过MQTT协议连接到服务器(需抓包确认)
AT+LMQTTCONN=<tcpconnectID>[,<clientID>[,<username>[,<password>]]]
<clientID>字符串型。客户端标识符。用户可以随便定义。 <username>,<password> 不需要填写
AT+LMQTTCONN=0,"NT35E"
AT+LMQTTSUBUNSUB=<tcpconnectID>,<subflag>,<msgID>,<topic1>[,<qos1>[,<topic2>[,<qos2>]d…]]
<subflag>整型。消息类型 0 订阅 1 取消订阅
<msgID>整型。数据包消息标识符。范围：0~65535。
<topic>带双引号的字符串型。客户端订阅或者退订的主题。长度范围：0~256 字节。
<qos>整型。客户端发送订阅消息(SUBSCRIBE)的 QoS 等级，此时为必选参数。2 正好一次，该主题下的消息确保接收端仅接收到一次
AT+LMQTTSUBUNSUB=0,0,1,"/a1JszCpjS61/ NT35E_06011 /user/COMMUTEST",2
这里注意<topic>对应参数的替换，里面的deviceName需要替换。
订阅主题之后，服务器下发的数据模组就可以正常接收了。模组下发位置
发布消息在对应的设备目录下，如果有设备"订阅"对应的消息，平台"发布"相应的数据设备就可以接收到了。
AT+LMQTTPUB=<tcpconnectID>,<msgID>,<qos>,<retain>,<topic>,<msglen>,<msg>
<msgID>整型。 0~65535。任意定义，但<qos>=0 时，该参数值只能为0。
<qos>整型。 0 最多一次 1 至少一次 2 正好一次
<retain>整型 。服务器是否保存该消息。0 不保存 1 保存
<topic>带双引号的字符串型。 客户端发布消息的主题。长度范围：0~256 字节
<msglen>整型 。指定的消息数据长度。范围：0~1460。
<msg>字符串型。 需要发布的消息数据。
AT+LMQTTPUB=0,0,0,1,"/a1JszCpjS61/ NT35E_06011 /user/COMMUTEST",10,"1122334455"
注意刚刚自己创建的主题属性是" 发布和订阅 "，所以模组发送该主题的信息，阿里云也是可以收到的
注意这里模组发送数据的时候，也推送了自己发送的数据，因为刚刚订阅了这个主题，所以模组订阅(收)到了对应的数据
前面我们通过NT35E与平台进行信息交互，那么为什么是这样填写对应的参数呢，每个参数对应的说明在阿里云上是什么样的呢，用户可以查看阿里云的<帮助文档>进行确认。
上面我们使用三元组的方式( 一机一密 )实现NT35E与阿里云平台通信，但实际生产过程中该方式不好实现，比如工厂有1000个设备生产，如果每个设备都复制不同的三元组，很难实现工厂批量化生产，此时可以通过 一型一密 的通信方式解决该问题。
一型一密模组端实现方式后续更新。
0条评论