devbox
盐析白兔
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

物联网平台搭建的全过程介绍（五）——基于阿里云物联网平台的Android聊天app源码_基于阿里云物联网平台的android物联网软件框架

作者：盐析白兔 | 2024-05-21 03:33:45

赞

踩

基于阿里云物联网平台的android物联网软件框架

本例程Android源码请点此处免费下载

物联网平台搭建的全过程介绍（四）两台设备之间通过云数据流转实现远程通信之Android studio例程中介绍了两台Android设备通过物联网平台进行通信的步骤；

可调颜色大小可加粗可设置段落自动滚到最后一行的TextView

中介绍了用两个按键模拟聊天界面的实现步骤。

那么下一步就把以上两部分内容结合起来，把两个按键中的一个“发送2”监听换成mqtt接收到消息的监听，接收另外一台设备数据流转过来的信息，并显示在TextView中。“发送1”按键监听中，除把发送内容显示在TextView之外，还要通过mqtt发送到物联网平台，然后流转到另外一台设备。这样就真正实现了类似微信、QQ聊天的即时通信app。本例还增加了登录界面和设置昵称的功能。

目录

一、界面设计

1、前台布局

2、layout代码

(1)登录界面activity_login.xml

(2)聊天界面activity_main.xml

(3)设置昵称settings.xml

二、java程序

1、工程文件目录图

 2、java文件

(1)AiotMqttOption.java

(2)登录loginActivity.java

（3)设置settingsActivity.java

(4)主程序聊天MainActivity.java

三、物联网数据流转解析器配置

1、产品功能定义

2、数据源

3、数据目的

4、解析器脚本

四、测试

1、聊天界面

 2、物联网平台接收数据

 五、本例今后需要改进的地方

1、登录的实用化改进

2、添加好友、建群功能的实现

3、阿里云物联网平台API的调用

一、界面设计

1、前台布局

登录界面

聊天界面

设置昵称界面

  

2、layout代码

(1)登录界面activity_login.xml

  1. <?xml version="1.0" encoding="utf-8"?>
  2. <androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
  3.     xmlns:app="http://schemas.android.com/apk/res-auto"
  4.     xmlns:tools="http://schemas.android.com/tools"
  5.     android:layout_width="match_parent"
  6.     android:layout_height="match_parent"
  7.     android:background="@mipmap/back0"
  8.     tools:context=".loginActivity">
  9.     
  10.     <LinearLayout
  11.         android:layout_width="match_parent"
  12.         android:layout_height="match_parent"
  13.         android:layout_marginTop="50dp"
  14.         android:orientation="vertical">
  15.         <LinearLayout
  16.             android:layout_width="match_parent"
  17.             android:layout_height="50dp"
  18.             android:layout_marginTop="10dp"
  19.             android:gravity="center"
  20.  
  21.             android:orientation="horizontal">
  22.             <ImageView
  23.                 android:id="@+id/pirlogo"
  24.                 android:layout_width="133dp"
  25.                 android:layout_height="54dp"
  26.                 app:layout_constraintTop_toTopOf="parent"
  27.                 app:layout_constraintHorizontal_bias="0.2"
  28.                 app:layout_constraintLeft_toLeftOf="parent"
  29.                 app:layout_constraintRight_toRightOf="parent"
  30.                 app:layout_constraintBottom_toBottomOf="parent"
  31.                 app:layout_constraintVertical_bias="0.25"
  32.                 android:src="@drawable/ic_stat_name"/>
  33.         </LinearLayout>
  34.  
  35.         <LinearLayout
  36.             android:layout_width="match_parent"
  37.             android:layout_height="wrap_content"
  38.             android:layout_marginTop="50dp"
  39.             android:gravity="center"
  40.  
  41.             android:orientation="horizontal">
  42.             <TextView
  43.                 android:layout_width="wrap_content"
  44.                 android:layout_height="wrap_content"
  45.                 android:textColor="@color/chocolate"
  46.                 android:gravity="center"
  47.                 android:textSize="25dp"
  48.                 android:text="我的聊聊"/>
  49.         </LinearLayout>
  50.         <LinearLayout
  51.             android:layout_width="match_parent"
  52.             android:layout_height="wrap_content"
  53.             android:layout_marginTop="50dp"
  54.             android:layout_marginLeft="20dp"
  55.             android:layout_marginRight="20dp"
  56.             android:orientation="horizontal">
  57.             <TextView
  58.                 android:layout_width="0dp"
  59.                 android:layout_height="wrap_content"
  60.                 android:layout_weight="0.3"
  61.                 android:gravity="center"
  62.                 android:textColor="@color/forestgreen"
  63.                 android:textSize="18dp"
  64.                 android:text="用户名:"/>
  65.             <EditText
  66.                 android:id="@+id/name"
  67.                 android:layout_width="0dp"
  68.                 android:layout_height="wrap_content"
  69.                 android:textColor="@color/black"
  70.                 android:layout_weight="1"
  71.                 />
  72.         </LinearLayout>
  73.  
  74.         <LinearLayout
  75.             android:layout_width="match_parent"
  76.             android:layout_height="wrap_content"
  77.             android:layout_marginTop="10dp"
  78.             android:layout_marginLeft="20dp"
  79.             android:layout_marginRight="20dp"
  80.             android:orientation="horizontal">
  81.             <TextView
  82.                 android:layout_width="0dp"
  83.                 android:layout_height="wrap_content"
  84.                 android:gravity="center"
  85.                 android:textSize="18dp"
  86.                 android:textColor="@color/forestgreen"
  87.                 android:layout_weight="0.3"
  88.                 android:text="密    码:"/>
  89.             <EditText
  90.                 android:id="@+id/pwd"
  91.                 android:layout_width="0dp"
  92.                 android:layout_height="wrap_content"
  93.                 android:inputType="textPassword"
  94.                 android:textColor="@color/black"
  95.                 android:layout_weight="1"
  96.                 />
  97.         </LinearLayout>
  98.         <LinearLayout
  99.             android:layout_width="match_parent"
  100.             android:layout_height="wrap_content"
  101.             android:layout_marginTop="10dp"
  102.             android:layout_marginLeft="20dp"
  103.             android:layout_marginRight="20dp"
  104.             android:orientation="horizontal">
  105.             <Button
  106.                 android:id="@+id/login"
  107.                 android:layout_width="wrap_content"
  108.                 android:layout_height="wrap_content"
  109.                 android:layout_weight="1"
  110.                 android:layout_margin="5dp"
  111.                 android:background="@drawable/button0"
  112.                 android:textColor="@color/black"
  113.                 android:text="@string/login"
  114.                 />
  115.             <Button
  116.                 android:id="@+id/settings"
  117.                 android:layout_width="wrap_content"
  118.                 android:layout_height="wrap_content"
  119.                 android:layout_weight="1"
  120.                 android:layout_margin="5dp"
  121.                 android:background="@drawable/button0"
  122.                 android:textColor="@color/black"
  123.                 android:text="@string/settings"
  124.                 />
  125.         </LinearLayout>
  126.  
  127.     </LinearLayout>
  128.  
  129. </androidx.constraintlayout.widget.ConstraintLayout>

