Wear-এ ডেটা লেয়ার ইভেন্টগুলি পরিচালনা করুন

যখন আপনি ডেটা লেয়ার API-তে কল করেন, তখন কলটি সম্পূর্ণ হয়ে গেলে আপনি কলটির স্থিতি পেতে পারেন। আপনি Wear OS by Google নেটওয়ার্কের যেকোনো জায়গায় আপনার অ্যাপের ডেটা পরিবর্তনের ফলে সৃষ্ট ডেটা ইভেন্টগুলিও শুনতে পারেন।

ডেটা লেয়ার এপিআই-এর সাথে কার্যকরভাবে কাজ করার একটি উদাহরণের জন্য, অ্যান্ড্রয়েড ডেটালেয়ার নমুনা অ্যাপটি দেখুন।

ডেটা লেয়ার কলের স্থিতির জন্য অপেক্ষা করুন

Data Layer API-তে কল করা হলে—যেমন DataClient ক্লাসের putDataItem পদ্ধতি ব্যবহার করে করা কল—কখনও কখনও Task<ResultType> অবজেক্ট ফেরত আসে। Task অবজেক্ট তৈরি হওয়ার সাথে সাথেই, অপারেশনটি ব্যাকগ্রাউন্ডে সারিবদ্ধ হয়ে যায়। এর পরে যদি আপনি আর কিছু না করেন, তাহলে অপারেশনটি অবশেষে নীরবে সম্পন্ন হয়।

তবে, অপারেশন সম্পন্ন হওয়ার পরে আপনি সাধারণত ফলাফলের সাথে কিছু করতে চান, তাই Task অবজেক্ট আপনাকে ফলাফলের স্থিতির জন্য অপেক্ষা করতে দেয়, হয় অ্যাসিঙ্ক্রোনাসভাবে বা সিঙ্ক্রোনাসভাবে।

অ্যাসিঙ্ক্রোনাস কল

যদি আপনার কোডটি মূল UI থ্রেডে চলমান থাকে, তাহলে Data Layer API-তে ব্লকিং কল করবেন না। Task অবজেক্টে একটি কলব্যাক পদ্ধতি যোগ করে অ্যাসিঙ্ক্রোনাসভাবে কলগুলি চালান, যা অপারেশন সম্পন্ন হলে কার্যকর হয়:

// Using Kotlin function references
task.addOnSuccessListener(::handleDataItem)
task.addOnFailureListener(::handleDataItemError)
task.addOnCompleteListener(::handleTaskComplete)
...
fun handleDataItem(dataItem: DataItem) { ... }
fun handleDataItemError(exception: Exception) { ... }
fun handleTaskComplete(task: Task<DataItem>) { ... }

বিভিন্ন কাজের সম্পাদনের জন্য শৃঙ্খলিতকরণ সহ অন্যান্য সম্ভাবনার জন্য টাস্ক API দেখুন।

সিঙ্ক্রোনাস কল

যদি আপনার কোডটি WearableListenerService এর মতো ব্যাকগ্রাউন্ড সার্ভিসে আলাদা হ্যান্ডলার থ্রেডে চলছে, তাহলে কলগুলি ব্লক করা ঠিক আছে। এই ক্ষেত্রে, আপনি Task অবজেক্টে Tasks.await() কল করতে পারেন, যা অনুরোধটি সম্পূর্ণ না হওয়া পর্যন্ত এবং একটি Result অবজেক্ট ফেরত না দেওয়া পর্যন্ত ব্লক করে। এটি নিম্নলিখিত উদাহরণে দেখানো হয়েছে।

দ্রষ্টব্য: মূল থ্রেডে থাকাকালীন এটি কল করবেন না।

try {
    Tasks.await(dataItemTask).apply {
        Log.d(TAG, "Data item set: $uri")
    }
}
catch (e: ExecutionException) { ... }
catch (e: InterruptedException) { ... }

ডেটা লেয়ার ইভেন্টগুলি শুনুন

