商业源码 如何将CC3200接入机智云
1 登录机智云
请确保在开始之前已经注册了机智云开发者账号，如果没有可以访问机智云网站注册
2 创建新设备
在登录之后添加一个CC3200 LaunchPad 设备，或者也可以通过模板去创建一个。
为CC3200 LaunchPad LED D7 创建一个数据点
按照 向导点击下一步，最后可以按照demo APP，或者下载SDK去定制APP
3 获取Product Key
在设备创建好之后，进入个人项目，然后得到Product Key
CC3200的代码存放在githubcom，请从下面的链接来下载
https://githubcom/yhpan0613/SimpleLink-CC3200/releases
选择一个版本，然后点击zip就可以获取到最新的代码
修改CC3200代码
在SimpleLink-CC3200git\example\getting_started_with_wlan_station\gagent\include的gagenth里面有一个宏定义：#define PRODUCT_KEY,
请将它修改成为上面你创建好的设备的product key
在commonh里面修改你要连接路由器的SSID和密码。
5 运行程序连接到机智云
用IAR打开wlan_stationeww, 然后编译下载到CC3200LP里面运行
连接到机智云分为两个步骤，第一个通过访问HTTP Server来获取MQTT服务器的IP
第二步是每隔50秒发MQTT心跳包PING，服务器会返回心跳包的回应PONG。
如果有看到下面的LOG说明心跳是正常的：
INFO MQTT Send packet length=2
CRITICAL GAgent Cloud Ping
CRITICAL GAgent Cloud Pong
3 从机智云网站上可以看到你的设备的状态信息：
6 可以在机智云网站上生成IOE demo的APP，在手机上安装，然后就可以扫描到CC3200 Launchpad，进行绑定。
7 添加内容去为你的设备做定制化的数据交互。
希望可以帮助到你
"Mqtt"是一种消息传输协议，用于在物联网中传输数据。当您说打印机无法连接到MQTT服务器时，这意味着打印机无法通过Mqtt协议和服务器进行通信。
可能的原因包括：
1 MQTT服务器地址或端口号设置不正确。
2 MQTT服务器无法访问或已停止服务。
3 打印机没有正确配置Mqtt客户端配置，以便与MQTT服务器进行通信。
4 打印机与网络连接不良或网络故障。
为了解决这个问题，您可以尝试以下步骤：
1 检查MQTT服务器地址和端口是否正确，并确认服务器是否正常运行。
2 检查打印机的Mqtt客户端配置是否正确，包括认证信息、主题等，并尝试重新配置。
3 检查打印机与网络的连接状态并排除网络故障。
如果您需要进一步的帮助，请查阅打印机或MQTT的相关手册或联系相关技术支持。
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方法，如果项目中需要知道客户端是否掉线可以调用该方法。
0条评论