使用EventBus实现Android实时速度显示与后台保存教程-java教程-PHP中文网

使用EventBus实现Android实时速度显示与后台保存教程

本教程详细介绍了如何在Android应用中实现实时速度的显示与后台保存功能。通过利用前台服务（Foreground Service）获取位置数据，并结合EventBus库实现服务与UI界面（MainActivity）之间的实时数据通信，确保即使应用处于后台或屏幕关闭时，速度数据也能持续更新并显示在用户界面上，同时进行数据存储。

1. 引言与核心挑战

在android 应用开发中，当我们需要在后台持续执行任务（例如获取地理位置信息并计算速度）并同时更新用户界面时，会遇到一个常见挑战：如何有效地在后台服务（service）和前台活动（activity）之间进行实时数据通信。尤其是在用户关闭屏幕或将应用切换到后台时，确保数据更新的连续性和ui的响应性变得尤为重要。

本教程将展示如何结合Android的前台服务（Foreground Service）和Google的FusedLocationProviderClient来获取实时位置数据，并通过引入强大的开源库EventBus，优雅地解决服务与活动之间的数据同步问题，实现速度的实时显示与后台存储。

2. 核心技术概述

2.1 前台服务 (Foreground Service)

前台服务是Android提供的一种特殊类型的服务，它会在后台运行但对用户可见（通过通知栏）。这使得即使应用被系统杀死或用户关闭屏幕，服务也能持续运行，非常适合需要长时间运行且不中断的任务，如位置追踪。

2.2 FusedLocationProviderClient

FusedLocationProviderClient是Google Play服务中用于获取位置信息的推荐API。它结合了GPS、Wi-Fi和蜂窝网络等多种定位技术，以提供最佳的位置准确性和功耗平衡。

2.3 EventBus

EventBus是一个Android优化过的发布/订阅模式的事件总线库。它简化了组件间的通信，解耦了发送者和接收者。通过EventBus，一个组件可以发布一个事件，而其他订阅了该事件的组件则可以接收并处理它，无需直接引用彼此。这对于服务与活动之间的通信非常有效。

3. 实现步骤

3.1 项目准备与依赖添加

首先，在你的build.gradle (Module: app)文件中添加必要的依赖：

dependencies {
    // Google Play Services Location
    implementation 'com.google.android.gms:play-services-location:21.0.1'
    // EventBus
    implementation 'org.greenrobot:eventbus:3.3.1'
    // Firebase Database (如果需要后台存储到Firebase)
    implementation 'com.google.firebase:firebase-database:20.3.0'
    // ... 其他依赖
}

登录后复制

别忘了在项目根目录的build.gradle中添加Google服务插件：

buildscript {
    repositories {
        google()
        mavenCentral()
    }
    dependencies {
        classpath 'com.android.tools.build:gradle:8.1.0' // 你的Gradle版本
        classpath 'com.google.gms:google-services:4.4.0' // Google Services Plugin
    }
}

登录后复制

并在应用级别的build.gradle顶部应用它：

ViiTor实时翻译

AI实时多语言翻译专家！强大的语音识别、AR翻译功能。

116

查看详情

plugins {
    id 'com.android.application'
    id 'com.google.gms.google-services' // 应用Google Services Plugin
}

登录后复制

3.2 定义事件类

创建一个简单的POJO（Plain Old Java Object）作为EventBus的事件载体。这个事件将携带从服务发送到活动的速度数据。

// MessageEvents.java (可以放在一个单独的包或文件中)
public class MessageEvents {
    public static class NewSpeedEvent {
        public final float speed; // 速度，单位通常为km/h

        public NewSpeedEvent(float speed) {
            this.speed = speed;
        }
    }

    // 如果需要，可以定义其他事件类型
    public static class LocationUpdateEvent {
        public final Location location;

        public LocationUpdateEvent(Location location) {
            this.location = location;
        }
    }
}

登录后复制

3.3 修改 LocationService

LocationService将负责获取实时位置，计算速度，并通过EventBus发布NewSpeedEvent。同时，它需要作为前台服务运行以确保持续性。

// LocationService.java
public class LocationService extends Service {

    // ... (FirebaseDatabase, FusedLocationProviderClient, LocationRequest, LocationCallback等成员变量保持不变)
    // 请确保这些变量已正确初始化，如原代码所示

    private float speed; // 用于存储当前速度

    @Override
    public void onCreate() {
        super.onCreate();
        fusedLocationClient = LocationServices.getFusedLocationProviderClient(this);

        // 创建通知渠道并启动前台服务
        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
            createNotificationChannel();
        } else {
            startForeground(1, new Notification());
        }

