一段时间后服务停止工作。需要连续工作

2024-03-15

我正在开发一个计步器应用程序,在其中计算行走的步数并在午夜将其更新到服务器。我有一个持续运行的服务来完成这一切。

这是我的服务:

    public class StepCounterService extends Service implements SensorEventListener, StepListener, WebServiceInterface, GoogleApiClient.ConnectionCallbacks,
        GoogleApiClient.OnConnectionFailedListener, LocationListener {

    private static final int SERVICE_ID = 27;
    private static final int SEND_SESSION_REQUEST_CODE = 1;
    private static final int SEND_ACTIVITY_REQUEST_CODE = 2;
    private static final int MAIN_NOTIFICATION_ID = 3;
    private static final int SECONDARY_NOTIFICATION_ID = 4;
    private LocalBroadcastManager broadcaster;

    static final public String STEP_INCREMENT = "com.app.STEP_INCREMENTED";
    static final public String SESSION_COMPLETE = "com.app.SESSION_COMPLETE";
    static final public String ACTIVITY_COMPLETE = "com.app.ACTIVITY_COMPLETE";
    static final public String STEP_INCREMENT_KEY = "step_count";

    Session session;

    private StepDetector stepDetector;
    private SensorManager sensorManager;
    private Sensor sensor;
    private int numberOfSteps = 0;

    private GoogleApiClient googleApiClient;
    private LocationRequest mLocationRequest;
    double currentLatitude;
    double currentLongitude;
    ArrayList<String> arrayListLocations;
    private AlarmManager sendActivityAlarmManager;
    private PendingIntent activityAlarmIntent;

    private NotificationManager notificationManager;
    RemoteViews contentView;
    PowerManager.WakeLock wl;
    private String TAG = "Wake Lock Tag";
    private int SET_LAST_LOCATION_REQUEST_CODE = 5;


    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        return null;
    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        // TODO Auto-generated method stub
        return START_STICKY;
    }

    @Override
    public void onTaskRemoved(Intent rootIntent) {
        // TODO Auto-generated method stub
        System.out.println("---- In onTaskRemoved Function");
        restartKilledService();
    }

    @Override
    public void onDestroy() {
        System.out.println("---- In onDestroy Function");
        if (wl != null) {
            wl.release();
        }
        super.onDestroy();
        restartKilledService();
    }

    void restartKilledService() {

        System.out.println("---- In restartKilledService Function");

        Intent restartService = new Intent(getApplicationContext(), StepCounterService.class);
        restartService.setPackage(getPackageName());
        PendingIntent restartServicePI = PendingIntent.getService(getApplicationContext(), StepCounterService.SERVICE_ID, restartService, PendingIntent.FLAG_CANCEL_CURRENT);

        AlarmManager alarmService = (AlarmManager) getApplicationContext().getSystemService(Context.ALARM_SERVICE);
        alarmService.set(AlarmManager.RTC_WAKEUP, SystemClock.elapsedRealtime() + 100, restartServicePI);
    }

    @Override
    public void onCreate() {
        // TODO Auto-generated method stub

        PowerManager pm = (PowerManager) getApplicationContext().getSystemService(getApplicationContext().POWER_SERVICE);
        wl = pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, TAG);
        wl.acquire();

        super.onCreate();

        session = new Session(this);
        buildGoogleApiClient();

        broadcaster = LocalBroadcastManager.getInstance(this);

        sensorManager = (SensorManager) getSystemService(SENSOR_SERVICE);
        sensor = sensorManager.getDefaultSensor(Sensor.TYPE_ACCELEROMETER);
        stepDetector = new StepDetector();
        stepDetector.registerListener(StepCounterService.this);

        Context ctx = getApplicationContext();
        Calendar cal = Calendar.getInstance();
        AlarmManager am = (AlarmManager) ctx.getSystemService(Context.ALARM_SERVICE);
        long interval = 1000 * 60 * 5; // 5 minutes in milliseconds
        Intent serviceIntent = new Intent(ctx, StepCounterService.class);

        PendingIntent servicePendingIntent = PendingIntent.getService(ctx, StepCounterService.SERVICE_ID, serviceIntent, PendingIntent.FLAG_CANCEL_CURRENT);
        am.setRepeating(AlarmManager.RTC_WAKEUP, cal.getTimeInMillis(), interval, servicePendingIntent);

        sensorManager.registerListener(this, sensor, SensorManager.SENSOR_DELAY_FASTEST);

        notificationManager = (NotificationManager) getSystemService(Activity.NOTIFICATION_SERVICE);
        contentView = new RemoteViews(getPackageName(), R.layout.notification_layout);
        contentView.setImageViewResource(R.id.image, R.drawable.notif_icon);

        if (session.getUser() != null && !(session.getUser().getName().equals("")))
            updateMainNotification(session.getTodaySteps() + "");

        startAlarm();
    }


    protected synchronized void buildGoogleApiClient() {
        googleApiClient = new GoogleApiClient.Builder(this)
                .addConnectionCallbacks(this)
                .addOnConnectionFailedListener(this)
                .addApi(LocationServices.API)
                .build();
        googleApiClient.connect();

        mLocationRequest = LocationRequest.create()
                .setPriority(LocationRequest.PRIORITY_HIGH_ACCURACY)
                .setInterval(10 * 1000)        // 10 seconds, in milliseconds
                .setFastestInterval(1 * 1000);
    }

    @Override
    public void onSensorChanged(SensorEvent event) {
        if (event.sensor.getType() == Sensor.TYPE_ACCELEROMETER) {
            stepDetector.updateAccel(event.timestamp, event.values[0], event.values[1], event.values[2]);
        }
    }

    @Override
    public void step(long timeNs) {
        numberOfSteps = session.getTodaySteps();
        numberOfSteps++;

        sendStepIncrementBroadcast(numberOfSteps);

        session.setTodaySteps(numberOfSteps);

        if (session.getUser() != null && !(session.getUser().getName().equals("")))
            updateMainNotification(numberOfSteps + "");
        else {
            try {
                notificationManager.cancel(MAIN_NOTIFICATION_ID);
            } catch (Exception e) {

            }
        }
    }

    public void sendStepIncrementBroadcast(int numberOfSteps) {
        Intent intent = new Intent(STEP_INCREMENT);
        intent.putExtra(STEP_INCREMENT_KEY, numberOfSteps);
        broadcaster.sendBroadcast(intent);
    }

    @Override
    public void onAccuracyChanged(Sensor sensor, int i) {

    }

    public float[] getDataFromSteps(int stepsCount) {
        float caloriesCount = 0;
        float creditsCount = 0;
        try {
            double adjustedWeight = Double.parseDouble(session.getUser().getWeight()) / LinksAndKeys.weightAdjuster;
            caloriesCount = Math.round(((adjustedWeight * LinksAndKeys.metValue) / LinksAndKeys.setPace) * (stepsCount / LinksAndKeys.stepsPerMile));
            caloriesCount = caloriesCount * 1.2f;
            creditsCount = caloriesCount / 25.4f;
        } catch (Exception e) {
            caloriesCount = 0;
            creditsCount = 0;
        }

        float[] resultantFloat = {caloriesCount, creditsCount};
        return resultantFloat;
    }

    private void startAlarm() {

        sendActivityAlarmManager = (AlarmManager) this.getSystemService(Context.ALARM_SERVICE);

        Intent intent = new Intent(this, ActivityCompleteReceiver.class);
        activityAlarmIntent = PendingIntent.getBroadcast(this, 0, intent, 0);

        Calendar calendar = Calendar.getInstance();
        calendar.setTimeInMillis(System.currentTimeMillis());
        calendar.set(Calendar.HOUR_OF_DAY, 23);
        calendar.set(Calendar.MINUTE, 58);
//        calendar.set(Calendar.HOUR_OF_DAY, generateRandomTime()[0]);
//        calendar.set(Calendar.MINUTE, generateRandomTime()[1]);

        if (System.currentTimeMillis() > calendar.getTimeInMillis()) {
            calendar.add(Calendar.DAY_OF_YEAR, 1);
        }

        sendActivityAlarmManager.setRepeating(AlarmManager.RTC_WAKEUP, calendar.getTimeInMillis(),
                AlarmManager.INTERVAL_DAY, activityAlarmIntent);
    }

    private void updateMainNotification(String stepsValue) {

        String title = "Today: " + stepsValue + " steps - " + LinksAndKeys.decimalFormat.format(getDataFromSteps(session.getTodaySteps())[1]) + " FIMOs";
        String message = "Keep Walking and Keep Earning";

        contentView.setTextViewText(R.id.textViewTitle, title);
        contentView.setTextViewText(R.id.textViewMessage, message);

        Intent notificationIntent = new Intent(StepCounterService.this, SplashActivity.class);
        notificationIntent.setFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP | Intent.FLAG_ACTIVITY_SINGLE_TOP);
        PendingIntent intent = PendingIntent.getActivity(StepCounterService.this, 0, notificationIntent, 0);


        NotificationCompat.Builder mBuilder = new NotificationCompat.Builder(this)
                .setSmallIcon(R.drawable.running_icon)
                .setContent(contentView).setContentIntent(intent);

        Notification notification = mBuilder.build();
        notification.flags |= Notification.FLAG_ONGOING_EVENT;