(2)聊天界面activity_main.xml

  1. <?xml version="1.0" encoding="utf-8"?>
  2. <androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
  3.     xmlns:app="http://schemas.android.com/apk/res-auto"
  4.     xmlns:tools="http://schemas.android.com/tools"
  5.     android:layout_width="match_parent"
  6.     android:layout_height="match_parent"
  7.     android:background="@color/wechat_bottombar"
  8.     tools:context=".MainActivity">
  9.  
  10.     <LinearLayout
  11.         android:layout_width="match_parent"
  12.         android:layout_height="match_parent"
  13.         android:layout_marginLeft="0dp"
  14.         android:layout_marginTop="0dp"
  15.         android:layout_marginRight="0dp"
  16.         android:background="@drawable/bg_stoke_4"
  17.         android:layout_marginBottom="0dp"
  18.         android:orientation="vertical">
  19.  
  20.         <LinearLayout
  21.             android:layout_width="match_parent"
  22.             android:layout_height="wrap_content"
  23.             android:layout_marginLeft="0dp"
  24.             android:layout_marginTop="0dp"
  25.             android:layout_marginRight="0dp"
  26.             android:background="@drawable/bg_stoke_4"
  27.             android:layout_marginBottom="0dp"
  28.             android:layout_weight="0"
  29.             android:orientation="horizontal">
  30.  
  31.                 <TextView
  32.                     android:id="@+id/tv_title"
  33.                     android:layout_width="match_parent"
  34.                     android:layout_height="wrap_content"
  35.                     android:scrollbars="vertical"
  36.                     android:background="@drawable/bg_stoke_4"
  37.                     android:layout_weight="1"
  38.                     android:textSize="16dp"
  39.                     android:typeface="sans"
  40.                     android:textColor="@color/black"
  41.                     android:textStyle="normal"
  42.                     android:padding="10dp"
  43.                     android:gravity="center"
  44.                     android:layout_marginLeft="10dp"
  45.                     android:layout_marginRight="10dp"
  46.                     app:layout_constraintBottom_toBottomOf="parent"
  47.                     app:layout_constraintLeft_toLeftOf="parent"
  48.                     app:layout_constraintRight_toRightOf="parent"
  49.                     app:layout_constraintTop_toTopOf="parent" />
  50.  
  51.         </LinearLayout>
  52.  
  53.  
  54.     <LinearLayout
  55.         android:layout_width="match_parent"
  56.         android:layout_height="match_parent"
  57.         android:layout_marginLeft="0dp"
  58.         android:layout_marginTop="5dp"
  59.         android:layout_marginRight="0dp"
  60.         android:background="@drawable/bg_stoke_1"
  61.         android:layout_marginBottom="0dp"
  62.         android:layout_weight="1"
  63.         android:orientation="horizontal">
  64.  
  65.         <ScrollView
  66.             android:id="@+id/sv_chat"
  67.             android:layout_width="fill_parent"
  68.             android:layout_height="wrap_content"
  69.             android:layout_marginTop="5dp"
  70.             android:background="@drawable/bg_stoke_4"
  71.             >
  72.         <TextView
  73.             android:id="@+id/tv_content"
  74.             android:layout_width="match_parent"
  75.             android:layout_height="wrap_content"
  76.             android:scrollbars="vertical"
  77.             android:background="@drawable/bg_stoke_4"
  78.             android:focusable="true"
  79.             android:layout_marginTop="5dp"
  80.             android:layout_marginLeft="10dp"
  81.             android:layout_marginRight="10dp"
  82.             app:layout_constraintBottom_toBottomOf="parent"
  83.             app:layout_constraintLeft_toLeftOf="parent"
  84.             app:layout_constraintRight_toRightOf="parent"
  85.             app:layout_constraintTop_toTopOf="parent" />
  86.         </ScrollView>
  87.     </LinearLayout>
  88.  
  89.         <LinearLayout
  90.             android:layout_width="match_parent"
  91.             android:layout_height="wrap_content"
  92.             android:layout_marginLeft="0dp"
  93.             android:layout_marginTop="0dp"
  94.             android:layout_marginRight="0dp"
  95.             android:background="@drawable/bg_stoke_3"
  96.             android:layout_marginBottom="0dp"
  97.             android:layout_weight="0"
  98.             android:gravity="center"
  99.             android:orientation="horizontal">
  100.  
  101.             <EditText
  102.                 android:id="@+id/et_send_content"
  103.                 android:layout_width="wrap_content"
  104.                 android:layout_height="wrap_content"
  105.                 android:background="@color/white"
  106.                 android:layout_marginLeft="10dp"
  107.                 android:layout_marginTop="0dp"
  108.                 android:layout_marginRight="10dp"
  109.                 android:layout_marginBottom="0dp"
  110.                 android:textSize="16dp"
  111.                 android:typeface="sans"
  112.                 android:textColor="@color/black"
  113.                 android:textStyle="normal"
  114.                 android:padding="8dp"
  115.                 android:layout_weight="1"
  116.                 />
  117.  
  118.             <Button
  119.                 android:id="@+id/btn_send"
  120.                 android:layout_width="wrap_content"
  121.                 android:layout_height="wrap_content"
  122.                 android:layout_margin="5dp"
  123.                 android:layout_marginBottom="0dp"
  124.                 android:layout_weight="0"
  125.                 app:layout_constraintBottom_toBottomOf="parent"
  126.                 app:layout_constraintRight_toRightOf="parent"
  127.                 android:background="@drawable/button0"
  128.                 android:text="@string/chat_send2"
  129.                 android:textSize="16dp"
  130.                 />
  131.  
  132.         </LinearLayout>
  133.  
  134.     </LinearLayout>
  135.  
  136. </androidx.constraintlayout.widget.ConstraintLayout>