যেহেতু ডেটা স্তরটি হ্যান্ডহেল্ড এবং পরিধেয় ডিভাইসগুলিতে ডেটা সিঙ্ক্রোনাইজ করে এবং প্রেরণ করে, তাই আপনাকে সাধারণত ডেটা আইটেম তৈরি এবং বার্তা গ্রহণের মতো গুরুত্বপূর্ণ ইভেন্টগুলি শুনতে হবে।

ডেটা লেয়ার ইভেন্টগুলি শোনার জন্য, আপনার কাছে দুটি বিকল্প রয়েছে:

• এমন একটি পরিষেবা তৈরি করুন যা WearableListenerService প্রসারিত করে।
• DataClient.OnDataChangedListener ইন্টারফেসটি বাস্তবায়ন করে এমন একটি কার্যকলাপ বা ক্লাস তৈরি করুন।

এই দুটি বিকল্পের সাহায্যে, আপনি যে ইভেন্টগুলি পরিচালনা করতে আগ্রহী তার জন্য ডেটা ইভেন্ট কলব্যাক পদ্ধতিগুলিকে ওভাররাইড করেন।

দ্রষ্টব্য: শ্রোতা বাস্তবায়ন নির্বাচন করার সময় আপনার অ্যাপের ব্যাটারি ব্যবহারের কথা বিবেচনা করুন। একটি WearableListenerService অ্যাপের ম্যানিফেস্টে নিবন্ধিত থাকে এবং যদি এটি ইতিমধ্যেই চালু না থাকে তবে অ্যাপটি চালু করতে পারে। যদি আপনার অ্যাপটি ইতিমধ্যেই চলমান থাকাকালীন ইভেন্টগুলি শুনতে হয়, যা প্রায়শই ইন্টারেক্টিভ অ্যাপ্লিকেশনগুলির ক্ষেত্রে হয়, তাহলে WearableListenerService ব্যবহার করবেন না। পরিবর্তে, একটি লাইভ শ্রোতা নিবন্ধন করুন। উদাহরণস্বরূপ, DataClient ক্লাসের addListener পদ্ধতি ব্যবহার করুন। এটি সিস্টেমের উপর লোড কমাতে এবং ব্যাটারির ব্যবহার কমাতে পারে।

একটি WearableListenerService ব্যবহার করুন

আপনি সাধারণত আপনার পরিধেয় এবং হ্যান্ডহেল্ড উভয় অ্যাপেই WearableListenerService এর ইনস্ট্যান্স তৈরি করেন। তবে, যদি আপনি কোনও অ্যাপের ডেটা ইভেন্টে আগ্রহী না হন, তাহলে আপনাকে সেই অ্যাপে পরিষেবাটি বাস্তবায়ন করার প্রয়োজন নেই।

উদাহরণস্বরূপ, আপনার কাছে একটি হ্যান্ডহেল্ড অ্যাপ থাকতে পারে যা ডেটা আইটেম অবজেক্ট সেট করে এবং গ্রহণ করে এবং একটি পরিধেয় অ্যাপ থাকতে পারে যা তার UI আপডেট করার জন্য এই আপডেটগুলি শোনে। পরিধেয় অ্যাপটি কখনই কোনও ডেটা আইটেম আপডেট করে না, তাই হ্যান্ডহেল্ড অ্যাপটি পরিধেয় অ্যাপ থেকে কোনও ডেটা ইভেন্ট শোনে না।

WearableListenerService ব্যবহার করে আপনি যে ইভেন্টগুলি শুনতে পারেন তার মধ্যে কয়েকটি হল:

• onDataChanged() : যখনই কোনও ডেটা আইটেম অবজেক্ট তৈরি, মুছে ফেলা বা পরিবর্তন করা হয়, তখন সিস্টেমটি সমস্ত সংযুক্ত নোডে এই কলব্যাকটি ট্রিগার করে।
• onMessageReceived() : একটি নোড থেকে প্রেরিত একটি বার্তা লক্ষ্য নোডে এই কলব্যাকটি ট্রিগার করে।
• onCapabilityChanged() : যখন আপনার অ্যাপের একটি ইনস্ট্যান্সের বিজ্ঞাপনে দেখানো কোনও ক্ষমতা নেটওয়ার্কে উপলব্ধ হয়, তখন সেই ইভেন্টটি এই কলব্যাকটি ট্রিগার করে। আপনি যদি কাছাকাছি কোনও নোড খুঁজছেন, তাহলে আপনি কলব্যাকে প্রদত্ত নোডগুলির isNearby() পদ্ধতিটি অনুসন্ধান করতে পারেন।

