Android SDK接入

val pushInitConfig = PushInitConfig.Builder()
    .application(application)
    .appKey(appKey)    //请填写你自己的appKey
    .appSecret(appSecret)    //请填写你自己的appSecret
    .build()

PushInitConfig pushInitConfig = new PushInitConfig.Builder()
        .application(application)
        .appKey(appKey)    //请填写你自己的appKey
        .appSecret(appSecret)    //请填写你自己的appSecret
        .build();

PushServiceFactory.init(context)

PushServiceFactory.init(context);

PushServiceFactory.init(pushInitConfig)

PushServiceFactory.init(pushInitConfig);

val pushService = PushServiceFactory.getCloudPushService()
pushService.register(this, object : com.alibaba.sdk.android.push.CommonCallback {
    override fun onSuccess(success: String) {}
    override fun onFailed(errorCode: String, errorMessage: String) {}
})

CloudPushService pushService = PushServiceFactory.getCloudPushService();
pushService.register(this, new com.alibaba.sdk.android.push.CommonCallback() {
    @Override
    public void onSuccess(String success) {

    }

    @Override
    public void onFailed(String errorCode, String errorMessage) {
        
    }
});

class MyMessageReceiver: MessageReceiver(){

    override fun onNotificationReceivedInApp(
        context: Context?,
        title: String?,
        summary: String?,
        map: MutableMap<String, String>?,
        openType: Int,
        openActivity: String?,
        openUrl: String?
    ) {
        //这里可以处理下发的推送通知
    }

    override fun showNotificationNow(p0: Context?, p1: MutableMap<String, String>?): Boolean {
        //false表示拦截，true表示不拦截，请根据进行拦截，拦截后会执行到 onNotificationReceivedInApp
        return false
    }
}

public class MyMessageReceiver extends MessageReceiver {
    @Override
    protected void onNotificationReceivedInApp(Context context, String title, String summary, Map<String, String> map, int openType, String openActivity, String openUrl) {
        //这里可以处理下发的推送通知
    }

    @Override
    public boolean showNotificationNow(Context context, Map<String, String> map) {
        //false表示拦截，true表示不拦截，请根据进行拦截，拦截后会执行到 onNotificationReceivedInApp
        return false;
    }
}

class Kk: MessageReceiver() {
    override fun onMessage(context: Context?, cPushMessage: CPushMessage?) {
        val title = cPushMessage?.title
        val content = cPushMessage?.content

        if (isForeground) {
            //App处于前台，弹窗形式显示
        } else {
            //App处于后台，通知形式显示
        }
    }
}

public class MyMessageReceiver extends MessageReceiver {
    @Override
    protected void onMessage(Context context, CPushMessage cPushMessage) {
        String title = cPushMessage.getTitle();
        String content = cPushMessage.getContent();

        if (isForeground) {
            //App处于前台，弹窗形式显示
        } else {
            //App处于后台，通知形式显示
        }
    }
}

PushServiceFactory.getCloudPushService()
    .bindTag(CloudPushService.DEVICE_TARGET, arrayOf(tag), null, object : CommonCallback {
        override fun onSuccess(s: String) {}
        override fun onFailed(errorCode: String, errorMsg: String) {}
    })

PushServiceFactory.getCloudPushService().bindTag(CloudPushService.DEVICE_TARGET, new String[]{tag}, null, new CommonCallback() {
    @Override
    public void onSuccess(String s) {

    }

    @Override
    public void onFailed(String errorCode, String errorMsg) {

    }
});

val pushService = PushServiceFactory.getCloudPushService()
//仅适用于Debug包，正式包不需要此行
pushService.setLogLevel(CloudPushService.LOG_DEBUG)

CloudPushService pushService = PushServiceFactory.getCloudPushService();
//仅适用于Debug包，正式包不需要此行
pushService.setLogLevel(CloudPushService.LOG_DEBUG);      

val pushInitConfig = PushInitConfig.Builder()
    .application(application)
    // 开启channel进程
    .disableChannelProcess(false)
    // 开启channel进程心跳
    .disableChannelProcessHeartbeat(false)
    .build()