(3)设置昵称settings.xml

  1. <?xml version="1.0" encoding="utf-8"?>
  2. <androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
  3.     xmlns:app="http://schemas.android.com/apk/res-auto"
  4.     xmlns:tools="http://schemas.android.com/tools"
  5.     android:layout_width="match_parent"
  6.     android:layout_height="match_parent"
  7.     android:background="@color/wechat_bottombar"
  8.     tools:context=".settingsActivity">
  9.  
  10.     <LinearLayout
  11.         android:layout_width="match_parent"
  12.         android:layout_height="match_parent"
  13.         android:layout_marginLeft="0dp"
  14.         android:layout_marginTop="0dp"
  15.         android:layout_marginRight="0dp"
  16.         android:background="@drawable/bg_stoke_4"
  17.         android:layout_marginBottom="0dp"
  18.         android:orientation="vertical">
  19.  
  20.         <LinearLayout
  21.             android:layout_width="match_parent"
  22.             android:layout_height="wrap_content"
  23.             android:layout_marginLeft="0dp"
  24.             android:layout_marginTop="0dp"
  25.             android:layout_marginRight="0dp"
  26.             android:background="@drawable/bg_stoke_1"
  27.             android:layout_marginBottom="0dp"
  28.             android:layout_weight="0"
  29.             android:orientation="horizontal">
  30.  
  31.             <TextView
  32.                 android:id="@+id/tv_setings_title"
  33.                 android:layout_width="match_parent"
  34.                 android:layout_height="wrap_content"
  35.                 android:scrollbars="vertical"
  36.                 android:background="@drawable/bg_stoke_4"
  37.                 android:layout_weight="1"
  38.                 android:textSize="16dp"
  39.                 android:typeface="sans"
  40.                 android:textColor="@color/black"
  41.                 android:textStyle="normal"
  42.                 android:padding="5dp"
  43.                 android:gravity="center"
  44.                 android:layout_marginTop="0dp"
  45.                 android:layout_marginLeft="10dp"
  46.                 android:layout_marginRight="10dp"
  47.                 app:layout_constraintBottom_toBottomOf="parent"
  48.                 app:layout_constraintLeft_toLeftOf="parent"
  49.                 app:layout_constraintRight_toRightOf="parent"
  50.                 app:layout_constraintTop_toTopOf="parent" />
  51.  
  52.         </LinearLayout>
  53.  
  54.         <LinearLayout
  55.             android:layout_width="match_parent"
  56.             android:layout_height="wrap_content"
  57.             android:layout_marginLeft="0dp"
  58.             android:layout_marginTop="100dp"
  59.             android:layout_marginRight="0dp"
  60.             android:background="@drawable/bg_stoke_4"
  61.             android:layout_marginBottom="0dp"
  62.             android:layout_weight="0"
  63.             android:orientation="horizontal">
  64.  
  65.             <TextView
  66.  
  67.                 android:layout_width="wrap_content"
  68.                 android:layout_height="wrap_content"
  69.                 android:scrollbars="vertical"
  70.                 android:background="@drawable/bg_stoke_4"
  71.                 android:layout_weight="1"
  72.                 android:textSize="16dp"
  73.                 android:typeface="sans"
  74.                 android:textColor="@color/black"
  75.                 android:textStyle="normal"
  76.                 android:padding="10dp"
  77.                 android:gravity="center"
  78.                 android:text="我的昵称:"
  79.                 android:layout_marginLeft="10dp"
  80.                 android:layout_marginRight="10dp"
  81.                  />
  82.  
  83.             <TextView
  84.                 android:id="@+id/tv_setings_nickname"
  85.                 android:layout_width="wrap_content"
  86.                 android:layout_height="wrap_content"
  87.                 android:gravity="center"
  88.                 android:textSize="18dp"
  89.                 android:textColor="@color/forestgreen"
  90.                 android:layout_weight="1"
  91.                 android:text="我的昵称"/>
  92.  
  93.         </LinearLayout>
  94.  
  95.  
  96.  
  97.         <LinearLayout
  98.             android:layout_width="match_parent"
  99.             android:layout_height="wrap_content"
  100.             android:layout_marginLeft="0dp"
  101.             android:layout_marginTop="10dp"
  102.             android:layout_marginRight="0dp"
  103.             android:background="@drawable/bg_stoke_4"
  104.             android:layout_marginBottom="0dp"
  105.             android:layout_weight="0"
  106.             android:gravity="center"
  107.             android:orientation="horizontal">
  108.  
  109.  
  110.             <EditText
  111.                 android:id="@+id/et_settings_nickname"
  112.                 android:layout_width="wrap_content"
  113.                 android:layout_height="wrap_content"
  114.                 android:background="@color/white"
  115.                 android:layout_marginLeft="10dp"
  116.                 android:layout_marginTop="0dp"
  117.                 android:layout_marginRight="10dp"
  118.                 android:layout_marginBottom="0dp"
  119.                 android:textSize="16dp"
  120.                 android:typeface="sans"
  121.                 android:textColor="@color/black"
  122.                 android:textStyle="normal"
  123.                 android:padding="8dp"
  124.                 android:layout_weight="1"
  125.  
  126.                 />
  127.  
  128.             <Button
  129.                 android:id="@+id/btn_set"
  130.                 android:layout_width="wrap_content"
  131.                 android:layout_height="wrap_content"
  132.                 android:layout_margin="5dp"
  133.                 android:layout_marginBottom="0dp"
  134.                 android:layout_weight="0"
  135.                 app:layout_constraintBottom_toBottomOf="parent"
  136.                 app:layout_constraintRight_toRightOf="parent"
  137.                 android:background="@drawable/button0"
  138.                 android:text="@string/btn_set"
  139.                 android:textSize="16dp"
  140.                 />
  141.  
  142.         </LinearLayout>
  143.  
  144.     </LinearLayout>
  145.  
  146. </androidx.constraintlayout.widget.ConstraintLayout>