আপনি ChannelClient.ChannelCallback থেকেও ইভেন্ট শুনতে পারেন, যেমন onChannelOpened() ।

পূর্ববর্তী সমস্ত ইভেন্টগুলি মূল থ্রেডে নয়, একটি ব্যাকগ্রাউন্ড থ্রেডে কার্যকর করা হয়।

একটি WearableListenerService তৈরি করতে, এই পদক্ষেপগুলি অনুসরণ করুন:

1. এমন একটি ক্লাস তৈরি করুন যা WearableListenerService প্রসারিত করে।
2. আপনার আগ্রহের ইভেন্টগুলি শুনুন, যেমন onDataChanged() ।
3. আপনার WearableListenerService সম্পর্কে সিস্টেমকে অবহিত করার জন্য আপনার Android ম্যানিফেস্টে একটি ইন্টেন্ট ফিল্টার ঘোষণা করুন। এই ঘোষণাটি সিস্টেমকে প্রয়োজন অনুসারে আপনার পরিষেবাকে আবদ্ধ করতে দেয়।

নিম্নলিখিত উদাহরণে WearableListenerService কীভাবে বাস্তবায়ন করতে হয় তা দেখানো হয়েছে:

class DataLayerListenerService : WearableListenerService() {

    override fun onDataChanged(dataEvents: DataEventBuffer) {
        if (Log.isLoggable(TAG, Log.DEBUG)) {
            Log.d(TAG, "onDataChanged: $dataEvents")
        }

        // Loop through the events and send a message
        // to the node that created the data item.
        dataEvents
            .map { it.dataItem.uri }
            .forEach { uri ->
                // Get the node ID from the host value of the URI.
                val nodeId: String = uri.host!!
                // Set the data of the message to be the bytes of the URI.
                val payload: ByteArray = uri.toString().toByteArray()

                // Send the RPC.
                Wearable.getMessageClient(this)
                    .sendMessage(
                        nodeId,
                        DATA_ITEM_RECEIVED_PATH,
                        payload
                    )
            }
    }
}
DataLayerService.kt

নিম্নলিখিত বিভাগে ব্যাখ্যা করা হয়েছে কিভাবে এই শ্রোতার সাথে একটি ইন্টেন্ট ফিল্টার ব্যবহার করতে হয়।

WearableListenerService-এর সাথে ফিল্টার ব্যবহার করুন

পূর্ববর্তী বিভাগে দেখানো WearableListenerService উদাহরণের জন্য একটি ইন্টেন্ট ফিল্টার এইরকম দেখতে হতে পারে:

<service
    android:name=".snippets.datalayer.DataLayerListenerService"
    android:exported="true"
    tools:ignore="ExportedService" >
    <intent-filter>
        <action android:name="com.google.android.gms.wearable.DATA_CHANGED" />
        <data
            android:scheme="wear"
            android:host="*"
            android:path="/start-activity" />
    </intent-filter>
</service>
AndroidManifest.xml

DATA_CHANGED অ্যাকশন ফিল্টার সিস্টেমকে বলে যে আপনার অ্যাপ ডেটা লেয়ার ইভেন্টগুলিতে আগ্রহী।

এই উদাহরণে, ঘড়িটি /start-activity ডেটা আইটেমটি শোনে, এবং ফোনটি /data-item-received ( DATA_ITEM_RECEIVED_PATH ) বার্তার প্রতিক্রিয়া শোনে।

