将应用扩展到穿戴式设备上,提升应用的健康与健身体验 搭载 Wear OS 的设备。
添加 Wear OS 模块
Android Studio 提供了一个方便的向导,供您向应用添加 Wear OS 模块。在 文件 >New Module 菜单中,选择 Wear OS,如下所示 图片:
<ph type="x-smartling-placeholder">![Android Studio 中的 Wear OS 模块向导](https://developer.android.google.cn/static/health-and-fitness/guides/basic-fitness-app/images/basic_fitness_app_img_8.png?authuser=7&hl=sr)
请务必注意,Minimum SDK 必须为 API 30 或更高 ,让您使用最新版本的健康服务。健康服务 通过配置健康状况,更轻松地跟踪指标和记录数据 传感器。
完成向导后,请同步您的项目。下面的 Run 配置:
<ph type="x-smartling-placeholder">![显示 Wear OS 应用运行按钮的图片](https://developer.android.google.cn/static/health-and-fitness/guides/basic-fitness-app/images/basic_fitness_app_img_5.png?authuser=7&hl=sr)
这样,您就可以在穿戴式设备上运行 Wear OS 模块。您有两种选择:
运行配置会将应用部署到 Wear OS 模拟器,或者 并显示“hello world”体验这是基本的界面设置,使用 Compose for Wear OS,了解如何开始使用您的应用。
添加健康服务和 Hilt
将以下库集成到您的 Wear OS 模块中:
创建健康服务管理器
为了更方便地使用健康服务, 和更流畅的 API,您可以创建如下所示的封装容器:
private const val TAG = "WATCHMAIN"
class HealthServicesManager(context: Context) {
private val measureClient = HealthServices.getClient(context).measureClient
suspend fun hasHeartRateCapability() = runCatching {
val capabilities = measureClient.getCapabilities()
(DataType.HEART_RATE_BPM in capabilities.supportedDataTypesMeasure)
}.getOrDefault(false)
/**
* Returns a cold flow. When activated, the flow will register a callback for heart rate data
* and start to emit messages. When the consuming coroutine is canceled, the measure callback
* is unregistered.
*
* [callbackFlow] creates a bridge between a callback-based API and Kotlin flows.
*/
@ExperimentalCoroutinesApi
fun heartRateMeasureFlow(): Flow<MeasureMessage> = callbackFlow {
val callback = object : MeasureCallback {
override fun onAvailabilityChanged(dataType: DeltaDataType<*, *>, availability: Availability) {
// Only send back DataTypeAvailability (not LocationAvailability)
if (availability is DataTypeAvailability) {
trySendBlocking(MeasureMessage.MeasureAvailability(availability))
}
}
override fun onDataReceived(data: DataPointContainer) {
val heartRateBpm = data.getData(DataType.HEART_RATE_BPM)
Log.d(TAG, "💓 Received heart rate: ${heartRateBpm.first().value}")
trySendBlocking(MeasureMessage.MeasureData(heartRateBpm))
}
}
Log.d(TAG, "⌛ Registering for data...")
measureClient.registerMeasureCallback(DataType.HEART_RATE_BPM, callback)
awaitClose {
Log.d(TAG, "👋 Unregistering for data")
runBlocking {
measureClient.unregisterMeasureCallback(DataType.HEART_RATE_BPM, callback)
}
}
}
}
sealed class MeasureMessage {
class MeasureAvailability(val availability: DataTypeAvailability) : MeasureMessage()
class MeasureData(val data: List<SampleDataPoint<Double>>) : MeasureMessage()
}
创建 Hilt 模块以对其进行管理后,请使用以下代码段:
@Module
@InstallIn(SingletonComponent::class)
internal object DataModule {
@Provides
@Singleton
fun provideHealthServices(@ApplicationContext context: Context): HealthServicesManager = HealthServicesManager(context)
}
您可以将 HealthServicesManager
作为任何其他 Hilt 依赖项注入。
新的 HealthServicesManager
提供了一种 heartRateMeasureFlow()
方法,
为心脏监测器注册监听器并发出接收的数据。
在穿戴式设备上启用数据更新
与健身相关的数据更新需要 BODY_SENSORS
权限。如果您
请在您的应用中声明 BODY_SENSORS
权限,
应用的清单文件中然后,请求权限,如以下代码段所示:
val permissionState = rememberPermissionState(
permission = Manifest.permission.BODY_SENSORS,
onPermissionResult = { granted -> /* do something */ }
)
[...]
if (permissionState.status.isGranted) {
// do something
} else {
permissionState.launchPermissionRequest()
}
如果您在实体设备上测试应用,数据应开始更新。
从 Wear OS 4 开始,模拟器也会自动显示测试数据。在上一个 您可以模拟来自传感器的数据流。在终端中 窗口中,运行以下 ADB 命令:
adb shell am broadcast \
-a "whs.USE_SYNTHETIC_PROVIDERS" \
com.google.android.wearable.healthservices
如要查看不同的心率值,请尝试模拟不同的锻炼。 此命令模拟步行:
adb shell am broadcast \
-a "whs.synthetic.user.START_WALKING" \
com.google.android.wearable.healthservices
此命令模拟运行:
adb shell am broadcast \
-a "whs.synthetic.user.START_RUNNING" \
com.google.android.wearable.healthservices
如需停止模拟数据,请运行以下命令:
adb shell am broadcast -a \
"whs.USE_SENSOR_PROVIDERS" \
com.google.android.wearable.healthservices
读取心率数据
授予 BODY_SENSORS
权限后,您可以读取用户的心率
HealthServicesManager
中的 (heartRateMeasureFlow()
)。在 Wear OS 应用的
界面中,显示了由设备上的传感器测量的当前心率值
。
在 ViewModel
中,开始使用心率流对象收集数据,
如以下代码段所示:
val hr: MutableState<Double> = mutableStateOf(0.0)
[...]
healthServicesManager
.heartRateMeasureFlow()
.takeWhile { enabled.value }
.collect { measureMessage ->
when (measureMessage) {
is MeasureData -> {
val latestHeartRateValue = measureMessage.data.last().value
hr.value = latestHeartRateValue
}
is MeasureAvailability -> availability.value =
measureMessage.availability
}
}
使用类似于以下内容的可组合项对象,在以下位置显示实时数据: 应用界面:
val heartRate by viewModel.hr
Text(
text = "Heart Rate: $heartRate",
style = MaterialTheme.typography.display1
)
将数据发送到手持设备
如需将健康和健身数据发送到手持设备,请使用 DataClient
类。以下代码段展示了如何发送爱心
评估您的应用之前收集的数据:
class HealthServicesManager(context: Context) {
private val dataClient by lazy { Wearable.getDataClient(context) }
[...]
suspend fun sendToHandheldDevice(heartRate: Int) {
try {
val result = dataClient
.putDataItem(PutDataMapRequest
.create("/heartrate")
.apply { dataMap.putInt("heartrate", heartRate) }
.asPutDataRequest()
.setUrgent())
.await()
Log.d(TAG, "DataItem saved: $result")
} catch (cancellationException: CancellationException) {
throw cancellationException
} catch (exception: Exception) {
Log.d(TAG, "Saving DataItem failed: $exception")
}
}
}
在手机上接收数据
要在手机上接收数据,请创建一个
WearableListenerService
:
@AndroidEntryPoint
class DataLayerListenerService : WearableListenerService() {
@Inject
lateinit var heartRateMonitor: HeartRateMonitor
override fun onDataChanged(dataEvents: DataEventBuffer) {
dataEvents.forEach { event ->
when (event.type) {
DataEvent.TYPE_CHANGED -> {
event.dataItem.run {
if (uri.path?.compareTo("/heartrate") == 0) {
val heartRate = DataMapItem.fromDataItem(this)
.dataMap.getInt(HR_KEY)
Log.d("DataLayerListenerService",
"New heart rate value received: $heartRate")
heartRateMonitor.send(heartRate)
}
}
}
DataEvent.TYPE_DELETED -> {
// DataItem deleted
}
}
}
}
}
完成此步骤后,您会注意到一些有趣的细节:
- 借助
@AndroidEntryPoint
注解,我们可以在此类中使用 Hilt @Inject lateinit var heartRateMonitor: HeartRateMonitor
确实会 在此类中注入依赖项- 该类会实现
onDataChanged()
并接收一系列事件 您可以解析并使用
通过以下 HeartRateMonitor
逻辑,您可以发送接收的心率
值添加到应用代码库的其他部分:
class HeartRateMonitor {
private val datapoints = MutableSharedFlow<Int>(extraBufferCapacity = 10)
fun receive(): SharedFlow<Int> = datapoints.asSharedFlow()
fun send(hr: Int) {
datapoints.tryEmit(hr)
}
}
数据总线接收来自 onDataChanged()
方法的事件,并发出这些事件
可供使用 SharedFlow
的数据观察器使用。
最后一位数是手机应用中 Service
的声明
AndroidManifest.xml
:
<service
android:name=".DataLayerListenerService"
android:exported="true">
<intent-filter>
<!-- listeners receive events that match the action and data filters -->
<action android:name="com.google.android.gms.wearable.DATA_CHANGED" />
<data
android:host="*"
android:pathPrefix="/heartrate"
android:scheme="wear" />
</intent-filter>
</service>
在手持设备上显示实时数据
在手持设备上运行的应用部分中,注入
HeartRateMonitor
传递到视图模型的构造函数中。这部HeartRateMonitor
对象观察心率数据并根据需要发出界面更新。