二、java程序

1、工程文件目录图

 2、java文件

(1)AiotMqttOption.java

  1. package com.example.myaliyunchat;
  2.  
  3. import java.math.BigInteger;
  4. import javax.crypto.Mac;
  5. import javax.crypto.spec.SecretKeySpec;
  6.  
  7. /**
  8.  * MQTT建连选项类，输入设备三元组productKey, deviceName和deviceSecret, 生成Mqtt建连参数clientId，username和password.
  9.  */
  10. class AiotMqttOption {
  11.     private String username = "";
  12.     private String password = "";
  13.     private String clientId = "";
  14.  
  15.     String getUsername() { return this.username;}
  16.     String getPassword() { return this.password;}
  17.     String getClientId() { return this.clientId;}
  18.  
  19.     /**
  20.      * 获取Mqtt建连选项对象
  21.      * @param productKey 产品秘钥
  22.      * @param deviceName 设备名称
  23.      * @param deviceSecret 设备机密
  24.      * @return AiotMqttOption对象或者NULL
  25.      */
  26.     public AiotMqttOption getMqttOption(String productKey, String deviceName, String deviceSecret) {
  27.         if (productKey == null || deviceName == null || deviceSecret == null) {
  28.             return null;
  29.         }
  30.  
  31.         try {
  32.             String timestamp = Long.toString(System.currentTimeMillis());
  33.  
  34.             // clientId
  35.             this.clientId = productKey + "." + deviceName + "|timestamp=" + timestamp +
  36.                     ",_v=paho-android-1.0.0,securemode=2,signmethod=hmacsha256|";
  37.  
  38.             // userName
  39.             this.username = deviceName + "&" + productKey;
  40.  
  41.             // password
  42.             String macSrc = "clientId" + productKey + "." + deviceName + "deviceName" +
  43.                     deviceName + "productKey" + productKey + "timestamp" + timestamp;
  44.             String algorithm = "HmacSHA256";
  45.             Mac mac = Mac.getInstance(algorithm);
  46.             SecretKeySpec secretKeySpec = new SecretKeySpec(deviceSecret.getBytes(), algorithm);
  47.             mac.init(secretKeySpec);
  48.             byte[] macRes = mac.doFinal(macSrc.getBytes());
  49.             password = String.format("%064x", new BigInteger(1, macRes));
  50.         } catch (Exception e) {
  51.             e.printStackTrace();
  52.             return null;
  53.         }
  54.  
  55.         return this;
  56.     }
  57. }