//        notificationManager.notify(MAIN_NOTIFICATION_ID, notification);
        startForeground(MAIN_NOTIFICATION_ID, notification);
    }

    private void updateReminderNotification() {

        String title = "A gentle reminder";
        String message = "Its time to get on track";

        contentView.setTextViewText(R.id.textViewTitle, title);
        contentView.setTextViewText(R.id.textViewMessage, message);

        Intent notificationIntent = new Intent(StepCounterService.this, SplashActivity.class);
        notificationIntent.setFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP | Intent.FLAG_ACTIVITY_SINGLE_TOP);
        PendingIntent intent = PendingIntent.getActivity(StepCounterService.this, 0, notificationIntent, 0);


        NotificationCompat.Builder mBuilder = new NotificationCompat.Builder(this)
                .setSmallIcon(R.drawable.running_icon)
                .setContent(contentView).setContentIntent(intent);

        Notification notification = mBuilder.build();
        notificationManager.notify(SECONDARY_NOTIFICATION_ID, notification);
    }

    private int[] generateRandomTime() {
        int[] timeIntegers = new int[2];

        final Random r = new Random();
        timeIntegers[0] = r.nextInt(58 - 56) + 56;
        timeIntegers[1] = r.nextInt(59 - 1) + 1;

        return timeIntegers;
    }
}