PushServiceFactory.init(pushInitConfig)

val pushService = PushServiceFactory.getCloudPushService()
pushService.register(this, object : com.alibaba.sdk.android.push.CommonCallback {
    override fun onSuccess(success: String) {}
    override fun onFailed(errorCode: String, errorMessage: String) {}
})

PushInitConfig pushInitConfig = new PushInitConfig.Builder()
        .application(application)
        // 开启channel进程
        .disableChannelProcess(false)
        // 开启channel进程心跳
        .disableChannelProcessheartbeat(false)
        .build()

PushServiceFactory.init(pushInitConfig);

CloudPushService pushService = PushServiceFactory.getCloudPushService();
pushService.register(applicationContext, new CommonCallback() {
    @Override
    public void onSuccess(String response) {
        
    }
    @Override
    public void onFailed(String errorCode, String errorMessage) {
        
    }
});

val pushInitConfig = PushInitConfig.Builder()
    .application(application)
    // 根据情况禁止channel进程
    .disableChannelProcess(false)
    // 禁止channel进程心跳
    .disableChannelProcessHeartbeat(false)
    .build()

PushServiceFactory.init(pushInitConfig)

val pushService = PushServiceFactory.getCloudPushService()
pushService.register(this, object : com.alibaba.sdk.android.push.CommonCallback {
    override fun onSuccess(success: String) {}
    override fun onFailed(errorCode: String, errorMessage: String) {}
})

PushInitConfig pushsInitConfig = new PushInitConfig.Builder()
        .application(application)
        // 根据情况禁止channel进程
        .disableChannelProcess(true)
        // 禁止channel进程心跳
        .disableChannelProcessheartbeat(true)
        .build();
PushServiceFactory.init(pushsInitConfig);

CloudPushService pushService = PushServiceFactory.getCloudPushService();
pushService.register(applicationContext, new CommonCallback() {
    @Override
    public void onSuccess(String response) {

    }
    @Override
    public void onFailed(String errorCode, String errorMessage) {

    }
});

val handler = Handler()
val controlService = PushServiceFactory.getPushControlService()
controlService.setConnectionChangeListener(object : ConnectionChangeListener {
    override fun onConnect() {}
    override fun onDisconnect(code: String, msg: String) {
        val isNetworkIssue = !isNetworkConnected()
        // 过一段时间再检查，比如30s
        handler.postDelayed(Runnable {
            if (isNetworkConnected() && !controlService.isConnected()) {
                // 如果网络没有问题，而且连接没有恢复
                // 此时记录埋点 code 和 msg 信息，一定要记录msg信息
                recordDisconnectEvent(code, msg)
                if (isNetworkIssue) {
                    // 刚才没有网络，尝试重连
                    controlService.reconnect()
                } else {
                    // 网络没有问题，或者重连也不行，进行重置，重新进行初始化
                    controlService.reset()
                    initCloudChannel(getContext())
                }
            }
        }, 30 * 1000)
    }
})

// 示意代码，请不要直接使用，请根据具体的业务情况使用api
final Handler handler = new Handler();
PushControlService controlService = PushServiceFactory.getPushControlService();
controlService.setConnectionChangeListener(new PushControlService.ConnectionChangeListener() {
    @Override
    public void onConnect() {

    }

    @Override
    public void onDisconnect(final String code, final String msg) {
        final boolean isNetworkIssue = !isNetworkConnected();
        // 过一段时间再检查，比如30s
        handler.postDelayed(new Runnable() {
            @Override
            public void run() {
                if(isNetworkConnected() && !controlService.isConnected()) {
                    // 如果网络没有问题，而且连接没有恢复
                    // 此时记录埋点 code 和 msg 信息，一定要记录msg信息
                    recordDisconnectEvent(code, msg);
                    if (isNetworkIssue) {
                        // 刚才没有网络，尝试重连
                        controlService.reconnect();
                    } else {
                        // 网络没有问题，或者重连也不行，进行重置，重新进行初始化
                        controlService.reset();
                        initCloudChannel(getContext());
                    }

                }
            }
        }, 30 * 1000);
    }
});