(2)登录loginActivity.java

  1. package com.example.myaliyunchat;
  2.  
  3.  
  4. import android.content.Intent;
  5. import android.content.SharedPreferences;
  6. import android.os.Bundle;
  7. import android.view.View;
  8. import android.widget.Button;
  9. import android.widget.EditText;
  10. import android.widget.Toast;
  11. import androidx.appcompat.app.AppCompatActivity;
  12. public class loginActivity extends AppCompatActivity {
  13.  
  14.  
  15.     private EditText User_name,User_pwd;
  16.  
  17.     String loginer1="20220001";
  18.     String loginer2="20220002";
  19.     String Password1="123456";
  20.     String Password2="654321";
  21.     boolean check1;
  22.     boolean check2;
  23.     String str_name;
  24.     String str_pwd;
  25.  
  26.     SharedPreferences sp_user;
  27.  
  28.  
  29.     @Override
  30.     protected void onCreate(Bundle savedInstanceState) {
  31.         super.onCreate(savedInstanceState);
  32.  
  33.         setContentView(R.layout.activity_login);
  34.  
  35.         User_name = this.findViewById(R.id.name);            //用户名输入框
  36.         User_pwd = this.findViewById(R.id.pwd);              //密码输入框
  37.         Button btnlogin = this.findViewById(R.id.login);         //登录按钮
  38.         Button btn_set = this.findViewById(R.id.settings);
  39.  
  40.         sp_user=this.getSharedPreferences("sp_user",this.MODE_PRIVATE);
  41.         User_name.setText(sp_user.getString("Name",null));
  42.         User_pwd.setText(sp_user.getString("Password",null));
  43.  
  44.  
  45.         btnlogin.setOnClickListener(new View.OnClickListener() {
  46.             @Override
  47.             public void onClick(View v) {
  48.  
  49.                 SharedPreferences.Editor editor = sp_user.edit();
  50.  
  51.                 str_name = User_name.getText().toString();
  52.                 str_pwd = User_pwd.getText().toString();
  53.                 check1=(str_name.equals(loginer1)) &&(str_pwd.equals(Password1));
  54.                 check2=(str_name.equals(loginer2)) &&(str_pwd.equals(Password2));
  55.  
  56.                 if(check1 || check2)
  57.                 {
  58.                     editor.putString("Name", str_name);
  59.                     editor.putString("Password", str_pwd);
  60.                     editor.apply();
  61.  
  62.                     Intent intent = new Intent(loginActivity.this, MainActivity.class);
  63.                     startActivity(intent);
  64.                 }
  65.                 else
  66.                 {
  67.                     User_name.setText("");
  68.                     User_pwd.setText("");
  69.                     Toast toast = Toast.makeText(loginActivity.this, getText(R.string.wrong_neme_or_psw), Toast.LENGTH_LONG);
  70.                     toast.show();
  71.  
  72.                 }
  73.             }
  74.         });
  75.  
  76.         btn_set.setOnClickListener(new View.OnClickListener() {
  77.             @Override
  78.             public void onClick(View v) {
  79.  
  80.                     Intent intent = new Intent(loginActivity.this, settingsActivity.class);
  81.                     startActivity(intent);
  82.                 }
  83.  
  84.         });
  85.  
  86. }
  87.  
  88.  
  89. }
  90.

(3)设置settingsActivity.java

  1. package com.example.myaliyunchat;
  2.  
  3. import android.content.SharedPreferences;
  4. import android.os.Bundle;
  5. import android.view.View;
  6. import android.widget.Button;
  7. import android.widget.EditText;
  8. import android.widget.TextView;
  9. import androidx.appcompat.app.AppCompatActivity;
  10.  
  11. public class settingsActivity extends AppCompatActivity {
  12.  
  13.     private EditText et_nickname;
  14.     TextView tv_title,tv_nickname;
  15.     String str_nickname;
  16.     SharedPreferences sp_user;//存放用户账号、密码、昵称信息
  17.  
  18.     @Override
  19.     protected void onCreate(Bundle savedInstanceState) {
  20.         super.onCreate(savedInstanceState);
  21.         setContentView(R.layout.settings);
  22.         tv_title = this.findViewById(R.id.tv_setings_title);//标题栏
  23.         et_nickname = this.findViewById(R.id.et_settings_nickname);//昵称输入框
  24.         tv_nickname= this.findViewById(R.id.tv_setings_nickname);//昵称显示
  25.         Button btn_set = this.findViewById(R.id.btn_set);         //设置确认
  26.         tv_title.setText(R.string.settings_title);
  27.  
  28.         sp_user=this.getSharedPreferences("sp_user",this.MODE_PRIVATE);
  29.         tv_nickname.setText(sp_user.getString("nickname",null));
  30.         btn_set.setOnClickListener(new View.OnClickListener() {
  31.             @Override
  32.             public void onClick(View v) {
  33.  
  34.                 SharedPreferences.Editor editor = sp_user.edit();
  35.                 str_nickname = et_nickname.getText().toString();
  36.                 editor.putString("nickname", str_nickname);
  37.                 editor.apply();
  38.                 tv_nickname.setText(sp_user.getString("nickname",null));
  39.                 et_nickname.setText("");
  40.  
  41.             }
  42.         });
  43.  
  44. }
  45.  
  46. }
  47.