这是活动完成接收器:

public class ActivityCompleteReceiver extends BroadcastReceiver implements WebServiceInterface {

    Session session;
    private LocalBroadcastManager broadcaster;
    static final public String ACTIVITY_COMPLETE = "com.fimo.ACTIVITY_COMPLETE";
    private static final int SEND_ACTIVITY_REQUEST_CODE = 1;
    Gson gson;
    MyDatabase myDatabase;
    UserActivity currentUserActivity;

    @Override
    public void onReceive(Context context, Intent intent) {

        session = new Session(context);
        broadcaster = LocalBroadcastManager.getInstance(context);
        myDatabase = new MyDatabase(context);
        gson = new Gson();

        sendActivityToServer(context, session.getUser().getId(), session.getTodaySteps());
    }

    private void sendActivityToServer(Context context, String id, int steps) {

        Calendar c = Calendar.getInstance();
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
        String date = dateFormat.format(c.getTime());

        UserActivity userActivity = new UserActivity();
        userActivity.setDate(date);
        userActivity.setSteps(steps);
        userActivity.setCalories(getDataFromSteps(steps)[0]);
        userActivity.setCredits(getDataFromSteps(steps)[1]);

        currentUserActivity = userActivity;

        if (isNetworkAvailable(context)) {
            HashMap<String, String> paramsList = new HashMap<>();
            ArrayList<UserActivity> arrayListUserActivity = myDatabase.getAllUserActivities();
            arrayListUserActivity.add(userActivity);

            paramsList.put(LinksAndKeys.ID_KEY, id);
            paramsList.put(LinksAndKeys.DATA_KEY, gson.toJson(arrayListUserActivity));

            Log.d("Receiver Request ----", id + " - " + gson.toJson(arrayListUserActivity));

            WebServiceController webServiceController = new WebServiceController(
                    context, ActivityCompleteReceiver.this);
            String hitURL = LinksAndKeys.SEND_ACTIVITY_URL;
            webServiceController.sendSilentRequest(false, hitURL, paramsList, SEND_ACTIVITY_REQUEST_CODE);
        } else {
            myDatabase.addUserActivity(currentUserActivity);
            currentUserActivity = null;

            Intent in = new Intent(ACTIVITY_COMPLETE);
            broadcaster.sendBroadcast(in);

            session.setTodaySteps(0);
        }

    }

    private boolean isNetworkAvailable(Context context) {
        ConnectivityManager connectivityManager
                = (ConnectivityManager) context.getSystemService(Context.CONNECTIVITY_SERVICE);
        NetworkInfo activeNetworkInfo = connectivityManager.getActiveNetworkInfo();
        return activeNetworkInfo != null && activeNetworkInfo.isConnected();
    }