স্ট্যান্ডার্ড অ্যান্ড্রয়েড ফিল্টার ম্যাচিং নিয়ম প্রযোজ্য। আপনি প্রতিটি ম্যানিফেস্টে একাধিক পরিষেবা, প্রতিটি পরিষেবাতে একাধিক ইন্টেন্ট ফিল্টার, প্রতিটি ফিল্টারে একাধিক ক্রিয়া এবং প্রতিটি ফিল্টারে একাধিক ডেটা স্তবক নির্দিষ্ট করতে পারেন। ফিল্টারগুলি একটি ওয়াইল্ডকার্ড হোস্টে বা একটি নির্দিষ্ট হোস্টে মিলতে পারে। একটি ওয়াইল্ডকার্ড হোস্টে মিল করতে, host="*" ব্যবহার করুন। একটি নির্দিষ্ট হোস্টে মিল করতে, host=<node_id> নির্দিষ্ট করুন।

আপনি একটি আক্ষরিক পাথ বা পাথ প্রিফিক্সও মেলাতে পারেন। এটি করার জন্য, আপনাকে একটি ওয়াইল্ডকার্ড বা নির্দিষ্ট হোস্ট নির্দিষ্ট করতে হবে। অন্যথায়, সিস্টেম আপনার নির্দিষ্ট পাথটি উপেক্ষা করবে।

Wear OS কোন ধরণের ফিল্টার সমর্থন করে সে সম্পর্কে আরও তথ্যের জন্য, WearableListenerService এর API রেফারেন্স ডকুমেন্টেশন দেখুন।

ডেটা ফিল্টার এবং ম্যাচিং নিয়ম সম্পর্কে আরও তথ্যের জন্য, <data> ম্যানিফেস্ট এলিমেন্টের জন্য API রেফারেন্স ডকুমেন্টেশন দেখুন।

ইন্টেন্ট ফিল্টার মেলানোর সময়, দুটি গুরুত্বপূর্ণ নিয়ম মনে রাখবেন:

• যদি ইন্টেন্ট ফিল্টারের জন্য কোনও স্কিম নির্দিষ্ট না করা থাকে, তাহলে সিস্টেমটি অন্যান্য সমস্ত URI বৈশিষ্ট্য উপেক্ষা করে।
• যদি ফিল্টারের জন্য কোনও হোস্ট নির্দিষ্ট না করা থাকে, তাহলে সিস্টেমটি সমস্ত পাথ অ্যাট্রিবিউট উপেক্ষা করে।

একটি লাইভ শ্রোতা ব্যবহার করুন

যদি আপনার অ্যাপটি শুধুমাত্র ডেটা-লেয়ার ইভেন্টগুলির বিষয়ে চিন্তা করে যখন ব্যবহারকারী অ্যাপের সাথে ইন্টারঅ্যাক্ট করছে, তাহলে প্রতিটি ডেটা পরিবর্তন পরিচালনা করার জন্য দীর্ঘমেয়াদী পরিষেবার প্রয়োজন নাও হতে পারে। এই ক্ষেত্রে, আপনি নিম্নলিখিত এক বা একাধিক ইন্টারফেস প্রয়োগ করে একটি কার্যকলাপের ইভেন্টগুলি শুনতে পারেন:

• DataClient.OnDataChangedListener
• MessageClient.OnMessageReceivedListener
• CapabilityClient.OnCapabilityChangedListener
• ChannelClient.ChannelCallback

ডেটা ইভেন্ট শোনার জন্য একটি কার্যকলাপ তৈরি করতে, এই পদক্ষেপগুলি অনুসরণ করুন:

1. প্রয়োজনীয় ইন্টারফেসগুলি বাস্তবায়ন করুন।
2. onCreate() অথবা onResume() পদ্ধতিতে, Wearable.getDataClient(this).addListener() , MessageClient.addListener() , CapabilityClient.addListener() , অথবা ChannelClient.registerChannelCallback() এ কল করে Google Play পরিষেবাগুলিকে জানান যে আপনার কার্যকলাপ ডেটা লেয়ার ইভেন্টগুলিতে আগ্রহী।
3. onStop() অথবা onPause() এ, DataClient.removeListener() , MessageClient.removeListener() , CapabilityClient.removeListener() , অথবা ChannelClient.unregisterChannelCallback() দিয়ে যেকোনো শ্রোতাকে নিবন্ধনমুক্ত করুন।
4. যদি কোনও কার্যকলাপের জন্য শুধুমাত্র একটি নির্দিষ্ট পাথ প্রিফিক্স সহ ইভেন্টগুলি গ্রহণ করার প্রয়োজন হয়, তাহলে কেবলমাত্র বর্তমান অ্যাপ্লিকেশন অবস্থার সাথে প্রাসঙ্গিক ডেটা গ্রহণ করার জন্য একটি প্রিফিক্স ফিল্টার সহ একটি শ্রোতা যোগ করুন।
5. আপনার প্রয়োগ করা ইন্টারফেসের উপর নির্ভর করে onDataChanged() , onMessageReceived() , onCapabilityChanged() , অথবা ChannelClient.ChannelCallback থেকে পদ্ধতিগুলি প্রয়োগ করুন। এই পদ্ধতিগুলি প্রধান থ্রেডে কল করা হয়, অথবা আপনি WearableOptions ব্যবহার করে একটি কাস্টম Looper নির্দিষ্ট করতে পারেন।

এখানে একটি উদাহরণ দেওয়া হল যা DataClient.OnDataChangedListener প্রয়োগ করে:

class MainActivity : Activity(), DataClient.OnDataChangedListener {

    public override fun onResume() {
        super.onResume()
        Wearable.getDataClient(this).addListener(this)
    }

    override fun onPause() {
        super.onPause()
        Wearable.getDataClient(this).removeListener(this)
    }

    override fun onDataChanged(dataEvents: DataEventBuffer) {
        dataEvents.forEach { event ->
            if (event.type == DataEvent.TYPE_DELETED) {
                Log.d(TAG, "DataItem deleted: " + event.dataItem.uri)
            } else if (event.type == DataEvent.TYPE_CHANGED) {
                Log.d(TAG, "DataItem changed: " + event.dataItem.uri)
            }
        }
    }
}
DataLayerService.kt

সতর্কতা: Wearable Data Layer API ব্যবহার করার আগে, এটি কোনও ডিভাইসে উপলব্ধ কিনা তা পরীক্ষা করে নিন; অন্যথায়, একটি ব্যতিক্রম ঘটতে পারে। Horologist এ বাস্তবায়িত GoogleApiAvailability ক্লাসটি ব্যবহার করুন।

লাইভ শ্রোতাদের সাথে ফিল্টার ব্যবহার করুন

পূর্বে উল্লেখ করা হয়েছে, ঠিক যেমন আপনি ম্যানিফেস্ট-ভিত্তিক WearableListenerService অবজেক্টের জন্য ইন্টেন্ট ফিল্টার নির্দিষ্ট করতে পারেন, তেমনি Wearable API এর মাধ্যমে লাইভ লিসেনার নিবন্ধন করার সময় আপনি ইন্টেন্ট ফিল্টার ব্যবহার করতে পারেন। API-ভিত্তিক লাইভ লিসেনার এবং ম্যানিফেস্ট-ভিত্তিক লিসেনার উভয়ের ক্ষেত্রেই একই নিয়ম প্রযোজ্য।

একটি সাধারণ ধরণ হল একটি অ্যাক্টিভিটির onResume() পদ্ধতিতে একটি নির্দিষ্ট পাথ বা পাথ প্রিফিক্স দিয়ে একজন শ্রোতাকে নিবন্ধন করা এবং তারপর অ্যাক্টিভিটির onPause() পদ্ধতিতে শ্রোতাটিকে সরিয়ে ফেলা। এই পদ্ধতিতে শ্রোতাদের বাস্তবায়ন করলে আপনার অ্যাপটি আরও নির্বাচনীভাবে ইভেন্টগুলি গ্রহণ করতে পারে, এর নকশা এবং দক্ষতা উন্নত হয়।