题外话
我老爸也问我物联网发展的趋势是什么!!!!!!
我自己感觉的:(正在朝着 "我,机器人" 这部电影的服务器方向发展)
以后的设备都会和服务器交互,就是说本地不再做处理,全部的处理数据是在一个庞大的服务器端
咱现在手机上的各种软件以后也不会安装在手机了,所有的都是在服务器端
现在的微信小程序,阿里小程序等等,正是在把应用程序放到了他们的服务器端运行.
这种运行方式考验两方面:
1.服务器处理能力
2.网络数据通信速度
只要是这两方面达到了,就会使很多东西革新换代(像电脑和手机),当前也会促使其它行业发展起来.
前言
这节让大家知道Android是怎么连接的MQTT
使用的是下面这个包
官方下载地址
https://docs.emqx.io/sdk_tools?category=MQTT_Clients
新建工程,导入jar包
jar包拷贝到新工程的app/libs目录
软件设置加载jar包
连接MQTT
public class MainActivity extends AppCompatActivity { private static MqttClient mqttClient; private static MqttConnectOptions mqttConnectOptions; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); mqttConnectOptions = new MqttConnectOptions();//MQTT的连接设置 mqttConnectOptions.setCleanSession(true);//清除连接信息 mqttConnectOptions.setUserName("yang");//设置连接的用户名 mqttConnectOptions.setPassword("11223344".toCharArray());//设置连接的密码 mqttConnectOptions.setConnectionTimeout(3);// 设置连接超时时间 单位为秒 mqttConnectOptions.setKeepAliveInterval(60);//心跳包时间60S try { mqttClient = new MqttClient( "tcp://47.92.31.46:1883",//连接的地址信息 System.currentTimeMillis()+"",//ClientID,使用当前时间戳 new MemoryPersistence());// mqttClient.setCallback(new MqttCallback() {//回调函数 @Override//连接断开 public void connectionLost(Throwable throwable) { } @Override//接收到消息 public void messageArrived(String s, MqttMessage mqttMessage) throws Exception { } @Override//没用过 public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { } }); new Thread(new Runnable() {//用任务 @Override public void run() { try { mqttClient.connect(mqttConnectOptions); if (mqttClient.isConnected()) { Log.e("Mqtt Info", "ConnectSuccess"); } }catch (Exception e){ Log.e("Mqtt Err", e.toString()); } } }).start(); } catch (Exception e){ Log.e("Mqtt Err", e.toString()); } } }
添加网络通信权限
<uses-permission android:name="android.permission.INTERNET" />
下载到手机测试
订阅主题,打印接收的消息
Log.e("MqttMsg:", "Topic:"+s+" "+"Msg:"+mqttMessage.toString());
mqttClient.subscribe("1111",0);//订阅1111,消息等级0
测试
发送消息
final MqttMessage msgMessage = new MqttMessage(mqttMessage.toString().getBytes());
new Thread(new Runnable() {//用任务
@Override
public void run() {
try {
mqttClient.publish("2222",msgMessage);//发布主题为2222的消息
}catch (Exception e){
Log.e("Mqtt Err", e.toString());
}
}
}).start();
测试