    @Override
    public void getResponse(int responseCode, String responseString, String requestType, int requestCode) {
        if (requestCode == SEND_ACTIVITY_REQUEST_CODE && responseCode == 200) {
            try {
                JSONObject responseObject = new JSONObject(responseString);
                String message = responseObject.getString("message");
                if (message.equals("Success")) {

                    myDatabase.deleteAllUserActivities();

                    JSONObject jsonObject = responseObject.getJSONObject("data");
                    session.setServerCredits(Float.parseFloat(jsonObject.getString("credits")));

                    Intent in = new Intent(ACTIVITY_COMPLETE);
                    broadcaster.sendBroadcast(in);

                    session.setTodaySteps(0);
                } else {
                    myDatabase.addUserActivity(currentUserActivity);
                    currentUserActivity = null;

                    Intent in = new Intent(ACTIVITY_COMPLETE);
                    broadcaster.sendBroadcast(in);

                    session.setTodaySteps(0);
                }

            } catch (Exception e) {
                myDatabase.addUserActivity(currentUserActivity);
                currentUserActivity = null;

                Intent in = new Intent(ACTIVITY_COMPLETE);
                broadcaster.sendBroadcast(in);

                session.setTodaySteps(0);
            }
        } else {
            if (currentUserActivity != null) {
                myDatabase.addUserActivity(currentUserActivity);
                currentUserActivity = null;

                Intent in = new Intent(ACTIVITY_COMPLETE);
                broadcaster.sendBroadcast(in);

                session.setTodaySteps(0);
            }
        }
    }

    public float[] getDataFromSteps(int stepsCount) {
        float caloriesCount = 0;
        float creditsCount = 0;
        try {
            double adjustedWeight = Double.parseDouble(session.getUser().getWeight()) / LinksAndKeys.weightAdjuster;
            caloriesCount = Math.round(((adjustedWeight * LinksAndKeys.metValue) / LinksAndKeys.setPace) * (stepsCount / LinksAndKeys.stepsPerMile));
            caloriesCount = caloriesCount * 1.2f;
            creditsCount = caloriesCount / 25.4f;
        } catch (Exception e) {
            caloriesCount = 0;
            creditsCount = 0;
        }

        float[] resultantFloat = {caloriesCount, creditsCount};
        return resultantFloat;
    }
}

编写的代码应该以这种方式运行:

每天计算用户走了的步数。 -> 在午夜 11.56-11.59 之间的特定时间,将数据发送到活动完成接收器 -> 接收器接收数据并尝试将其发送到服务器(如果互联网可用)。如果没有,则将其保存到本地数据库 -> 保存或发送后,将步数重置为 0,服务第二天从 0 重新开始计数。

问题是服务在给定时间的某些天实际上没有工作,并且接收者没有收到活动完整意图。如果我保持手机开机并通过设置距离当前时间几分钟的时间来测试它,则服务可以正常工作。但如果手机长时间保持不动,那么我认为这种情况会在服务停止工作时发生。这是我的猜测,实际问题可能是别的。任何建议或解决方案都将受到高度赞赏。


从 API 级别 19 开始,使用AlarmManager.setRepeating()你正在做的就是打电话给你的ActivityCompleteReceiver,并不可靠准确。如果愿意,Android 可以延迟发送此警报。如果您确实希望在每天的确切时间触发此操作,您应该执行以下操作:

Use AlarmManager.setExact()并为下一个触发时间设置一个闹钟(不是重复闹钟)。当此警报发出时,发送您的统计数据或您想要的任何内容,然后致电AlarmManager.setExact()设置下一个闹钟(第二天)。你应该避免使用setRepeating()除非你绝对需要使用它。

您需要注意使用唤醒锁所做的事情,因为您当前的代码始终保持部分唤醒锁,这将阻止设备进入睡眠状态,从而耗尽电池。了解如何优化电池使用。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

一段时间后服务停止工作。需要连续工作 的相关文章

