Android小Demo——通过MQTT协议连接OneNet平台（新版）

87 阅读 0 评论 58 点赞

我是靠谱客的博主怡然招牌，这篇文章主要介绍Android小Demo——通过MQTT协议连接OneNet平台（新版），现在分享给大家，希望可以做个参考。

详细的过程可参考：https://blog.csdn.net/weixin_51080921/article/details/124150694?spm=1001.2014.3001.5501

这里只是说明和旧版不一样的地方

第一个是服务器接入地址（非加密方式）：

复制代码

1
private static final String SERVER_URL = "tcp://mqtts.heclouds.com:1883";

第二个是设备ID（这里的设备ID直接是设备名字）：

复制代码

1
private static final String CLIENT_ID = "Android";

第三个是PASSWORD（这里的密码是Token生成的）：

可参考：https://blog.csdn.net/weixin_51080921/article/details/124197691?spm=1001.2014.3001.5501

中的第三步做法

下面说说加密方式连接：

首先是证书，可参考：https://blog.csdn.net/weixin_51080921/article/details/124253434?spm=1001.2014.3001.5501

onenet文档中心下载的证书格式是.pem的，Android中要用到的得转为.bks格式。

然后是服务器接入地址（关于是tcp还是ssl看自己喜欢，但是一定要前后匹配）：

复制代码

1
private static final String SERVER_URL = "ssl://mqttstls.heclouds.com:8883";

前面说的前后匹配是指：

复制代码Server URI and supplied <code>SocketFactory</code> do not match. URIs beginning <code>tcp://</code> must use a <code>javax.net.SocketFactory</code>, and URIs beginning <code>ssl://</code> must use a <code>javax.net.ssl.SSLSocketFactory</code>.
1
2
3
Server URI and supplied <code>SocketFactory</code> do not match.
URIs beginning <code>tcp://</code> must use a <code>javax.net.SocketFactory</code>,
and URIs beginning <code>ssl://</code> must use a <code>javax.net.ssl.SSLSocketFactory</code>.

复制代码

1
2
3
//      添加证书
        sslSocketFactory = getSocketFactory();
        conOpt.setSocketFactory(sslSocketFactory);

getSocketFactory()函数：

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
private SSLSocketFactory getSocketFactory() {
        try {
            SSLContext context;
            KeyStore ts = KeyStore.getInstance("BKS");
            ts.load(getResources().openRawResource(R.raw.certificate), "123456".toCharArray());
            TrustManagerFactory tmf = TrustManagerFactory.getInstance("X509");
            tmf.init(ts);
            TrustManager[] tm = tmf.getTrustManagers();
            context = SSLContext.getInstance("TLS");
            context.init(null, tm, null);

            return context.getSocketFactory();
        } catch (Exception e) {
            Log.e(TAG, "认证失败", e);
            return null;
        }
    }