自己解决基于MQTT的android推送

这里可以看MQTT的监听端口是1883,如果自己的防火墙打开了,那么用速sudo ufw allow 1883,这个端口允许访问!
用命令netstat -lt可以查看所有监听的TCP协议端口!

...
tcp6       0      0 [::]:1883               [::]:*                  LISTEN 
...

2.配置客户端

先下载一个现成的demo
https://github.com/tokudu/AndroidPushNotificationsDemo
这是很老的一个Eclipse项目,但是不妨碍测试,下下来,我直接把相关文件拷贝到了androidstudio下面,习惯了as
1.修改清单文件中的报错,增加访问外部sd卡的权限
2.修改推送服务PushService的

private static final String MQTT_HOST = "10.42.0.1";
private static int MQTT_BROKER_PORT_NUM = 1883;

上面是我的服务端ip,和端口~
3.通知,原项目用的过时的包,有一个方法,现在没有了,那我就改成v7下的兼容api

    private void showNotification(String text) {
        NotificationCompat.Builder builder = new NotificationCompat.Builder(this);
        builder.setContentTitle(NOTIF_TITLE);
        builder.setContentText(text);
        builder.setAutoCancel(true);
        builder.setSmallIcon(com.tokudu.demo.R.drawable.icon);
        builder.setWhen(System.currentTimeMillis());
//      Notification n = new Notification();
//      n.flags |= Notification.FLAG_SHOW_LIGHTS;
//      n.flags |= Notification.FLAG_AUTO_CANCEL;
//      n.defaults = Notification.DEFAULT_ALL;
//      n.icon = com.tokudu.demo.R.drawable.icon;
//      n.when = System.currentTimeMillis();
//      // Simply open the parent activity
        PendingIntent pi = PendingIntent.getActivity(this, 0, new Intent(this,
                PushActivity.class), 0);

//      // Change the name of the notification here
//      n.setLatestEventInfo(this, NOTIF_TITLE, text, pi);
        builder.setContentIntent(pi);
        builder.setDefaults(NotificationCompat.DEFAULT_ALL);
        Notification n = builder.build();
        mNotifMan.notify(NOTIF_CONNECTED++, n);
    }

在这里启动,停止推送,都是交给了服务,在onStart()中判断action内容~
连接tcp://10.42.0.1@1883

// Create connection spec
String mqttConnSpec = "tcp://" + brokerHostName + "@" + MQTT_BROKER_PORT_NUM;
// Create the client and connect
mqttClient = MqttClient.createMqttClient(mqttConnSpec, MQTT_PERSISTENCE);
String clientID = MQTT_CLIENT_ID + "/"+ mPrefs.getString(PREF_DEVICE_ID, "");
mqttClient.connect(clientID, MQTT_CLEAN_START, MQTT_KEEP_ALIVE);

订阅自己的专题

String[] topics = { topicName };
mqttClient.subscribe(topics, MQTT_QUALITIES_OF_SERVICE);

可以订阅多个专题!

好啦,如果没有异常,打印了"Connection established to 10.42.0.1 on topic tokudu/yzq124 ", 就连接成功了...

好,上后台看下真正连上来没有!

最后面的 tokudu.yzq124 即是 客户端订阅的专题,那么来一发吧!

自定义自己的内容,Send!

此时,客户端会收到从broker推送过来的消息

        /*
         * Called when we receive a message from the message broker.
         */
        public void publishArrived(String topicName, byte[] payload, int qos,
                boolean retained) {
            // Show a notification
            String s = new String(payload);
            showNotification(s);
            log("Got message: " + s);
        }

MQTT强大的是群推模式
客户端可以注册多个token(客户端的唯一标识)可以让所有客户端都注册该token即可，然后发送的时候，只需要针对一个token发消息，那么所有的手机都收到了。不用像其他的推送一样，对每个token都去发一遍。所以MQTT群发的效率的极高的。这样的话对手机端来说就很好了，也许我们需要对某个程序的所有手机发、向某个程序某个版本手机发，向某台手机发推送 等等用MQTT都可以很轻松的实现。

版权声明：本文来源CSDN，感谢博主原创文章，遵循 CC 4.0 by-sa 版权协议，转载请附上原文出处链接和本声明。
原文链接：https://blog.csdn.net/XiaoMu_Mu/article/details/80474986
站方申明：本站部分内容来自社区用户分享，若涉及侵权，请联系站方删除。

• 发表于 2020-05-07 23:10:48
• 阅读 ( 1462 )
• 分类：