随机推荐

  • 从多个 jpg 图像创建 Dicom

    我已经成功地用一张图像构建了 dicom 但我找不到添加更多图像的方法 我认为问题可能出在我的像素阵列中 任何人都可以帮我纠正它吗 Populate required values for file meta information met
  • 如何动态设置谷歌地图自定义缩放级别?

    我正在使用谷歌地图 根据要求 我需要设置取决于我的搜索查询的不同缩放级别 如果国家 地区地图上有多个位置 则地图应聚焦该国家 地区 其他情况是 如果城市中标记了不同的位置 则地图应集中到城市级别 var geoCoder new GClie
  • “#!/bin/env”是什么意思(位于 node.js 脚本的顶部)?

    我发现一些 Node js 项目的顶部有这个app js 如在这个开放轮班计划 https github com openshift openshift mongo node express example blob master serv
  • WinDBG - 查找实际的(非托管)异常

    我试图在托管 非托管混合代码中找到实际的异常 问题是我有一个 Net 类 它捕获所有未处理的异常 然后创建一个转储 因此当我查看转储时 存在混合的托管 非托管代码 并且我无法真正获取实际的非托管异常 更糟糕的是 Net 似乎有自己的例外 所
  • 如何在 ACSL 中编写“is power of 2”谓词?

    我尝试编写一个 ACSL 谓词来查看整数是否是 2 的幂 如下所示 predicate positive power of 2 integer i i gt 0 i 1 i 1 0 positive power of 2 i gt gt 1
  • OpenFileIDialog C# 中的 URL 作为文件名

    在我的 C win 表单中 我使用OpenFileDialog供用户选择要保存的文件 当用户指定一个 url 文件时 例如http www xyz com qdms MyFile PDFOpenFileDialog 下载文件并给出下载的文件
  • OPENCV 链接错误 - Win32 和 VS2012

    我已经构建了 openCV 3 0 0 alpha 和 beta 版本 但每次我运行我的项目时 我都会收到此错误 仅适用于 imread 功能 error LNK2019 unresolved external symbol class c
  • 如何设置Redis最大内存?

    我发现配置在this http redis io topics config 它只是说使用指定配置的命令 redis server
  • 如何从受密码保护的站点更新 Eclipse 插件?

    我在 这个网站 http javaforge com project HGE http javaforge com project HGE 我需要 注册 才能下载 Mercurial 的 Eclipse 插件 我注册了 但似乎什么也没发生
  • Wix:如何警告用户而不是使用属性终止安装?

    我正在 x64 计算机上搜索 Microsoft Access 数据库引擎的注册表项 这是我的代码
  • 将请求的文件从 API 传输到 API:NestJS(HttpService: Axios) 到 Python(flask)

    我正在尝试将文件从 NestJS API 传输到 Python Flask API 此过程将由 Nest API 上的 POST 请求 FormData 文件 触发 然后 Nest api 应该将文件发送到 Python api NestJ
  • MongoEngine - 通过 id 从 ListField 中提取引用

    我想删除一些引用ListField ReferenceField 仅基于其价值 我将有关图像的信息存储在以下模型中 class ImageUrl Document src UrlField counter IntField deleted
  • torchvision和tensorflow-gpu导入错误

    运行这个 import torchvision import tensorflow 产生错误 SystemError google protobuf pyext descriptor cc 354 内部函数的参数错误 但是 交换导入的顺序不
  • Tomcat不返回图片资源

    我正在使用 eclipse 并使用 eclipse 中的 tomcat6 运行我的 jsp servlet 我的 servlet 为我创建了一个图像 并将其存储在我的 webapps 的目录中 但是 当我尝试从 JSP 访问此图像时 它返回
  • React中输入的屏蔽卡号

    我正在学习 React 并希望输入有两个约束 16个数字 每四个后面加一个空格 import React Component from react export default class CardNumberInput extends C
  • C 预处理器插入的空格

    假设我们得到以下输入 C 代码 define Y 20 define A x 10 x Y A A 40 gcc E像这样的输出 10 10 40 20 20 gcc E traditional cpp像这样的输出 10 10 40 20
  • Linux 内核是如何测试的?

    Linux 内核开发人员如何在本地测试他们的代码以及在提交代码后 他们是否使用某种单元测试和构建自动化 测试计划 Linux 内核非常重视社区测试 通常 任何开发人员都会在提交之前测试自己的代码 并且通常他们会使用 Linus 的内核开发版
  • Javascript数组排序和唯一性

    我有一个像这样的 JavaScript 数组 var myData 237 124 255 124 366 255 我需要数组元素是唯一的并且已排序 myData 0 124 myData 1 237 myData 2 255 myData
  • 发出 Facebook 好友请求时可以获取吗?

    friend request 流包含 2 个字段 uid from 和 uid to 没有关于提出请求的日期信息 还有其他表包含该信息吗 Thanks 在 Facebook 论坛上得到回复 这是不可能的
  • 一段时间后服务停止工作。需要连续工作

    我正在开发一个计步器应用程序 在其中计算行走的步数并在午夜将其更新到服务器 我有一个持续运行的服务来完成这一切 这是我的服务 public class StepCounterService extends Service implement