(4)主程序聊天MainActivity.java

  1. package com.example.myaliyunchat;
  2.  
  3.  
  4. import androidx.appcompat.app.AppCompatActivity;
  5. import android.annotation.SuppressLint;
  6. import android.content.SharedPreferences;
  7. import android.os.Bundle;
  8. import android.text.Html;
  9. import android.util.Log;
  10. import android.view.View;
  11. import android.view.ViewTreeObserver;
  12. import android.widget.Button;
  13. import android.widget.EditText;
  14. import android.widget.ScrollView;
  15. import android.widget.TextView;
  16. import org.eclipse.paho.client.mqttv3.IMqttActionListener;
  17. import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
  18. import org.eclipse.paho.client.mqttv3.IMqttToken;
  19. import org.eclipse.paho.client.mqttv3.MqttCallback;
  20. import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
  21. import org.eclipse.paho.client.mqttv3.MqttException;
  22. import org.eclipse.paho.client.mqttv3.MqttMessage;
  23. import org.json.JSONException;
  24. import org.json.JSONObject;
  25. import org.eclipse.paho.android.service.MqttAndroidClient;
  26. import java.text.SimpleDateFormat;
  27. import java.util.Date;
  28. import java.util.Locale;
  29. import java.util.Objects;
  30.  
  31.  
  32. public class MainActivity extends AppCompatActivity {
  33.  
  34.     /* 设备三元组信息 */
  35.     //20220002
  36.     private String IotInstanceId="";
  37.     private String PRODUCTKEY="";
  38.     private String DEVICENAME="";
  39.     private String DEVICESECRET="";
  40.  
  41.     //20221001
  42.     private String PRODUCTKEY1="***********";
  43.     private String DEVICENAME1="20220001";
  44.     private String DEVICESECRET1="*********************************";
  45.  
  46.     //20220002
  47.     private String PRODUCTKEY2="***********";
  48.     private String DEVICENAME2="20220002";
  49.     private String DEVICESECRET2="*********************************";
  50.  
  51.     String loginName;
  52.     String NickName;
  53.     String loginer1="20220001";
  54.     String loginer2="20220002";
  55.  
  56.     //系统默认昵称
  57.     String NickName1="曹操";
  58.     String NickName2="刘备";
  59.  
  60.  
  61.     /* 自动Topic, 用于上报消息 */
  62.     private String PUB_TOPIC;
  63.  
  64.     /* 自动Topic, 用于接受消息 */
  65.     private String SUB_TOPIC;
  66.  
  67.     /* 阿里云Mqtt服务器域名 */
  68.     String host;
  69.  
  70.     /*Mqtt建连参数*/
  71.     private String clientId;
  72.     private String userName;
  73.     private String passWord;
  74.  
  75.     //设置log.e的TAG
  76.     private final String TAG = "AiotMqtt";
  77.  
  78.     MqttAndroidClient mqttAndroidClient;
  79.  
  80.     SharedPreferences sp_user;//存放用户账号、密码、昵称信息
  81.  
  82.     //ui相关变量
  83.     TextView tv_content,tv_title;
  84.     EditText et_send_content;
  85.     Button btn_send;
  86.     ScrollView scrollView;
  87.  
  88.     @SuppressLint("WrongViewCast")
  89.     @Override
  90.     protected void onCreate(Bundle savedInstanceState) {
  91.         super.onCreate(savedInstanceState);
  92.         setContentView(R.layout.activity_main);
  93.  
  94.         scrollView=this.findViewById(R.id.sv_chat);
  95.         tv_content= this.findViewById(R.id.tv_content);
  96.         tv_title= this.findViewById(R.id.tv_title);
  97.         tv_content.setSelected(true);
  98.  
  99.  
  100.         et_send_content=this.findViewById(R.id.et_send_content);
  101.         tv_content.setTextSize(16);
  102.  
  103.         btn_send= findViewById(R.id.btn_send);
  104.  
  105.         sp_user=this.getSharedPreferences("sp_user",this.MODE_PRIVATE);
  106.         loginName=sp_user.getString("Name",null);
  107.  
  108.  
  109.         //根据登录账号的不同分别选择不同的阿里云三要素、昵称
  110.         assert loginName != null;
  111.         if(loginName.equals(loginer1))
  112.         {
  113.             PRODUCTKEY=PRODUCTKEY1;
  114.             DEVICENAME=DEVICENAME1;
  115.             DEVICESECRET=DEVICESECRET1;
  116.             NickName=NickName1;
  117.         }
  118.         else if(loginName.equals(loginer2))
  119.         {
  120.             PRODUCTKEY=PRODUCTKEY2;
  121.             DEVICENAME=DEVICENAME2;
  122.             DEVICESECRET=DEVICESECRET2;
  123.             NickName=NickName2;
  124.         }
  125.         else
  126.         {
  127.             PRODUCTKEY="";
  128.             DEVICENAME="";
  129.             DEVICESECRET="";
  130.             NickName="";
  131.         }
  132.         if(Objects.requireNonNull(sp_user.getString("Name", null)).isEmpty())
  133.         {
  134.             if(loginName.equals(loginer1))
  135.             {
  136.                 NickName=NickName1;
  137.             }
  138.             else if(loginName.equals(loginer2))
  139.             {
  140.                 NickName=NickName2;
  141.             }
  142.             else
  143.             {
  144.                 NickName="";
  145.             }
  146.             SharedPreferences.Editor editor = sp_user.edit();
  147.             editor.putString("nickname", NickName);
  148.             editor.apply();
  149.         }
  150.  
  151.         NickName=sp_user.getString("nickname",null);
  152.  
  153.  
  154.         //根据阿里云三要素构建subtopic、pubtopic、host
  155.         AliyunTopicHostSet(0);
  156.  
  157.         //MQTT建连选项类，输入设备三元组productKey, deviceName和deviceSecret, 生成Mqtt建连参数clientId，username和password
  158.         AiotMqttOption aiotMqttOption = new AiotMqttOption().getMqttOption(PRODUCTKEY, DEVICENAME, DEVICESECRET);
  159.         if (aiotMqttOption == null) {
  160.             Log.e(TAG, "device info error");
  161.         } else {
  162.             clientId = aiotMqttOption.getClientId();
  163.             userName = aiotMqttOption.getUsername();
  164.             passWord = aiotMqttOption.getPassword();
  165.         }
  166.  
  167.  
  168.  
  169.         /* Mqtt建连 */
  170.         try {
  171.  
  172.             /* 创建MqttConnectOptions对象并配置username和password */
  173.             final MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
  174.             mqttConnectOptions.setUserName(userName);
  175.             mqttConnectOptions.setPassword(passWord.toCharArray());
  176.  
  177.             /* 创建MqttAndroidClient对象, 并设置回调接口 */
  178.             //String plstring;
  179.             mqttAndroidClient = new MqttAndroidClient(getApplicationContext(), host, clientId);
  180.             mqttAndroidClient.connect(mqttConnectOptions,null, new IMqttActionListener() {
  181.                 //连接成功方法
  182.                 @Override
  183.                 public void onSuccess(IMqttToken asyncActionToken) {
  184.                     Log.i(TAG, "connect succeed");
  185.  
  186.                     subscribeTopic(SUB_TOPIC);
  187.                 }
  188.                 //连接失败方法
  189.                 @Override
  190.                 public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
  191.                     Log.i(TAG, "connect failed");
  192.                 }
  193.             });
  194.  
  195.         } catch (MqttException e) {
  196.             e.printStackTrace();
  197.         }
  198.  
  199.         /**
  200.          * mqtt回调类，此类内包含三个方法：connectionLost（掉线），messageArrived（订阅消息到达），deliveryComplete（发布消息送达）
  201.          */
  202.         mqttAndroidClient.setCallback(new MqttCallback() {
  203.  
  204.             //连接中断方法
  205.             @Override
  206.             public void connectionLost(Throwable cause) {
  207.                 Log.i(TAG, "connection lost");
  208.             }
  209.  
  210.             @SuppressLint("SetTextI18n")
  211.             @Override
  212.  
  213.             //订阅消息后，消息到达时方法
  214.             public void messageArrived(String topic, MqttMessage message) throws Exception {
  215.  
  216.                 Log.i(TAG, "topic: " + topic + ", msg: " + new String(message.getPayload()));
  217.  
  218.                 String payload = new String(message.getPayload());
  219. //                JSONObject Jobj_payload = new JSONObject(payload);
  220. //                JSONObject Jobj_params=new JSONObject(Jobj_payload.getString("params"));
  221.  
  222.                 JSONObject Jobj_params = new JSONObject(payload);
  223.  
  224.                 String chat_user=Jobj_params.getString("user");
  225.                 String char_message=Jobj_params.getString("message");
  226.                 Date curDate = new Date(System.currentTimeMillis());
  227.                 SimpleDateFormat format= new SimpleDateFormat("M月d日 HH:mm", Locale.getDefault());
  228.                 String str_curDate = format.format(curDate);
  229.  
  230.                 tv_content.append( Html.fromHtml("<font color='#696969' size='5'>"+chat_user +"("+str_curDate+"):"+"</font>"+"<br>"));
  231.                 tv_content.append( Html.fromHtml("<p><font color='#D2691E' size='5'>"+char_message+"</font><p>"+"<br>"));
  232.                 tv_title.setText(chat_user);
  233.  
  234.             }// messageArrived类结束标志
  235.  
  236.             //发布消息后，消息投递成功后返回方法
  237.             @Override
  238.             public void deliveryComplete(IMqttDeliveryToken token) {
  239.                 Log.i(TAG, "msg delivered");
  240.             }
  241.         });//mqttAndroidClient.setCallback类结束标志
  242.  
  243.  
  244.  
  245.         /**
  246.          * 点"上传"按钮后，将数学、语文分数发送到阿里云物联网平台
  247.          */
  248.         btn_send.setOnClickListener((view)-> {
  249.  
  250.  
  251.             String send_content=et_send_content.getText().toString();
  252.             Date curDate = new Date(System.currentTimeMillis());
  253.             SimpleDateFormat format= new SimpleDateFormat("M月d日 HH:mm", Locale.getDefault());
  254.             String str_curDate = format.format(curDate);
  255.  
  256.             tv_content.append( Html.fromHtml("<font color='#696969' size='10'>"+NickName+"("+str_curDate+"):"+"</font>"+"<br>"));
  257.             tv_content.append( Html.fromHtml("<p><font color='#3CB371' size='10'>"+send_content+"</font><p>"+"<br>"));
  258.             et_send_content.setText("");
  259.  
  260.             //发布消息的payload数据包生成方法一：利用JSONObject，分两层将params内的数学、语文分数，和params外的id，version打成一个json数据包
  261.             JSONObject Jobj_payload = new JSONObject();
  262.             JSONObject Jobj_params = new JSONObject();
  263.             try {
  264.                 Jobj_params.put("message",send_content);
  265.                 Jobj_params.put("user_id",NickName);
  266.                 Jobj_payload.put("id", DEVICENAME);
  267.                 Jobj_payload.put("version", "1.0");
  268.                 Jobj_payload.put("params", Jobj_params);
  269.  
  270.             } catch (JSONException e) {
  271.                 e.printStackTrace();
  272.             }
  273.             publishMessage(Jobj_payload.toString());
  274.             et_send_content.setText("");
  275. //            scrollView.fullScroll(ScrollView.FOCUS_DOWN);
  276.  
  277.  
  278.         });
  279.  
  280.         scrollView.getViewTreeObserver().addOnGlobalLayoutListener(new ViewTreeObserver.OnGlobalLayoutListener() {
  281.             @Override
  282.  
  283.             public void onGlobalLayout() {
  284.                 scrollView.post(new Runnable() {
  285.                     public void run() {
  286.                         scrollView.fullScroll(View.FOCUS_DOWN);
  287.  
  288.                     }
  289.  
  290.                 });
  291.  
  292.             }
  293.  
  294.         });
  295.     }//oncreat结束标志
  296.  
  297.  
  298.     /**
  299.      * 设置阿里云物联网平台参数
  300.      * @param IotInstanceType 实例类型，0:华东2（上海）服务器公共实例;1:企业实例
  301.      */
  302.     public void AliyunTopicHostSet(int IotInstanceType) {
  303.  
  304.         SUB_TOPIC ="/sys/" + PRODUCTKEY + "/" + DEVICENAME + "/thing/service/property/set";
  305.         PUB_TOPIC = "/sys/" + PRODUCTKEY + "/" + DEVICENAME + "/thing/event/property/post";
  306.  
  307.         if(IotInstanceType==0)
  308.         {
  309.             host="tcp://" + PRODUCTKEY + ".iot-as-mqtt.cn-shanghai.aliyuncs.com:1883";//适用于公共实例华东2(上海)
  310.         }
  311.         else
  312.         {
  313.             host="tcp://" + IotInstanceId + ".mqtt.iothub.aliyuncs.com:1883";//试用于企业实例
  314.         }
  315.  
  316.     }
  317.  
  318.     /**
  319.      * 订阅特定的主题
  320.      * @param topic mqtt主题
  321.      */
  322.     public void subscribeTopic(String topic) {
  323.         try {
  324.             mqttAndroidClient.subscribe(topic, 0, null, new IMqttActionListener() {
  325.                 @Override
  326.                 public void onSuccess(IMqttToken asyncActionToken) {
  327.                     Log.i(TAG, "subscribed succeed");
  328.                 }
  329.  
  330.                 @Override
  331.                 public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
  332.                     Log.i(TAG, "subscribed failed");
  333.                 }
  334.             });
  335.  
  336.         } catch (MqttException e) {
  337.             e.printStackTrace();
  338.         }
  339.     }
  340.  
  341.     /**
  342.      * 向默认的主题/user/update发布消息
  343.      * @param payload 消息载荷
  344.      */
  345.     public void publishMessage(String payload) {
  346.         try {
  347.             if (!mqttAndroidClient.isConnected()) {
  348.                 mqttAndroidClient.connect();
  349.             }
  350.  
  351.             MqttMessage message = new MqttMessage();
  352.             message.setPayload(payload.getBytes());
  353.             message.setQos(0);
  354.             mqttAndroidClient.publish(PUB_TOPIC, message,null, new IMqttActionListener() {
  355.                 @Override
  356.                 public void onSuccess(IMqttToken asyncActionToken) {
  357.                     Log.i(TAG, "publish succeed!");
  358.                 }
  359.  
  360.                 @Override
  361.                 public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
  362.                     Log.i(TAG, "publish failed!");
  363.                 }
  364.             });
  365.         } catch (MqttException e) {
  366.             Log.e(TAG, e.toString());
  367.             e.printStackTrace();
  368.         }
  369.     }
  370. }