        locationRequest = new LocationRequest.Builder(Priority.PRIORITY_HIGH_ACCURACY, 1000)
                .setWaitForAccurateLocation(false)
                .setMinUpdateIntervalMillis(500)
                .setMaxUpdateDelayMillis(1500)
                .build();

        locationCallback = new LocationCallback() {
            @Override
            public void onLocationResult(@NonNull LocationResult locationResult) {
                Location location = locationResult.getLastLocation();
                if (location != null) {
                    // 获取速度并转换为km/h (location.getSpeed()返回m/s)
                    speed = location.getSpeed() * 3.6f;

                    // 将实时速度保存到Firebase (如原代码所示)
                    myLiveRef.setValue(speed);
                    DatabaseReference newPastRef = myPastsRef.push();
                    newPastRef.setValue(String.valueOf(Calendar.getInstance().getTime()) + " ||||||||  " + speed + " KM/H");

                    // *** 关键：通过EventBus发布速度更新事件 ***
                    EventBus.getDefault().post(new MessageEvents.NewSpeedEvent(speed));
                    Log.d("LocationService", "Posted speed: " + speed + " km/h");
                }
            }
        };
        startLocationUpdates();
    }

    // ... (onBind, onTaskRemoved, onStartCommand, onDestroy, createNotificationChannel 等方法保持不变)
    // 确保 startLocationUpdates() 方法中包含权限检查
    private void startLocationUpdates() {
        if (ActivityCompat.checkSelfPermission(this, Manifest.permission.ACCESS_FINE_LOCATION) != PackageManager.PERMISSION_GRANTED &&
            ActivityCompat.checkSelfPermission(this, Manifest.permission.ACCESS_COARSE_LOCATION) != PackageManager.PERMISSION_GRANTED) {
            // 权限未授予，通常在Activity中处理权限请求
            return;
        }
        fusedLocationClient.requestLocationUpdates(locationRequest, locationCallback, Looper.getMainLooper());
    }

    @RequiresApi(api = Build.VERSION_CODES.O)
    private void createNotificationChannel() {
        String notificationChannelId = "Location channel id";
        String channelName = "Background Service";
        NotificationChannel chan = new NotificationChannel(
                notificationChannelId,
                channelName,
                NotificationManager.IMPORTANCE_NONE
        );
        chan.setLightColor(Color.BLUE);
        chan.setLockscreenVisibility(Notification.VISIBILITY_PRIVATE);
        NotificationManager manager = getSystemService(NotificationManager.class);
        manager.createNotificationChannel(chan);
        NotificationCompat.Builder notificationBuilder =
                new NotificationCompat.Builder(this, notificationChannelId);
        Notification notification = notificationBuilder.setOngoing(true)
                .setContentTitle("Location updates:")
                .setPriority(NotificationManager.IMPORTANCE_MIN)
                .setCategory(Notification.CATEGORY_SERVICE)
                .build();
        startForeground(2, notification);
    }
}

登录后复制

3.4 修改 MainActivity

MainActivity将订阅NewSpeedEvent，并在收到事件时更新其UI。

// MainActivity.java
public class MainActivity extends AppCompatActivity {

    // ... (MY_FINE_LOCATION_REQUEST, MY_BACKGROUND_LOCATION_REQUEST, textView, mServiceIntent, startServiceBtn, stopServiceBtn 等成员变量保持不变)
    // 请确保这些变量已正确初始化，如原代码所示

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        // ... (findViewById, setOnClickListener 等初始化代码保持不变)
        startServiceBtn = findViewById(R.id.start_service_btn);
        stopServiceBtn = findViewById(R.id.stop_service_btn);
        textView = findViewById(R.id.textView);