三、物联网数据流转解析器配置

1、产品功能定义

产品名称：我的聊聊，在该产品下创建两个设备：20220001和20220002

2、数据源

3、数据目的

4、解析器脚本

  1. var data = payload("json");
  2.  
  3. var select = {};
  4.  
  5. select.put("message", getOrNull(data,"items","message","value"));
  6. select.put("user", getOrNull(data,"items","user_id","value"));
  7.  
  8.  
  9. if(deviceName()=="20220001")
  10. {
  11. writeIotTopic(1003, "/sys/***********/20220002/thing/service/property/set", select);
  12. }
  13.  
  14. if(deviceName()=="20220002")
  15. {
  16. writeIotTopic(1003, "/sys/***********/20220001/thing/service/property/set", select);

因为数据源选择的是全部设备，所以20220001和20220002上传的数据都会流转到解析器来，所以在脚本中，要控制设备上传的数据不转发自己本身，只转发给另外一个用户。

四、测试

1、聊天界面

刘备端截图1

刘备端截图2

 2、物联网平台接收数据

曹操端上传数据

曹操端“聊天消息”记录

 五、本例今后需要改进的地方

1、登录的实用化改进

本例“我的聊聊”app两个登录账号以及两组阿里云物联网平台的三要素都是固定存在app内的，实际聊天工具应该把“我的聊聊”登录账号、密码、昵称以及对应的阿里云三要素存放到云服务器或者云数据库内。首先要访问数据库或者服务器web页面，验证账号和密码，通过之后，再从数据库中取出昵称、阿里云三要素，然后再使用这组三要素连接物联网平台，完成接入、订阅和发布的功能。

2、添加好友、建群功能的实现

本例只是实现了一对一聊天的基本功能，更加实用的聊天工具需要可以添加好友、建群，可以选择不同好友进行一对一聊天，可以群聊。这些功能需要app端相应功能，还要配合解析器脚本的合理化设计。

3、阿里云物联网平台API的调用

本例物联网平台设备的创建和云数据流转都是通过手工进行的，实际的项目需要能在app端调用API来自动创建。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/盐析白兔/article/detail/600627
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号