        // ... (权限检查和按钮点击事件处理逻辑保持不变)
        // 确保 starServiceFunc() 和 stopServiceFunc() 正确启动/停止服务
    }

    @Override
    protected void onStart() {
        super.onStart();
        // *** 关键：注册EventBus订阅者 ***
        EventBus.getDefault().register(this);
    }

    @Override
    protected void onStop() {
        super.onStop();
        // *** 关键：取消EventBus订阅者注册 ***
        EventBus.getDefault().unregister(this);
    }

    // *** 关键：EventBus事件订阅方法 ***
    @Subscribe(threadMode = ThreadMode.MAIN) // 确保在主线程更新UI
    public void onNewSpeedEvent(MessageEvents.NewSpeedEvent event) {
        // 收到速度更新事件，更新UI
        textView.setText(String.format("%.2f KM/H", event.speed));
        Log.d("MainActivity", "Received speed: " + event.speed + " km/h");
    }

    // ... (ServiceConnection, onRequestPermissionsResult, starServiceFunc, stopServiceFunc, requestBackgroundLocationPermission, requestFineLocationPermission 等方法保持不变)
    // 注意：原代码中starServiceFunc()创建了新的LocationService实例，这可能不是你想要的。
    // 如果你希望绑定到正在运行的服务，应该在bindService后通过ServiceConnection获取服务实例，而不是创建新实例。
    // 但对于EventBus通信，服务实例本身并不需要直接传递给Activity，只需EventBus注册即可。
    // 确保服务启动和绑定逻辑正确，以避免重复的服务实例或无法通信。
    private void starServiceFunc(){
        // 不再需要 mLocationService = new LocationService();
        // mServiceIntent 应该直接指向 LocationService.class
        mServiceIntent = new Intent(this, LocationService.class);
        if (!Util.isMyServiceRunning(LocationService.class, this)) {
            // 对于Android 8.0 (Oreo) 及更高版本，直接startService可能会抛出IllegalStateException
            // 应该使用 ContextCompat.startForegroundService(this, mServiceIntent);
            if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
                ContextCompat.startForegroundService(this, mServiceIntent);
            } else {
                startService(mServiceIntent);
            }
            // 绑定服务是可选的，如果Activity需要直接调用服务的方法，则需要绑定
            // 对于EventBus通信，绑定不是强制的，但可以用于其他目的
            bindService(mServiceIntent, connection, Context.BIND_AUTO_CREATE);

            Toast.makeText(this, getString(R.string.service_start_successfully), Toast.LENGTH_SHORT).show();
        } else {
            Toast.makeText(this, getString(R.string.service_already_running), Toast.LENGTH_SHORT).show();
        }
    }

    private void stopServiceFunc(){
        mServiceIntent = new Intent(this, LocationService.class); // 确保mServiceIntent指向正确的服务
        if (Util.isMyServiceRunning(LocationService.class, this)) {
            unbindService(connection); // 如果绑定了服务，停止服务前先解绑
            stopService(mServiceIntent);

            Toast.makeText(this, "Service stopped!!", Toast.LENGTH_SHORT).show();
        } else {
            Toast.makeText(this, "Service is already stopped!!", Toast.LENGTH_SHORT).show();
        }
    }
}

登录后复制

3.5 AndroidManifest.xml 配置

确保在AndroidManifest.xml中声明服务并请求必要的权限：

<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    package="com.example.yourapp">

    <uses-permission android:name="android.permission.ACCESS_FINE_LOCATION" />
    <uses-permission android:name="android.permission.ACCESS_COARSE_LOCATION" />
    <!-- Android 10 (API level 29) 及更高版本需要后台位置权限 -->
    <uses-permission android:name="android.permission.ACCESS_BACKGROUND_LOCATION" />
    <!-- 前台服务权限 -->
    <uses-permission android:name="android.permission.FOREGROUND_SERVICE"/>

    <application
        ...>
        <service
            android:name=".LocationService"
            android:enabled="true"
            android:exported="false" />
        <activity
            android:name=".MainActivity"
            ...>
            <intent-filter>
                <action android:name="android.intent.action.MAIN" />
                <category android:name="android.intent.category.LAUNCHER" />
            </intent-filter>
        </activity>
    </application>
</manifest>

登录后复制

4. 注意事项与最佳实践

权限管理： 务必在MainActivity中处理好运行时权限请求，包括ACCESS_FINE_LOCATION和针对Android 10+的ACCESS_BACKGROUND_LOCATION。用户必须授予这些权限才能正常获取位置数据。
前台服务通知： 前台服务必须伴随一个持续的通知。createNotificationChannel()方法负责创建通知渠道，并使用startForeground()将服务提升为前台服务。请确保通知内容对用户友好，清晰说明服务正在运行。
EventBus线程模式： 在@Subscribe注解中，threadMode = ThreadMode.MAIN至关重要。它确保onNewSpeedEvent方法总是在主线程（UI线程）上执行，从而可以安全地更新UI元素，避免CalledFromWrongThreadException。
EventBus生命周期管理： 始终在Activity的onStart()中注册EventBus，并在onStop()中注销。这可以防止内存泄漏和不必要的事件接收，确保在Activity可见时才进行UI更新。
服务启动与绑定： 在Android 8.0（API 26）及更高版本中，直接调用startService()来启动后台服务是有限制的。对于前台服务，应使用ContextCompat.startForegroundService(context, intent)来启动。服务绑定是可选的，如果Activity需要直接调用服务公开的方法，则需要绑定。对于EventBus通信，服务绑定不是强制的，因为通信是基于事件的。
Firebase集成： 原代码中已包含Firebase实时数据库的集成，用于存储实时和历史速度数据。这部分功能可以独立于UI更新逻辑，但很好地展示了后台数据持久化的能力。
错误处理： 在onLocationResult中，务必检查location对象是否为null，以避免空指针异常。